Versions in this module Expand all Collapse all v11 v11.0.0 Mar 13, 2019 Changes in this version + const NamespaceIndex + var ErrZeroLengthDeltasObject = errors.New("0 length Deltas object; can't get key") + var FIFOClosedError error = errors.New("DeltaFIFO: manipulating with closed queue") + func DeletionHandlingMetaNamespaceKeyFunc(obj interface{}) (string, error) + func ListAll(store Store, selector labels.Selector, appendFn AppendFunc) error + func ListAllByNamespace(indexer Indexer, namespace string, selector labels.Selector, ...) error + func MetaNamespaceIndexFunc(obj interface{}) ([]string, error) + func MetaNamespaceKeyFunc(obj interface{}) (string, error) + func NewIndexerInformer(lw ListerWatcher, objType runtime.Object, resyncPeriod time.Duration, ...) (Indexer, Controller) + func NewInformer(lw ListerWatcher, objType runtime.Object, resyncPeriod time.Duration, ...) (Store, Controller) + func NewNamespaceKeyedIndexerAndReflector(lw ListerWatcher, expectedType interface{}, resyncPeriod time.Duration) (indexer Indexer, reflector *Reflector) + func Pop(queue Queue) interface + func SetReflectorMetricsProvider(metricsProvider MetricsProvider) + func SplitMetaNamespaceKey(key string) (namespace, name string, err error) + func WaitForCacheSync(stopCh <-chan struct{}, cacheSyncs ...InformerSynced) bool + type AppendFunc func(interface{}) + type CacheMutationDetector interface + AddObject func(obj interface{}) + Run func(stopCh <-chan struct{}) + func NewCacheMutationDetector(name string) CacheMutationDetector + type Config struct + FullResyncPeriod time.Duration + ObjectType runtime.Object + Process ProcessFunc + RetryOnError bool + ShouldResync ShouldResyncFunc + type Controller interface + HasSynced func() bool + LastSyncResourceVersion func() string + Run func(stopCh <-chan struct{}) + func New(c *Config) Controller + type CounterMetric interface + Inc func() + type DeletedFinalStateUnknown struct + Key string + Obj interface{} + type Delta struct + Object interface{} + Type DeltaType + type DeltaFIFO struct + func NewDeltaFIFO(keyFunc KeyFunc, knownObjects KeyListerGetter) *DeltaFIFO + func (f *DeltaFIFO) Add(obj interface{}) error + func (f *DeltaFIFO) AddIfNotPresent(obj interface{}) error + func (f *DeltaFIFO) Close() + 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) HasSynced() bool + func (f *DeltaFIFO) IsClosed() bool + func (f *DeltaFIFO) KeyOf(obj interface{}) (string, error) + func (f *DeltaFIFO) List() []interface{} + func (f *DeltaFIFO) ListKeys() []string + func (f *DeltaFIFO) Pop(process PopProcessFunc) (interface{}, error) + func (f *DeltaFIFO) Replace(list []interface{}, resourceVersion string) error + func (f *DeltaFIFO) Resync() 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 ErrRequeue struct + Err error + func (e ErrRequeue) Error() string + 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{}, resourceVersion string) error + func (c *ExpirationCache) Resync() 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) Close() + 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) HasSynced() bool + func (f *FIFO) IsClosed() bool + func (f *FIFO) List() []interface{} + func (f *FIFO) ListKeys() []string + func (f *FIFO) Pop(process PopProcessFunc) (interface{}, error) + func (f *FIFO) Replace(list []interface{}, resourceVersion string) error + func (f *FIFO) Resync() error + func (f *FIFO) Update(obj interface{}) error + type FakeCustomStore struct + AddFunc func(obj interface{}) error + DeleteFunc func(obj interface{}) error + GetByKeyFunc func(key string) (item interface{}, exists bool, err error) + GetFunc func(obj interface{}) (item interface{}, exists bool, err error) + ListFunc func() []interface{} + ListKeysFunc func() []string + ReplaceFunc func(list []interface{}, resourceVerion string) error + ResyncFunc func() error + UpdateFunc func(obj interface{}) error + func (f *FakeCustomStore) Add(obj interface{}) error + func (f *FakeCustomStore) Delete(obj interface{}) error + func (f *FakeCustomStore) Get(obj interface{}) (item interface{}, exists bool, err error) + func (f *FakeCustomStore) GetByKey(key string) (item interface{}, exists bool, err error) + func (f *FakeCustomStore) List() []interface{} + func (f *FakeCustomStore) ListKeys() []string + func (f *FakeCustomStore) Replace(list []interface{}, resourceVersion string) error + func (f *FakeCustomStore) Resync() error + func (f *FakeCustomStore) Update(obj interface{}) error + type FakeExpirationPolicy struct + NeverExpire sets.String + RetrieveKeyFunc KeyFunc + func (p *FakeExpirationPolicy) IsExpired(obj *timestampedEntry) bool + type FilteringResourceEventHandler struct + FilterFunc func(obj interface{}) bool + Handler ResourceEventHandler + func (r FilteringResourceEventHandler) OnAdd(obj interface{}) + func (r FilteringResourceEventHandler) OnDelete(obj interface{}) + func (r FilteringResourceEventHandler) OnUpdate(oldObj, newObj interface{}) + type GaugeMetric interface + Set func(float64) + type GenericLister interface + ByNamespace func(namespace string) GenericNamespaceLister + Get func(name string) (runtime.Object, error) + List func(selector labels.Selector) (ret []runtime.Object, err error) + func NewGenericLister(indexer Indexer, resource schema.GroupResource) GenericLister + type GenericNamespaceLister interface + Get func(name string) (runtime.Object, error) + List func(selector labels.Selector) (ret []runtime.Object, err error) + type Getter interface + Get func() *restclient.Request + type Heap struct + func NewHeap(keyFn KeyFunc, lessFn LessFunc) *Heap + func (h *Heap) Add(obj interface{}) error + func (h *Heap) AddIfNotPresent(obj interface{}) error + func (h *Heap) BulkAdd(list []interface{}) error + func (h *Heap) Close() + func (h *Heap) Delete(obj interface{}) error + func (h *Heap) Get(obj interface{}) (interface{}, bool, error) + func (h *Heap) GetByKey(key string) (interface{}, bool, error) + func (h *Heap) IsClosed() bool + func (h *Heap) List() []interface{} + func (h *Heap) ListKeys() []string + func (h *Heap) Pop() (interface{}, error) + func (h *Heap) Update(obj interface{}) error + type Index map[string]sets.String + type IndexFunc func(obj interface{}) ([]string, error) + type Indexer interface + AddIndexers func(newIndexers Indexers) error + ByIndex func(indexName, indexKey string) ([]interface{}, error) + GetIndexers func() Indexers + Index func(indexName string, obj interface{}) ([]interface{}, error) + IndexKeys func(indexName, indexKey string) ([]string, error) + ListIndexFuncValues func(indexName string) []string + func NewIndexer(keyFunc KeyFunc, indexers Indexers) Indexer + type Indexers map[string]IndexFunc + type Indices map[string]Index + type InformerSynced func() bool + type KeyError struct + Err error + Obj interface{} + func (k KeyError) Error() string + type KeyFunc func(obj interface{}) (string, error) + func IndexFuncToKeyFuncAdapter(indexFunc IndexFunc) KeyFunc + type KeyGetter interface + GetByKey func(key string) (interface{}, bool, error) + type KeyLister interface + ListKeys func() []string + type KeyListerGetter interface + type LessFunc func(interface{}, interface{}) bool + type ListFunc func(options metav1.ListOptions) (runtime.Object, error) + type ListWatch struct + DisableChunking bool + ListFunc ListFunc + WatchFunc WatchFunc + func NewFilteredListWatchFromClient(c Getter, resource string, namespace string, ...) *ListWatch + func NewListWatchFromClient(c Getter, resource string, namespace string, fieldSelector fields.Selector) *ListWatch + func (lw *ListWatch) List(options metav1.ListOptions) (runtime.Object, error) + func (lw *ListWatch) Watch(options metav1.ListOptions) (watch.Interface, error) + type Lister interface + List func(options metav1.ListOptions) (runtime.Object, error) + type ListerWatcher interface + type MetricsProvider interface + NewItemsInListMetric func(name string) SummaryMetric + NewItemsInWatchMetric func(name string) SummaryMetric + NewLastResourceVersionMetric func(name string) GaugeMetric + NewListDurationMetric func(name string) SummaryMetric + NewListsMetric func(name string) CounterMetric + NewShortWatchesMetric func(name string) CounterMetric + NewWatchDurationMetric func(name string) SummaryMetric + NewWatchesMetric func(name string) CounterMetric + type MutationCache interface + ByIndex func(indexName, indexKey string) ([]interface{}, error) + GetByKey func(key string) (interface{}, bool, error) + Mutation func(interface{}) + func NewIntegerResourceVersionMutationCache(backingCache Store, indexer Indexer, ttl time.Duration, includeAdds bool) MutationCache + type PopProcessFunc func(interface{}) error + type ProcessFunc func(obj interface{}) error + type Queue interface + AddIfNotPresent func(interface{}) error + Close func() + HasSynced func() bool + Pop func(PopProcessFunc) (interface{}, error) + type Reflector struct + ShouldResync func() bool + func NewNamedReflector(name string, lw ListerWatcher, expectedType interface{}, store Store, ...) *Reflector + func NewReflector(lw ListerWatcher, expectedType interface{}, store Store, ...) *Reflector + func (r *Reflector) LastSyncResourceVersion() string + func (r *Reflector) ListAndWatch(stopCh <-chan struct{}) error + func (r *Reflector) Run(stopCh <-chan struct{}) + type ResourceEventHandler interface + OnAdd func(obj interface{}) + OnDelete func(obj interface{}) + OnUpdate func(oldObj, newObj interface{}) + type ResourceEventHandlerFuncs struct + AddFunc func(obj interface{}) + DeleteFunc func(obj interface{}) + UpdateFunc func(oldObj, newObj interface{}) + func (r ResourceEventHandlerFuncs) OnAdd(obj interface{}) + func (r ResourceEventHandlerFuncs) OnDelete(obj interface{}) + func (r ResourceEventHandlerFuncs) OnUpdate(oldObj, newObj interface{}) + type ResourceVersionComparator interface + CompareResourceVersion func(lhs, rhs runtime.Object) int + type SharedIndexInformer interface + AddIndexers func(indexers Indexers) error + GetIndexer func() Indexer + func NewSharedIndexInformer(lw ListerWatcher, objType runtime.Object, ...) SharedIndexInformer + type SharedInformer interface + AddEventHandler func(handler ResourceEventHandler) + AddEventHandlerWithResyncPeriod func(handler ResourceEventHandler, resyncPeriod time.Duration) + GetController func() Controller + GetStore func() Store + HasSynced func() bool + LastSyncResourceVersion func() string + Run func(stopCh <-chan struct{}) + func NewSharedInformer(lw ListerWatcher, objType runtime.Object, resyncPeriod time.Duration) SharedInformer + type ShouldResyncFunc func() bool + 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{}, string) error + Resync func() 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 SummaryMetric interface + Observe func(float64) + type TTLPolicy struct + Clock clock.Clock + Ttl time.Duration + func (p *TTLPolicy) IsExpired(obj *timestampedEntry) bool + type ThreadSafeStore interface + Add func(key string, obj interface{}) + AddIndexers func(newIndexers Indexers) error + ByIndex func(indexName, indexKey string) ([]interface{}, error) + Delete func(key string) + Get func(key string) (item interface{}, exists bool) + GetIndexers func() Indexers + Index func(indexName string, obj interface{}) ([]interface{}, error) + IndexKeys func(indexName, indexKey string) ([]string, error) + List func() []interface{} + ListIndexFuncValues func(name string) []string + ListKeys func() []string + Replace func(map[string]interface{}, string) + Resync func() error + 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{}, resourceVersion string) error + func (u *UndeltaStore) Update(obj interface{}) error + type WatchFunc func(options metav1.ListOptions) (watch.Interface, error) + type Watcher interface + Watch func(options metav1.ListOptions) (watch.Interface, error) Other modules containing this package gopkg.in/kubernetes/client-go.v2
Go to main page