var emptyFunc …
var coreNamespaceResource …
const storageWatchListPageSize …
const defaultBookmarkFrequency …
type Config …
type watchersMap …
func (wm watchersMap) addWatcher(w *cacheWatcher, number int) { … }
func (wm watchersMap) deleteWatcher(number int) { … }
func (wm watchersMap) terminateAll(done func(*cacheWatcher)) { … }
type indexedWatchers …
func (i *indexedWatchers) addWatcher(w *cacheWatcher, number int, scope namespacedName, value string, supported bool) { … }
func (i *indexedWatchers) deleteWatcher(number int, scope namespacedName, value string, supported bool) { … }
func (i *indexedWatchers) terminateAll(groupResource schema.GroupResource, done func(*cacheWatcher)) { … }
type watcherBookmarkTimeBuckets …
func newTimeBucketWatchers(clock clock.Clock, bookmarkFrequency time.Duration) *watcherBookmarkTimeBuckets { … }
func (t *watcherBookmarkTimeBuckets) addWatcherThreadUnsafe(w *cacheWatcher) bool { … }
func (t *watcherBookmarkTimeBuckets) popExpiredWatchersThreadUnsafe() [][]*cacheWatcher { … }
type filterWithAttrsFunc …
type indexedTriggerFunc …
type Cacher …
func (c *Cacher) RequestWatchProgress(ctx context.Context) error { … }
func NewCacherFromConfig(config Config) (*Cacher, error) { … }
func (c *Cacher) startCaching(stopChannel <-chan struct{ … }
func (c *Cacher) Versioner() storage.Versioner { … }
func (c *Cacher) Create(ctx context.Context, key string, obj, out runtime.Object, ttl uint64) error { … }
func (c *Cacher) Delete(
ctx context.Context, key string, out runtime.Object, preconditions *storage.Preconditions,
validateDeletion storage.ValidateObjectFunc, _ runtime.Object, opts storage.DeleteOptions) error { … }
type namespacedName …
func (c *Cacher) Watch(ctx context.Context, key string, opts storage.ListOptions) (watch.Interface, error) { … }
func (c *Cacher) Get(ctx context.Context, key string, opts storage.GetOptions, objPtr runtime.Object) error { … }
func shouldDelegateList(opts storage.ListOptions) bool { … }
func computeListLimit(opts storage.ListOptions) int64 { … }
func shouldDelegateListOnNotReadyCache(opts storage.ListOptions) bool { … }
func (c *Cacher) listItems(ctx context.Context, listRV uint64, key string, pred storage.SelectionPredicate, recursive bool) ([]interface{ … }
func (c *Cacher) GetList(ctx context.Context, key string, opts storage.ListOptions, listObj runtime.Object) error { … }
func (c *Cacher) GuaranteedUpdate(
ctx context.Context, key string, destination runtime.Object, ignoreNotFound bool,
preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, _ runtime.Object) error { … }
func (c *Cacher) Count(pathPrefix string) (int64, error) { … }
func (c *Cacher) ReadinessCheck() error { … }
func baseObjectThreadUnsafe(object runtime.Object) runtime.Object { … }
func (c *Cacher) triggerValuesThreadUnsafe(event *watchCacheEvent) ([]string, bool) { … }
func (c *Cacher) processEvent(event *watchCacheEvent) { … }
func (c *Cacher) dispatchEvents() { … }
func setCachingObjects(event *watchCacheEvent, versioner storage.Versioner) { … }
func (c *Cacher) dispatchEvent(event *watchCacheEvent) { … }
func (c *Cacher) startDispatchingBookmarkEventsLocked() { … }
func (c *Cacher) startDispatching(event *watchCacheEvent) { … }
func (c *Cacher) finishDispatching() { … }
func (c *Cacher) terminateAllWatchers() { … }
func (c *Cacher) stopWatcherLocked(watcher *cacheWatcher) { … }
func (c *Cacher) isStopped() bool { … }
func (c *Cacher) Stop() { … }
func forgetWatcher(c *Cacher, w *cacheWatcher, index int, scope namespacedName, triggerValue string, triggerSupported bool) func(bool) { … }
func filterWithAttrsAndPrefixFunction(key string, p storage.SelectionPredicate) filterWithAttrsFunc { … }
func (c *Cacher) LastSyncResourceVersion() (uint64, error) { … }
func (c *Cacher) getBookmarkAfterResourceVersionLockedFunc(parsedResourceVersion, requiredResourceVersion uint64, opts storage.ListOptions) (func() uint64, error) { … }
func isListWatchRequest(opts storage.ListOptions) bool { … }
func (c *Cacher) getWatchCacheResourceVersion(ctx context.Context, parsedWatchResourceVersion uint64, opts storage.ListOptions) (uint64, error) { … }
func (c *Cacher) waitUntilWatchCacheFreshAndForceAllEvents(ctx context.Context, requestedWatchRV uint64, opts storage.ListOptions) error { … }
func (c *Cacher) Wait(ctx context.Context) error { … }
func (c *Cacher) setInitialEventsEndBookmarkIfRequested(cacheInterval *watchCacheInterval, opts storage.ListOptions, currentResourceVersion uint64) { … }
type errWatcher …
func newErrWatcher(err error) *errWatcher { … }
func (c *errWatcher) ResultChan() <-chan watch.Event { … }
func (c *errWatcher) Stop() { … }
type immediateCloseWatcher …
func newImmediateCloseWatcher() *immediateCloseWatcher { … }
func (c *immediateCloseWatcher) ResultChan() <-chan watch.Event { … }
func (c *immediateCloseWatcher) Stop() { … }