kubernetes/staging/src/k8s.io/client-go/tools/cache/thread_safe_store.go

type ThreadSafeStore …

type storeIndex …

func (i *storeIndex) reset() { … }

func (i *storeIndex) getKeysFromIndex(indexName string, obj interface{ … }

func (i *storeIndex) getKeysByIndex(indexName, indexedValue string) (sets.String, error) { … }

func (i *storeIndex) getIndexValues(indexName string) []string { … }

func (i *storeIndex) addIndexers(newIndexers Indexers) error { … }

// updateSingleIndex modifies the objects location in the named index:
// - for create you must provide only the newObj
// - for update you must provide both the oldObj and the newObj
// - for delete you must provide only the oldObj
// updateSingleIndex must be called from a function that already has a lock on the cache
func (i *storeIndex) updateSingleIndex(name string, oldObj interface{ … }

// updateIndices modifies the objects location in the managed indexes:
// - for create you must provide only the newObj
// - for update you must provide both the oldObj and the newObj
// - for delete you must provide only the oldObj
// updateIndices must be called from a function that already has a lock on the cache
func (i *storeIndex) updateIndices(oldObj interface{ … }

func (i *storeIndex) addKeyToIndex(key, indexValue string, index Index) { … }

func (i *storeIndex) deleteKeyFromIndex(key, indexValue string, index Index) { … }

type threadSafeMap …

func (c *threadSafeMap) Add(key string, obj interface{ … }

func (c *threadSafeMap) Update(key string, obj interface{ … }

func (c *threadSafeMap) Delete(key string) { … }

func (c *threadSafeMap) Get(key string) (item interface{ … }

func (c *threadSafeMap) List() []interface{ … }

// ListKeys returns a list of all the keys of the objects currently
// in the threadSafeMap.
func (c *threadSafeMap) ListKeys() []string { … }

func (c *threadSafeMap) Replace(items map[string]interface{ … }

// Index returns a list of items that match the given object on the index function.
// Index is thread-safe so long as you treat all items as immutable.
func (c *threadSafeMap) Index(indexName string, obj interface{ … }

// ByIndex returns a list of the items whose indexed values in the given index include the given indexed value
func (c *threadSafeMap) ByIndex(indexName, indexedValue string) ([]interface{ … }

// IndexKeys returns a list of the Store keys of the objects whose indexed values in the given index include the given indexed value.
// IndexKeys is thread-safe so long as you treat all items as immutable.
func (c *threadSafeMap) IndexKeys(indexName, indexedValue string) ([]string, error) { … }

func (c *threadSafeMap) ListIndexFuncValues(indexName string) []string { … }

func (c *threadSafeMap) GetIndexers() Indexers { … }

func (c *threadSafeMap) AddIndexers(newIndexers Indexers) error { … }

func (c *threadSafeMap) Resync() error { … }

// NewThreadSafeStore creates a new instance of ThreadSafeStore.
func NewThreadSafeStore(indexers Indexers, indices Indices) ThreadSafeStore { … }