cache

package

Go to main page

Versions in this module

v1

v1.4.10-beta.0

Feb 15, 2017

v1.4.0-alpha.2

Jul 29, 2016

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) 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.3.0-alpha.3

Apr 26, 2016

v1.2.6

Jul 15, 2016

v1.2.3

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

v1.2.0-origin

Feb 12, 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-origin

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

v0.9.3

Jan 30, 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{})

v0.7.0

Dec 16, 2014

v0.5.5

Dec 2, 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

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