Documentation
¶
Index ¶
- Constants
- type DynamicWatches
- type DynamicWatchesAnnotationImpl
- func (impl *DynamicWatchesAnnotationImpl) FindWatchers(watchedMeta metav1.Object, watchedObject runtime.Object) []types.NamespacedName
- func (impl *DynamicWatchesAnnotationImpl) RemoveWatcher(watcher types.NamespacedName) error
- func (impl *DynamicWatchesAnnotationImpl) UpdateWatch(watcher types.NamespacedName, watched []types.NamespacedName) error
Constants ¶
View Source
const ( WatchedByAnnotation = "cassandra.datastax.com/watched-by" WatchedLabel = "cassandra.datastax.com/watched" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DynamicWatches ¶
type DynamicWatches interface {
UpdateWatch(watcher types.NamespacedName, watched []types.NamespacedName) error
RemoveWatcher(watcher types.NamespacedName) error
FindWatchers(meta metav1.Object, object runtime.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(watchedMeta metav1.Object, watchedObject runtime.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
Click to show internal directories.
Click to hide internal directories.