cache

Dec 14, 2016

Changes in this version

+ func ListAll(store Store, selector labels.Selector, appendFn AppendFunc) error

+ func ListAllByNamespace(indexer Indexer, namespace string, selector labels.Selector, ...) error

+ func ListWatchUntil(timeout time.Duration, lw ListerWatcher, conditions ...watch.ConditionFunc) (*watch.Event, error)

+ type AppendFunc func(interface{})

+ type CacheMutationDetector interface

+ AddObject func(obj interface{})

+ Run func(stopCh <-chan struct{})

+ func NewCacheMutationDetector(name string) CacheMutationDetector

+ type ClusterRoleBindingLister interface

+ Get func(name string) (*rbac.ClusterRoleBinding, error)

+ List func(selector labels.Selector) (ret []*rbac.ClusterRoleBinding, err error)

+ func NewClusterRoleBindingLister(indexer Indexer) ClusterRoleBindingLister

+ type ClusterRoleLister interface

+ Get func(name string) (*rbac.ClusterRole, error)

+ List func(selector labels.Selector) (ret []*rbac.ClusterRole, err error)

+ func NewClusterRoleLister(indexer Indexer) ClusterRoleLister

+ 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 unversioned.GroupResource) GenericLister

+ type GenericNamespaceLister interface

+ Get func(name string) (runtime.Object, error)

+ List func(selector labels.Selector) (ret []runtime.Object, err error)

type IndexerToNamespaceLister

+ func (i *IndexerToNamespaceLister) Get(name string) (*api.Namespace, error)

+ type RoleBindingLister interface

+ List func(selector labels.Selector) (ret []*rbac.RoleBinding, err error)

+ RoleBindings func(namespace string) RoleBindingNamespaceLister

+ func NewRoleBindingLister(indexer Indexer) RoleBindingLister

+ type RoleBindingNamespaceLister interface

+ Get func(name string) (*rbac.RoleBinding, error)

+ List func(selector labels.Selector) (ret []*rbac.RoleBinding, err error)

+ type RoleLister interface

+ List func(selector labels.Selector) (ret []*rbac.Role, err error)

+ Roles func(namespace string) RoleNamespaceLister

+ func NewRoleLister(indexer Indexer) RoleLister

+ type RoleNamespaceLister interface

+ Get func(name string) (*rbac.Role, error)

+ List func(selector labels.Selector) (ret []*rbac.Role, err error)

+ type StorageClassLister interface

+ Get func(name string) (*storage.StorageClass, error)

+ List func(selector labels.Selector) (ret []*storage.StorageClass, err error)

+ func NewStorageClassLister(indexer Indexer) StorageClassLister

type StoreToDeploymentLister

+ Indexer Indexer

+ type StoreToLimitRangeLister struct

+ Indexer Indexer

+ func (s *StoreToLimitRangeLister) LimitRanges(namespace string) storeLimitRangesNamespacer

+ func (s *StoreToLimitRangeLister) List(selector labels.Selector) (ret []*api.LimitRange, err error)

+ type StoreToPersistentVolumeClaimLister struct

+ Indexer Indexer

+ func (s *StoreToPersistentVolumeClaimLister) List(selector labels.Selector) (ret []*api.PersistentVolumeClaim, err error)

+ func (s *StoreToPersistentVolumeClaimLister) PersistentVolumeClaims(namespace string) storePersistentVolumeClaimsNamespacer

type StoreToPodLister

+ Indexer Indexer

type StoreToReplicaSetLister

+ Indexer Indexer

type StoreToReplicationControllerLister

+ Indexer Indexer

+ type StoreToServiceAccountLister struct

+ Indexer Indexer

+ func (s *StoreToServiceAccountLister) List(selector labels.Selector) (ret []*api.ServiceAccount, err error)

+ func (s *StoreToServiceAccountLister) ServiceAccounts(namespace string) storeServiceAccountsNamespacer

type StoreToServiceLister

+ Indexer Indexer

+ func (s *StoreToServiceLister) Services(namespace string) storeServicesNamespacer

+ type StoreToStatefulSetLister struct

+ func (s *StoreToStatefulSetLister) Exists(ps *apps.StatefulSet) (bool, error)

+ func (s *StoreToStatefulSetLister) GetPodStatefulSets(pod *api.Pod) (psList []apps.StatefulSet, err error)

+ func (s *StoreToStatefulSetLister) List() (psList []apps.StatefulSet, err error)

+ func (s *StoreToStatefulSetLister) StatefulSets(namespace string) storeStatefulSetsNamespacer

Oct 29, 2016

Changes in this version

+ func WaitForCacheSync(stopCh <-chan struct{}, cacheSyncs ...InformerSynced) bool

+ type InformerSynced func() bool

Oct 15, 2016

Changes in this version

+ func DeletionHandlingMetaNamespaceKeyFunc(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)

+ type Config struct

+ FullResyncPeriod time.Duration

+ ObjectType runtime.Object

+ Process ProcessFunc

+ RetryOnError bool

+ type Controller struct

+ func New(c *Config) *Controller

+ func (c *Controller) HasSynced() bool

+ func (c *Controller) Requeue(obj interface{}) error

+ func (c *Controller) Run(stopCh <-chan struct{})

+ type ControllerInterface interface

+ HasSynced func() bool

+ Run func(stopCh <-chan struct{})

+ type ErrRequeue struct

+ Err error

+ func (e ErrRequeue) Error() string

+ type IndexerToNamespaceLister struct

+ func (i *IndexerToNamespaceLister) List(selector labels.Selector) (namespaces []*api.Namespace, err error)

+ type ProcessFunc func(obj interface{}) error

+ 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 SharedIndexInformer interface

+ AddIndexers func(indexers Indexers) error

+ GetIndexer func() Indexer

+ func NewSharedIndexInformer(lw ListerWatcher, objType runtime.Object, resyncPeriod time.Duration, ...) SharedIndexInformer

+ type SharedInformer interface

+ AddEventHandler func(handler ResourceEventHandler) error

+ GetController func() ControllerInterface

+ 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 StoreToCertificateRequestLister struct

+ func (s *StoreToCertificateRequestLister) Exists(csr *certificates.CertificateSigningRequest) (bool, error)

+ func (s *StoreToCertificateRequestLister) List() (csrs certificates.CertificateSigningRequestList, err error)

type StoreToDeploymentLister

+ func (s *StoreToDeploymentLister) Deployments(namespace string) storeToDeploymentNamespacer

+ func (s *StoreToDeploymentLister) GetDeploymentsForPod(pod *api.Pod) (deployments []extensions.Deployment, err error)

+ type StoreToPodDisruptionBudgetLister struct

+ func (s *StoreToPodDisruptionBudgetLister) GetPodPodDisruptionBudgets(pod *api.Pod) (pdbList []policy.PodDisruptionBudget, err error)

Jul 1, 2016

Changes in this version

+ const NamespaceIndex

+ func Pop(queue Queue) interface

type DeltaFIFO

+ func (f *DeltaFIFO) Resync() error

type ExpirationCache

+ func (c *ExpirationCache) Resync() error

type FIFO

+ func (f *FIFO) Resync() 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 Indexer

+ AddIndexers func(newIndexers Indexers) error

+ GetIndexers func() Indexers

+ type PopProcessFunc func(interface{}) error

type Store

+ Resync func() 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 ThreadSafeStore

+ AddIndexers func(newIndexers Indexers) error

+ GetIndexers func() Indexers

+ Resync func() error

Apr 22, 2016

Changes in this version

type DeltaFIFO

+ func (f *DeltaFIFO) HasSynced() bool

type FIFO

+ func (f *FIFO) HasSynced() bool

+ type Getter interface

+ Get func() *restclient.Request

type Indexer

+ ByIndex func(indexName, indexKey string) ([]interface{}, error)

+ ListIndexFuncValues func(indexName string) []string

type KeyFunc

+ func IndexFuncToKeyFuncAdapter(indexFunc IndexFunc) KeyFunc

+ type KeyListerGetter interface

+ type NodeConditionPredicate func(node api.Node) bool

type Queue

+ HasSynced func() bool

type Reflector

+ func NewNamedReflector(name string, lw ListerWatcher, expectedType interface{}, store Store, ...) *Reflector

+ func (r *Reflector) ListAndWatch(stopCh <-chan struct{}) 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) Exists(deployment *extensions.Deployment) (bool, 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 *extensions.Job) (bool, error)

+ func (s *StoreToJobLister) GetPodJobs(pod *api.Pod) (jobs []extensions.Job, err error)

+ func (s *StoreToJobLister) List() (jobs extensions.JobList, err error)

+ 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 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 ThreadSafeStore

+ ByIndex func(indexName, indexKey string) ([]interface{}, error)

+ ListIndexFuncValues func(name string) []string

Jun 9, 2015

Changes in this version

type DeletedFinalStateUnknown

+ Obj interface{}

+ type KeyGetter interface

+ GetByKey func(key string) (interface{}, bool, error)

May 26, 2015

Changes in this version

+ func SplitMetaNamespaceKey(key string) (namespace, name string, err error)

+ 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

+ func (s *StoreToNodeLister) NodeCondition(conditionType api.NodeConditionType, conditionStatus api.ConditionStatus) storeToNodeConditionLister

type StoreToPodLister

+ func (s *StoreToPodLister) Pods(namespace string) storePodsNamespacer

Apr 13, 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)

+ type DeletedFinalStateUnknown struct

+ Key string

+ 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 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

+ func (f *FIFO) AddIfNotPresent(obj interface{}) error

+ func (f *FIFO) GetByKey(key string) (item interface{}, exists bool, err error)

+ func (f *FIFO) ListKeys() []string

+ type FakeExpirationPolicy struct

+ NeverExpire util.StringSet

+ RetrieveKeyFunc KeyFunc

+ func (p *FakeExpirationPolicy) IsExpired(obj *timestampedEntry) bool

+ 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 KeyLister interface

+ ListKeys func() []string

+ type KeyListerFunc func() []string

+ func (kl KeyListerFunc) ListKeys() []string

+ type ListFunc func() (runtime.Object, error)

type ListWatch

+ ListFunc ListFunc

+ WatchFunc WatchFunc

+ func NewListWatchFromClient(c *client.Client, resource string, namespace string, ...) *ListWatch

type Poller

+ func (p *Poller) RunUntil(stopCh <-chan struct{})

+ type Queue interface

+ AddIfNotPresent func(interface{}) error

+ Pop func() interface{}

type Reflector

+ func (r *Reflector) LastSyncResourceVersion() string

+ func (r *Reflector) RunUntil(stopCh <-chan struct{})

type Store

+ func NewFakeExpirationStore(keyFunc KeyFunc, deletedKeys chan<- string, expirationPolicy ExpirationPolicy, ...) Store

+ func NewTTLStore(keyFunc KeyFunc, ttl time.Duration) Store

+ GetByKey func(key string) (item interface{}, exists bool, err error)

+ ListKeys func() []string

type StoreToPodLister

+ func (s *StoreToPodLister) Exists(pod *api.Pod) (bool, 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 WatchFunc func(resourceVersion string) (watch.Interface, error)

Jan 28, 2015

Changes in this version

+ type ListWatch struct

+ Client *client.Client

+ FieldSelector labels.Selector

+ Namespace string

+ Resource string

+ func (lw *ListWatch) List() (runtime.Object, error)

+ func (lw *ListWatch) Watch(resourceVersion string) (watch.Interface, error)

+ type StoreToNodeLister struct

+ func (s *StoreToNodeLister) GetNodeInfo(id string) (*api.Node, error)

+ func (s *StoreToNodeLister) List() (machines api.NodeList, err error)

+ type StoreToPodLister struct

+ func (s *StoreToPodLister) List(selector labels.Selector) (pods []api.Pod, err error)

+ 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 UndeltaStore struct

+ ActualStore Store

+ PushFunc func([]interface{})

+ func NewUndeltaStore(pushFunc func([]interface{})) *UndeltaStore

+ func (u *UndeltaStore) Add(id string, obj interface{})

+ func (u *UndeltaStore) ContainedIDs() util.StringSet

+ func (u *UndeltaStore) Delete(id string)

+ func (u *UndeltaStore) Get(id string) (item interface{}, exists bool)

+ func (u *UndeltaStore) List() []interface{}

+ func (u *UndeltaStore) Replace(idToObj map[string]interface{})

+ func (u *UndeltaStore) Update(id string, obj interface{})

Nov 19, 2014

Changes in this version

+ type Enumerator interface

+ Get func(index int) (ID string, object interface{})

+ Len func() int

+ type FIFO struct

+ func NewFIFO() *FIFO

+ func (c *FIFO) ContainedIDs() util.StringSet

+ func (f *FIFO) Add(id string, obj interface{})

+ func (f *FIFO) Delete(id string)

+ func (f *FIFO) Get(id string) (item interface{}, exists bool)

+ func (f *FIFO) List() []interface{}

+ func (f *FIFO) Pop() interface{}

+ func (f *FIFO) Replace(idToObj map[string]interface{})

+ func (f *FIFO) Update(id string, obj interface{})

+ type GetFunc func() (Enumerator, 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()

+ type Reflector struct

+ func NewReflector(lw ListerWatcher, expectedType interface{}, store Store) *Reflector

+ func (r *Reflector) Run()

+ type Store interface

+ Add func(id string, obj interface{})

+ ContainedIDs func() util.StringSet

+ Delete func(id string)

+ Get func(id string) (item interface{}, exists bool)

+ List func() []interface{}

+ Replace func(idToObj map[string]interface{})

+ Update func(id string, obj interface{})

+ func NewStore() Store