cachemanager

Jan 30, 2023

Changes in this version

+ var ErrInMemoryCacheMiss = errors.New("in-memory cache miss")

+ type CacheAgent struct

+ func NewCacheAgents(informerFactory informers.SharedInformerFactory, store StorageWrapper) *CacheAgent

+ func (ca *CacheAgent) HasAny(items ...string) bool

type StorageWrapper

+ DeleteComponentResources func(component string) error

+ GetClusterInfo func(key storage.ClusterInfoKey) ([]byte, error)

+ GetStorage func() storage.Store

+ KeyFunc func(info storage.KeyBuildInfo) (storage.Key, error)

+ ListResourceKeysOfComponent func(component string, gvr schema.GroupVersionResource) ([]storage.Key, error)

+ Name func() string

+ ReplaceComponentList func(component string, gvr schema.GroupVersionResource, namespace string, ...) error

+ SaveClusterInfo func(key storage.ClusterInfoKey, content []byte) error

Aug 6, 2021

Changes in this version

type CacheManager

+ DeleteKindFor func(gvr schema.GroupVersionResource) error

May 26, 2021

Changes in this version

+ type CacheManager interface

+ CacheResponse func(req *http.Request, prc io.ReadCloser, stopCh <-chan struct{}) error

+ CanCacheFor func(req *http.Request) bool

+ ListCacheAgents func() []string

+ QueryCache func(req *http.Request) (runtime.Object, error)

+ UpdateCacheAgents func(agents []string) error

+ func NewCacheManager(storage StorageWrapper, serializerMgr *serializer.SerializerManager) (CacheManager, error)

+ type StorageWrapper interface

+ Create func(key string, obj runtime.Object) error

+ Delete func(key string) error

+ DeleteCollection func(rootKey string) error

+ Get func(key string) (runtime.Object, error)

+ GetRaw func(key string) ([]byte, error)

+ List func(key string) ([]runtime.Object, error)

+ ListKeys func(key string) ([]string, error)

+ Replace func(rootKey string, objs map[string]runtime.Object) error

+ Update func(key string, obj runtime.Object) error

+ UpdateRaw func(key string, contents []byte) error

+ func NewStorageWrapper(storage storage.Store) StorageWrapper