Versions in this module Expand all Collapse all v1 v1.4.0 Oct 17, 2016 Changes in this version + const NamespaceIndex + 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 Pop(queue Queue) interface + 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, knownObjects KeyListerGetter) *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) HasSynced() 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) 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) 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 Getter interface + Get func() *rest.Request + 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) + ListIndexFuncValues func(indexName string) []string + func NewIndexer(keyFunc KeyFunc, indexers Indexers) Indexer + type IndexerToNamespaceLister struct + func (i *IndexerToNamespaceLister) List(selector labels.Selector) (namespaces []*api.Namespace, err error) + 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) + 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 ListFunc func(options api.ListOptions) (runtime.Object, error) + type ListWatch struct + ListFunc ListFunc + WatchFunc WatchFunc + func NewListWatchFromClient(c Getter, resource string, namespace string, fieldSelector fields.Selector) *ListWatch + func (lw *ListWatch) List(options api.ListOptions) (runtime.Object, error) + func (lw *ListWatch) Watch(options api.ListOptions) (watch.Interface, error) + type ListerWatcher interface + List func(options api.ListOptions) (runtime.Object, error) + Watch func(options api.ListOptions) (watch.Interface, error) + type NodeConditionPredicate func(node *api.Node) bool + type PopProcessFunc func(interface{}) error + type Queue interface + AddIfNotPresent func(interface{}) error + HasSynced func() bool + Pop func(PopProcessFunc) (interface{}, error) + type Reflector struct + 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() + 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{}, 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 StoreToCertificateRequestLister struct + func (s *StoreToCertificateRequestLister) Exists(csr *certificates.CertificateSigningRequest) (bool, error) + func (s *StoreToCertificateRequestLister) List() (csrs certificates.CertificateSigningRequestList, err error) + type StoreToDaemonSetLister struct + func (s *StoreToDaemonSetLister) Exists(ds *extensions.DaemonSet) (bool, error) + func (s *StoreToDaemonSetLister) GetPodDaemonSets(pod *api.Pod) (daemonSets []extensions.DaemonSet, err error) + func (s *StoreToDaemonSetLister) List() (dss extensions.DaemonSetList, err error) + type StoreToDeploymentLister struct + func (s *StoreToDeploymentLister) Deployments(namespace string) storeToDeploymentNamespacer + func (s *StoreToDeploymentLister) Exists(deployment *extensions.Deployment) (bool, error) + func (s *StoreToDeploymentLister) GetDeploymentsForPod(pod *api.Pod) (deployments []extensions.Deployment, err error) + func (s *StoreToDeploymentLister) GetDeploymentsForReplicaSet(rs *extensions.ReplicaSet) (deployments []extensions.Deployment, err error) + func (s *StoreToDeploymentLister) List() (deployments []extensions.Deployment, err error) + type StoreToEndpointsLister struct + func (s *StoreToEndpointsLister) GetServiceEndpoints(svc *api.Service) (ep api.Endpoints, err error) + func (s *StoreToEndpointsLister) List() (services api.EndpointsList, err error) + type StoreToJobLister struct + func (s *StoreToJobLister) Exists(job *batch.Job) (bool, error) + func (s *StoreToJobLister) GetPodJobs(pod *api.Pod) (jobs []batch.Job, err error) + func (s *StoreToJobLister) List() (jobs batch.JobList, err error) + type StoreToNodeLister struct + func (s *StoreToNodeLister) List() (machines api.NodeList, err error) + func (s *StoreToNodeLister) NodeCondition(predicate NodeConditionPredicate) storeToNodeConditionLister + type StoreToPVCFetcher struct + func (s *StoreToPVCFetcher) GetPersistentVolumeClaimInfo(namespace string, id string) (*api.PersistentVolumeClaim, error) + type StoreToPVFetcher struct + func (s *StoreToPVFetcher) GetPersistentVolumeInfo(id string) (*api.PersistentVolume, error) + type StoreToPetSetLister struct + func (s *StoreToPetSetLister) Exists(ps *apps.PetSet) (bool, error) + func (s *StoreToPetSetLister) GetPodPetSets(pod *api.Pod) (psList []apps.PetSet, err error) + func (s *StoreToPetSetLister) List() (psList []apps.PetSet, err error) + func (s *StoreToPetSetLister) PetSets(namespace string) storePetSetsNamespacer + type StoreToPodDisruptionBudgetLister struct + func (s *StoreToPodDisruptionBudgetLister) GetPodPodDisruptionBudgets(pod *api.Pod) (pdbList []policy.PodDisruptionBudget, err error) + 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 StoreToReplicaSetLister struct + func (s *StoreToReplicaSetLister) Exists(rs *extensions.ReplicaSet) (bool, error) + func (s *StoreToReplicaSetLister) GetPodReplicaSets(pod *api.Pod) (rss []extensions.ReplicaSet, err error) + func (s *StoreToReplicaSetLister) List() (rss []extensions.ReplicaSet, err error) + func (s *StoreToReplicaSetLister) ReplicaSets(namespace string) storeReplicaSetsNamespacer + type StoreToReplicationControllerLister struct + func (s *StoreToReplicationControllerLister) Exists(controller *api.ReplicationController) (bool, error) + func (s *StoreToReplicationControllerLister) GetPodControllers(pod *api.Pod) (controllers []api.ReplicationController, err error) + func (s *StoreToReplicationControllerLister) List() (controllers []api.ReplicationController, err error) + func (s *StoreToReplicationControllerLister) ReplicationControllers(namespace string) storeReplicationControllersNamespacer + 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 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) + 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 api.ListOptions) (watch.Interface, error)
Go to main page