dynamicwatch

Documentation

Index

• Constants
• type DynamicWatches
  • func NewDynamicSecretWatches(client client.Client) DynamicWatches
• type DynamicWatchesAnnotationImpl
  • func (impl *DynamicWatchesAnnotationImpl) FindWatchers(watchedObject client.Object) []types.NamespacedName
  • func (impl *DynamicWatchesAnnotationImpl) RemoveWatcher(watcher types.NamespacedName) error
  • func (impl *DynamicWatchesAnnotationImpl) UpdateWatch(watcher types.NamespacedName, watched []types.NamespacedName) error

Constants

const (
	WatchedByAnnotation = "cassandra.datastax.com/watched-by"
	WatchedLabel        = "cassandra.datastax.com/watched"
)

Types

type DynamicWatches

type DynamicWatches interface {
	UpdateWatch(watcher types.NamespacedName, watched []types.NamespacedName) error
	RemoveWatcher(watcher types.NamespacedName) error
	FindWatchers(obj client.Object) []types.NamespacedName
}

func NewDynamicSecretWatches

func NewDynamicSecretWatches(client client.Client) DynamicWatches

type DynamicWatchesAnnotationImpl

type DynamicWatchesAnnotationImpl struct {
	Client          runtimeClient.Client
	Ctx             context.Context
	WatchedType     metav1.TypeMeta
	WatchedListType metav1.TypeMeta
	Logger          logr.Logger
}

func (*DynamicWatchesAnnotationImpl) FindWatchers

func (impl *DynamicWatchesAnnotationImpl) FindWatchers(watchedObject client.Object) []types.NamespacedName

func (*DynamicWatchesAnnotationImpl) RemoveWatcher

func (impl *DynamicWatchesAnnotationImpl) RemoveWatcher(watcher types.NamespacedName) error

func (*DynamicWatchesAnnotationImpl) UpdateWatch

func (impl *DynamicWatchesAnnotationImpl) UpdateWatch(watcher types.NamespacedName, watched []types.NamespacedName) error