NewDeltaFIFO returns a Queue which can be used to process changes to items.

NewDeltaFIFOWithOptions returns a Queue which can be used to process changes to items.

NewFIFO returns a Store which can be used to queue up items to process.

NewIndexer returns an Indexer implemented simply with a map and a lock.

NewStore returns a Store implemented simply with a map and a lock.

NewThreadSafeStore creates a new instance of ThreadSafeStore.

Pop is helper function for popping from Queue.

Change type definition.

Change type definition.

Replaced is emitted when we encountered watch errors and had to do a relist.

Sync is for synthetic events during a periodic resync.

Change type definition.

ErrFIFOClosed used when FIFO is closed.

ErrZeroLengthDeltasObject is returned in a KeyError if a Deltas object with zero length is encountered (should be impossible, but included for completeness).

DeletedFinalStateUnknown is placed into a DeltaFIFO in the case where an object was deleted but the watch deletion event was missed while disconnected from apiserver.

Delta is a member of Deltas (a list of Delta objects) which in its turn is the type stored by a DeltaFIFO.

DeltaFIFO is like FIFO, but differs in two ways.

DeltaFIFOOptions is the configuration parameters for DeltaFIFO.

ErrRequeue may be returned by a PopProcessFunc to safely requeue the current item.

FIFO is a Queue in which (a) each accumulator is simply the most recently provided object and (b) the collection of keys to process is a FIFO.

KeyError will be returned any time a KeyFunc gives an error; it includes the object at fault.

Indexer extends Store with multiple indices and restricts each accumulator to simply hold the current object (and be empty after Delete).

A KeyGetter is anything that knows how to get the value stored under a given key.

A KeyLister is anything that knows how to list its keys.

A KeyListerGetter is anything that knows how to list its keys and look up by key.

Queue extends Store with a collection of Store keys to "process".

Store is a generic object storage and processing interface.

ThreadSafeStore is an interface that allows concurrent indexed access to a storage backend.

Deltas is a list of one or more 'Delta's to an individual object.

DeltaType is the type of a change (addition, deletion, etc).

ExplicitKey can be passed to MetaNamespaceKeyFunc if you have the key for the object but not the object itself.

Index maps the indexed value to a set of keys in the store that match on that value.

Indexers maps a name to an IndexFunc.

IndexFunc knows how to compute the set of indexed values for an object.

Indices maps a name to an Index.

KeyFunc knows how to make a key from an object.

PopProcessFunc is passed to Pop() method of Queue interface.