cache

package

Go to main page

Versions in this module

v1

v1.3.2

Jan 7, 2017

v1.3.1

Sep 22, 2016

v1.3.0

Sep 19, 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

v1.2.0

Jun 23, 2016

v0

v0.4.0

Jun 23, 2016

Changes in this version

type DeltaFIFO

+ func (f *DeltaFIFO) HasSynced() bool

type FIFO

+ func (f *FIFO) HasSynced() bool

type Queue

+ HasSynced func() bool

type StoreToDeploymentLister

+ func (s *StoreToDeploymentLister) GetDeploymentsForReplicaSet(rs *extensions.ReplicaSet) (deployments []extensions.Deployment, err 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

+ func (s *StoreToReplicationControllerLister) ReplicationControllers(namespace string) storeReplicationControllersNamespacer

v0.3.0

Mar 16, 2016

Changes in this version

+ type KeyListerGetter interface

+ type NodeConditionPredicate func(node api.Node) bool

+ type StoreToDeploymentLister struct

+ func (s *StoreToDeploymentLister) Exists(deployment *extensions.Deployment) (bool, error)

+ func (s *StoreToDeploymentLister) GetDeploymentsForRC(rc *api.ReplicationController) (deployments []extensions.Deployment, err error)

+ func (s *StoreToDeploymentLister) List() (deployments []extensions.Deployment, 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)

v0.1.0

Oct 25, 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{}, resourceVersion string) 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{}, resourceVersion string) 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{}, resourceVersion string) error

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

+ type FakeExpirationPolicy struct

+ NeverExpire sets.String

+ RetrieveKeyFunc KeyFunc

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

+ type Getter interface

+ Get func() *client.Request

+ type Index map[string]sets.String

+ type IndexFunc func(obj interface{}) ([]string, error)

+ type Indexer interface

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

+ Index func(indexName string, obj interface{}) ([]interface{}, error)

+ ListIndexFuncValues func(indexName string) []string

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

+ func IndexFuncToKeyFuncAdapter(indexFunc IndexFunc) KeyFunc

+ 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 Getter, resource string, namespace string, fieldSelector fields.Selector) *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 Queue interface

+ AddIfNotPresent func(interface{}) error

+ Pop func() interface{}

+ 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

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

+ func (s *StoreToDaemonSetLister) Exists(ds *experimental.DaemonSet) (bool, error)

+ func (s *StoreToDaemonSetLister) GetPodDaemonSets(pod *api.Pod) (daemonSets []experimental.DaemonSet, err error)

+ func (s *StoreToDaemonSetLister) List() (dss []experimental.DaemonSet, 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 *experimental.Job) (bool, error)

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

+ func (s *StoreToJobLister) List() (jobs []experimental.Job, err error)

+ type StoreToNetworksLister struct

+ func (s *StoreToNetworksLister) GetNamespaceNetwork(ns *api.Namespace) *api.Network

+ func (s *StoreToNetworksLister) List() (networks api.NetworkList, 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 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)

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

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

+ Delete func(key string)

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

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

+ 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(resourceVersion string) (watch.Interface, error)

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