Versions in this module Expand all Collapse all v0 v0.19.0 Jun 9, 2015 Changes in this version + var ErrZeroLengthDeltasObject = errors.New("0 length Deltas object; can't get key") + func MetaNamespaceIndexFunc(obj interface{}) (string, error) + func MetaNamespaceKeyFunc(obj interface{}) (string, error) + func NewNamespaceKeyedIndexerAndReflector(lw ListerWatcher, expectedType interface{}, resyncPeriod time.Duration) (indexer Indexer, reflector *Reflector) + func SplitMetaNamespaceKey(key string) (namespace, name string, err error) + type DeletedFinalStateUnknown struct + Key string + Obj interface{} + type Delta struct + Object interface{} + Type DeltaType + type DeltaCompressor interface + Compress func(Deltas) Deltas + type DeltaCompressorFunc func(Deltas) Deltas + func (dc DeltaCompressorFunc) Compress(d Deltas) Deltas + type DeltaFIFO struct + func NewDeltaFIFO(keyFunc KeyFunc, compressor DeltaCompressor, knownObjectKeys KeyLister) *DeltaFIFO + func (f *DeltaFIFO) Add(obj interface{}) error + func (f *DeltaFIFO) AddIfNotPresent(obj interface{}) error + func (f *DeltaFIFO) Delete(obj interface{}) error + func (f *DeltaFIFO) Get(obj interface{}) (item interface{}, exists bool, err error) + func (f *DeltaFIFO) GetByKey(key string) (item interface{}, exists bool, err error) + func (f *DeltaFIFO) KeyOf(obj interface{}) (string, error) + func (f *DeltaFIFO) List() []interface{} + func (f *DeltaFIFO) ListKeys() []string + func (f *DeltaFIFO) Pop() interface{} + func (f *DeltaFIFO) Replace(list []interface{}) error + func (f *DeltaFIFO) Update(obj interface{}) error + type DeltaType string + const Added + const Deleted + const Sync + const Updated + type Deltas []Delta + func (d Deltas) Newest() *Delta + func (d Deltas) Oldest() *Delta + type Enumerator interface + Get func(index int) (object interface{}) + Len func() int + type ExpirationCache struct + func (c *ExpirationCache) Add(obj interface{}) error + func (c *ExpirationCache) Delete(obj interface{}) error + func (c *ExpirationCache) Get(obj interface{}) (interface{}, bool, error) + func (c *ExpirationCache) GetByKey(key string) (interface{}, bool, error) + func (c *ExpirationCache) List() []interface{} + func (c *ExpirationCache) ListKeys() []string + func (c *ExpirationCache) Replace(list []interface{}) error + func (c *ExpirationCache) Update(obj interface{}) error + type ExpirationPolicy interface + IsExpired func(obj *timestampedEntry) bool + type ExplicitKey string + type FIFO struct + func NewFIFO(keyFunc KeyFunc) *FIFO + func (f *FIFO) Add(obj interface{}) error + func (f *FIFO) AddIfNotPresent(obj interface{}) error + func (f *FIFO) Delete(obj interface{}) error + func (f *FIFO) Get(obj interface{}) (item interface{}, exists bool, err error) + func (f *FIFO) GetByKey(key string) (item interface{}, exists bool, err error) + func (f *FIFO) List() []interface{} + func (f *FIFO) ListKeys() []string + func (f *FIFO) Pop() interface{} + func (f *FIFO) Replace(list []interface{}) error + func (f *FIFO) Update(obj interface{}) error + type FakeExpirationPolicy struct + NeverExpire util.StringSet + RetrieveKeyFunc KeyFunc + func (p *FakeExpirationPolicy) IsExpired(obj *timestampedEntry) bool + type GetFunc func() (Enumerator, error) + type Index map[string]util.StringSet + type IndexFunc func(obj interface{}) (string, error) + type Indexer interface + Index func(indexName string, obj interface{}) ([]interface{}, error) + func NewIndexer(keyFunc KeyFunc, indexers Indexers) Indexer + type Indexers map[string]IndexFunc + type Indices map[string]Index + type KeyError struct + Err error + Obj interface{} + func (k KeyError) Error() string + type KeyFunc func(obj interface{}) (string, error) + type KeyGetter interface + GetByKey func(key string) (interface{}, bool, error) + type KeyLister interface + ListKeys func() []string + type ListFunc func() (runtime.Object, error) + type ListWatch struct + ListFunc ListFunc + WatchFunc WatchFunc + func NewListWatchFromClient(c *client.Client, resource string, namespace string, ...) *ListWatch + func (lw *ListWatch) List() (runtime.Object, error) + func (lw *ListWatch) Watch(resourceVersion string) (watch.Interface, error) + type ListerWatcher interface + List func() (runtime.Object, error) + Watch func(resourceVersion string) (watch.Interface, error) + type Poller struct + func NewPoller(getFunc GetFunc, period time.Duration, store Store) *Poller + func (p *Poller) Run() + func (p *Poller) RunUntil(stopCh <-chan struct{}) + type Queue interface + AddIfNotPresent func(interface{}) error + Pop func() interface{} + type Reflector struct + func NewReflector(lw ListerWatcher, expectedType interface{}, store Store, ...) *Reflector + func (r *Reflector) LastSyncResourceVersion() string + func (r *Reflector) Run() + func (r *Reflector) RunUntil(stopCh <-chan struct{}) + type Store interface + Add func(obj interface{}) error + Delete func(obj interface{}) error + Get func(obj interface{}) (item interface{}, exists bool, err error) + GetByKey func(key string) (item interface{}, exists bool, err error) + List func() []interface{} + ListKeys func() []string + Replace func([]interface{}) error + Update func(obj interface{}) error + func NewFakeExpirationStore(keyFunc KeyFunc, deletedKeys chan<- string, expirationPolicy ExpirationPolicy, ...) Store + func NewStore(keyFunc KeyFunc) Store + func NewTTLStore(keyFunc KeyFunc, ttl time.Duration) Store + type StoreToControllerLister struct + func (s *StoreToControllerLister) Exists(controller *api.ReplicationController) (bool, error) + func (s *StoreToControllerLister) GetPodControllers(pod *api.Pod) (controllers []api.ReplicationController, err error) + func (s *StoreToControllerLister) List() (controllers []api.ReplicationController, err error) + type StoreToNodeLister struct + func (s *StoreToNodeLister) GetNodeInfo(id string) (*api.Node, error) + func (s *StoreToNodeLister) List() (machines api.NodeList, err error) + func (s *StoreToNodeLister) NodeCondition(conditionType api.NodeConditionType, conditionStatus api.ConditionStatus) storeToNodeConditionLister + type StoreToPodLister struct + func (s *StoreToPodLister) Exists(pod *api.Pod) (bool, error) + func (s *StoreToPodLister) List(selector labels.Selector) (pods []*api.Pod, err error) + func (s *StoreToPodLister) Pods(namespace string) storePodsNamespacer + type StoreToServiceLister struct + func (s *StoreToServiceLister) GetPodServices(pod *api.Pod) (services []api.Service, err error) + func (s *StoreToServiceLister) List() (services api.ServiceList, err error) + type TTLPolicy struct + Clock util.Clock + Ttl time.Duration + func (p *TTLPolicy) IsExpired(obj *timestampedEntry) bool + type ThreadSafeStore interface + Add func(key string, obj interface{}) + Delete func(key string) + Get func(key string) (item interface{}, exists bool) + Index func(indexName string, obj interface{}) ([]interface{}, error) + List func() []interface{} + ListKeys func() []string + Replace func(map[string]interface{}) + Update func(key string, obj interface{}) + func NewThreadSafeStore(indexers Indexers, indices Indices) ThreadSafeStore + type UndeltaStore struct + PushFunc func([]interface{}) + func NewUndeltaStore(pushFunc func([]interface{}), keyFunc KeyFunc) *UndeltaStore + func (u *UndeltaStore) Add(obj interface{}) error + func (u *UndeltaStore) Delete(obj interface{}) error + func (u *UndeltaStore) Replace(list []interface{}) error + func (u *UndeltaStore) Update(obj interface{}) error + type WatchFunc func(resourceVersion string) (watch.Interface, error)