cache

type Cache ¶

type Cache interface {
	io.Closer
	// Watch establishes watches for all provided client.Objects.
	// Subsequent calls to Watch will result in no longer necessary
	// watches being stopped and removed and new watches being
	// created
	Watch(context.Context, Watcher, ...client.Object) error
}

Cache is a storage mechanism for keeping track of managed content sources

func NewCache(sourcerer sourcerer, owner client.Object, syncTimeout time.Duration) Cache

type CloserSyncingSource ¶

type CloserSyncingSource interface {
	source.SyncingSource
	io.Closer
}

CloserSyncingSource is a wrapper of the controller-runtime source.SyncingSource that includes methods for:

• Closing the source, stopping it's interaction with the Kubernetes API server and reaction to events

type Watcher ¶

type Watcher interface {
	Watch(source.Source) error
}