cache

package

Go to main page

Versions in this module

v1

v1.4.5

Oct 29, 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)

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

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

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

v1.4.0-alpha.1

Jul 11, 2016

v1.3.6-beta.0

Aug 11, 2016

v1.3.0

Jul 1, 2016

Changes in this version

+ const NamespaceIndex

+ func Pop(queue Queue) interface

type DeltaFIFO

+ func (f *DeltaFIFO) HasSynced() bool

+ func (f *DeltaFIFO) Resync() error

type ExpirationCache

+ func (c *ExpirationCache) Resync() error

type FIFO

+ func (f *FIFO) HasSynced() bool

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

+ Get func() *restclient.Request

type Indexer

+ AddIndexers func(newIndexers Indexers) error

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

+ GetIndexers func() Indexers

+ ListIndexFuncValues func(indexName string) []string

type KeyFunc

+ func IndexFuncToKeyFuncAdapter(indexFunc IndexFunc) KeyFunc

+ type KeyListerGetter interface

+ type NodeConditionPredicate func(node api.Node) bool

+ type PopProcessFunc func(interface{}) error

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 Store

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

+ AddIndexers func(newIndexers Indexers) error

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

+ GetIndexers func() Indexers

+ ListIndexFuncValues func(name string) []string

+ Resync func() error

v1.3.0-alpha.3

Apr 26, 2016

v1.2.0-beta.0

Mar 4, 2016

v1.2.0-alpha.3

Nov 3, 2015

v1.1.7-beta.0

Jan 27, 2016

v1.1.4-beta.0

Dec 7, 2015

v1.1.0-beta

Sep 25, 2015

v1.0.8-beta

Oct 27, 2015

v1.0.2

Aug 1, 2015

v0

v0.21.2

Jul 11, 2015

Changes in this version

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

type DeletedFinalStateUnknown

+ Obj interface{}

+ type KeyGetter interface

+ GetByKey func(key string) (interface{}, bool, 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

v0.15.0

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

+ ListKeys func() []string

+ type KeyListerFunc func() []string

+ func (kl KeyListerFunc) ListKeys() []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 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) Exists(pod *api.Pod) (bool, error)

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL