cache

Jun 10, 2015

Changes in this version

type DeletedFinalStateUnknown

+ Obj interface{}

+ type KeyGetter interface

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

May 12, 2015

Changes in this version

+ 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

Apr 29, 2015

Changes in this version

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

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

+ 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) ListKeys() []string

+ type FakeExpirationPolicy struct

+ NeverExpire util.StringSet

+ RetrieveKeyFunc KeyFunc

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

+ type KeyError struct

+ Err error

+ Obj interface{}

+ func (k KeyError) Error() string

+ type KeyLister interface

+ ListKeys func() []string

+ type KeyListerFunc func() []string

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

+ type Queue interface

+ AddIfNotPresent func(interface{}) error

+ Pop func() interface{}

type Reflector

+ func (r *Reflector) LastSyncResourceVersion() string

type Store

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

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

+ ListKeys func() []string

+ 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

Mar 17, 2015

Changes in this version

type StoreToPodLister

+ func (s *StoreToPodLister) Exists(pod *api.Pod) (bool, error)

Mar 16, 2015

Changes in this version

+ func NewNamespaceKeyedIndexerAndReflector(lw ListerWatcher, expectedType interface{}, resyncPeriod time.Duration) (indexer Indexer, reflector *Reflector)

Mar 3, 2015

Changes in this version

type FIFO

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

Feb 18, 2015

Changes in this version

+ func MetaNamespaceIndexFunc(obj interface{}) (string, 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 ListFunc func() (runtime.Object, error)

type ListWatch

+ ListFunc ListFunc

+ WatchFunc WatchFunc

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

+ type WatchFunc func(resourceVersion string) (watch.Interface, error)

Feb 3, 2015

Changes in this version

+ func MetaNamespaceKeyFunc(obj interface{}) (string, error)

type FIFO

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

+ type KeyFunc func(obj interface{}) (string, error)

type Poller

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

type Reflector

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

type Store

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

type UndeltaStore

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

Jan 21, 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 18, 2014

Changes in this version

type FIFO

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

type Store

+ ContainedIDs func() util.StringSet

Oct 17, 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) Contains() 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{})

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