cache

Documentation

Index

• type ResourceCache
  • func NewResourceCache(args ResourceCacheArgs) ResourceCache
• type ResourceCacheArgs

Types

type ResourceCache

type ResourceCache interface {
	// Set sets the key to the provided value, and generates an update
	// on the queue the value has changed.
	Set(key string, value interface{})

	// Get gets the value associated with the given key.  Returns nil
	// if the key is not present.
	Get(key string) (interface{}, bool)

	// Prime sets the key to the provided value, but does not generate
	// and update on the queue ever.
	Prime(key string, value interface{})

	// Delete deletes the value identified by the given key from the cache, and
	// generates an update on the queue if a value was deleted.
	Delete(key string)

	// Clean removes the object identified by the given key from the cache.
	// It does not generate an update on the queue.
	Clean(key string)

	// ListKeys lists the keys currently in the cache.
	ListKeys() []string

	// Run enables the generation of events on the output queue starts
	// cache reconciliation.
	Run(reconcilerPeriod string)

	// GetQueue returns the cache's output queue, which emits a stream
	// of any keys which have been created, modified, or deleted.
	GetQueue() workqueue.RateLimitingInterface
}

ResourceCache stores resources and queues updates when those resources are created, modified, or deleted. It de-duplicates updates by ensuring updates are only queued when an object has changed.

func NewResourceCache

func NewResourceCache(args ResourceCacheArgs) ResourceCache

NewResourceCache builds and returns a resource cache using the provided arguments.

type ResourceCacheArgs

type ResourceCacheArgs struct {
	// ListFunc returns a mapping of keys to objects from the Calico datastore.
	ListFunc func() (map[string]interface{}, error)

	// ObjectType is the type of object which is to be stored in this cache.
	ObjectType reflect.Type
}

ResourceCacheArgs struct passed to constructor of ResourceCache. Groups togather all the arguments to pass in single struct.