cache

Documentation

Index

• func CompareResourverVersion(obj interface{}, resourceVersion string) (int, error)
• func NewResourceInformer(lw cache.ListerWatcher, selector ResourceSelector, ...) cache.Controller
• type ResourceCache
  • func NewResourceCache() *ResourceCache
  • func (c *ResourceCache) Add(obj interface{}) error
  • func (c *ResourceCache) Delete(obj interface{}) error
  • func (c *ResourceCache) Get(obj interface{}) (item interface{}, exists bool, err error)
  • func (c *ResourceCache) GetByKey(key string) (item interface{}, exists bool, err error)
  • func (c *ResourceCache) IsNewer(obj interface{}) (bool, error)
  • func (c *ResourceCache) List() []interface{}
  • func (c *ResourceCache) ListKeys() []string
  • func (c *ResourceCache) Replace(objs []interface{}, resourceVersion string) error
  • func (c *ResourceCache) Resync() error
  • func (c *ResourceCache) Update(obj interface{}) error
• type ResourceHandler
• type ResourceHandlerFuncs
  • func (r ResourceHandlerFuncs) OnAdd(obj interface{}) error
  • func (r ResourceHandlerFuncs) OnDelete(obj interface{}) error
  • func (r ResourceHandlerFuncs) OnUpdate(newObj interface{}) error
• type ResourceSelector
• type ResourcecHash

Functions

func CompareResourverVersion

func CompareResourverVersion(obj interface{}, resourceVersion string) (int, error)

func NewResourceInformer

func NewResourceInformer(lw cache.ListerWatcher,
	selector ResourceSelector,
	transform cache.TransformFunc,
	resyncPeriod time.Duration,
	handler ResourceHandler,
	knownObjects cache.KeyListerGetter,
) cache.Controller

Types

type ResourceCache

type ResourceCache struct {
	// contains filtered or unexported fields
}

func NewResourceCache

func NewResourceCache() *ResourceCache

func (*ResourceCache) Add

func (c *ResourceCache) Add(obj interface{}) error

func (*ResourceCache) Delete

func (c *ResourceCache) Delete(obj interface{}) error

func (*ResourceCache) Get

func (c *ResourceCache) Get(obj interface{}) (item interface{}, exists bool, err error)

func (*ResourceCache) GetByKey

func (c *ResourceCache) GetByKey(key string) (item interface{}, exists bool, err error)

func (*ResourceCache) IsNewer

func (c *ResourceCache) IsNewer(obj interface{}) (bool, error)

func (*ResourceCache) List

func (c *ResourceCache) List() []interface{}

func (*ResourceCache) ListKeys

func (c *ResourceCache) ListKeys() []string

func (*ResourceCache) Replace

func (c *ResourceCache) Replace(objs []interface{}, resourceVersion string) error

func (*ResourceCache) Resync

func (c *ResourceCache) Resync() error

func (*ResourceCache) Update

func (c *ResourceCache) Update(obj interface{}) error

type ResourceHandler

type ResourceHandler interface {
	OnAdd(obj interface{}) error
	OnUpdate(newObj interface{}) error
	OnDelete(obj interface{}) error
}

type ResourceHandlerFuncs

type ResourceHandlerFuncs struct {
	AddFunc    func(obj interface{}) error
	UpdateFunc func(newObj interface{}) error
	DeleteFunc func(obj interface{}) error
}

func (ResourceHandlerFuncs) OnAdd

func (r ResourceHandlerFuncs) OnAdd(obj interface{}) error

func (ResourceHandlerFuncs) OnDelete

func (r ResourceHandlerFuncs) OnDelete(obj interface{}) error

func (ResourceHandlerFuncs) OnUpdate

func (r ResourceHandlerFuncs) OnUpdate(newObj interface{}) error

type ResourceSelector

type ResourceSelector interface {
	ApplyToList(*metav1.ListOptions)
	Predicate(interface{}) bool
}

type ResourcecHash

type ResourcecHash struct {
	ResourceVersion string
	Hash            string
}