storage

Mar 16, 2016

Changes in this version

+ const MaximumListWait

+ func IsNodeExist(err error) bool

+ func IsNotFound(err error) bool

+ func IsTestFailed(err error) bool

+ func IsUnreachable(err error) bool

+ func ParseListResourceVersion(resourceVersion string) (uint64, error)

type Cacher

+ func NewCacherFromConfig(config CacherConfig) *Cacher

+ func (c *Cacher) Stop()

+ type Config interface

+ GetType func() string

+ NewStorage func() (Interface, error)

Sep 25, 2015

Changes in this version

+ func Everything(runtime.Object) bool

+ func NamespaceKeyFunc(prefix string, obj runtime.Object) (string, error)

+ func NoNamespaceKeyFunc(prefix string, obj runtime.Object) (string, error)

+ func ParseWatchResourceVersion(resourceVersion, kind string) (uint64, error)

+ type Cacher struct

+ func NewCacher(config CacherConfig) *Cacher

+ func (c *Cacher) Backends() []string

+ func (c *Cacher) Codec() runtime.Codec

+ func (c *Cacher) Create(key string, obj, out runtime.Object, ttl uint64) error

+ func (c *Cacher) Delete(key string, out runtime.Object) error

+ func (c *Cacher) Get(key string, objPtr runtime.Object, ignoreNotFound bool) error

+ func (c *Cacher) GetToList(key string, filter FilterFunc, listObj runtime.Object) error

+ func (c *Cacher) GuaranteedUpdate(key string, ptrToType runtime.Object, ignoreNotFound bool, ...) error

+ func (c *Cacher) LastSyncResourceVersion() (uint64, error)

+ func (c *Cacher) List(key string, filter FilterFunc, listObj runtime.Object) error

+ func (c *Cacher) ListFromMemory(key string, listObj runtime.Object) error

+ func (c *Cacher) Set(key string, obj, out runtime.Object, ttl uint64) error

+ func (c *Cacher) Versioner() Versioner

+ func (c *Cacher) Watch(key string, resourceVersion uint64, filter FilterFunc) (watch.Interface, error)

+ func (c *Cacher) WatchList(key string, resourceVersion uint64, filter FilterFunc) (watch.Interface, error)

+ type CacherConfig struct

+ CacheCapacity int

+ KeyFunc func(runtime.Object) (string, error)

+ NewListFunc func() runtime.Object

+ ResourcePrefix string

+ StopChannel <-chan struct{}

+ Storage Interface

+ Type interface{}

+ Versioner Versioner

+ type FilterFunc func(obj runtime.Object) bool

+ type Interface interface

+ Backends func() []string

+ Codec func() runtime.Codec

+ Create func(key string, obj, out runtime.Object, ttl uint64) error

+ Delete func(key string, out runtime.Object) error

+ Get func(key string, objPtr runtime.Object, ignoreNotFound bool) error

+ GetToList func(key string, filter FilterFunc, listObj runtime.Object) error

+ GuaranteedUpdate func(key string, ptrToType runtime.Object, ignoreNotFound bool, ...) error

+ List func(key string, filter FilterFunc, listObj runtime.Object) error

+ Set func(key string, obj, out runtime.Object, ttl uint64) error

+ Versioner func() Versioner

+ Watch func(key string, resourceVersion uint64, filter FilterFunc) (watch.Interface, error)

+ WatchList func(key string, resourceVersion uint64, filter FilterFunc) (watch.Interface, error)

+ type ResponseMeta struct

+ Expiration *time.Time

+ ResourceVersion uint64

+ TTL int64

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

+ type UpdateFunc func(input runtime.Object, res ResponseMeta) (output runtime.Object, ttl *uint64, err error)

+ func SimpleUpdate(fn SimpleUpdateFunc) UpdateFunc

+ type Versioner interface

+ ObjectResourceVersion func(obj runtime.Object) (uint64, error)

+ UpdateList func(obj runtime.Object, resourceVersion uint64) error

+ UpdateObject func(obj runtime.Object, expiration *time.Time, resourceVersion uint64) error