cache

Documentation

Index

• func NewResourceInformer(config ResourceSyncConfig) 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 ResourceSyncConfig
• type ResourcecHash

Functions

func NewResourceInformer

func NewResourceInformer(config ResourceSyncConfig) 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 ResourceSyncConfig

type ResourceSyncConfig struct {
	ClusterName    string
	DynamicClient  dynamic.Interface
	GVR            schema.GroupVersionResource
	Namespace      string
	Selectors      []utils.Selector
	JSONPathParser *utils.JSONPathParser
	TransformFunc  cache.TransformFunc
	ResyncPeriod   time.Duration
	Handler        ResourceHandler
}

type ResourcecHash

type ResourcecHash struct {
	ResourceVersion string
	Hash            string
}