dynamicwatcher

Documentation

Index

• type DynamicWatcher
  • func New(log logr.Logger, scheme *runtime.Scheme, restMapper meta.RESTMapper, ...) *DynamicWatcher
  • func (dw *DynamicWatcher) Free(owner client.Object) error
  • func (dw *DynamicWatcher) OwnersForNamespacedGKV(ngvk namespacedGKV) []OwnerRef
  • func (dw *DynamicWatcher) Start(ctx context.Context, handler handler.EventHandler, ...) error
  • func (dw *DynamicWatcher) Watch(owner client.Object, obj runtime.Object) error
• type EnqueueWatchingObjects
  • func (e *EnqueueWatchingObjects) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueWatchingObjects) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueWatchingObjects) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueWatchingObjects) InjectScheme(s *runtime.Scheme) error
  • func (e *EnqueueWatchingObjects) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type OwnerRef

Types

type DynamicWatcher

type DynamicWatcher struct {
	// contains filtered or unexported fields
}

func New

func New(
	log logr.Logger,
	scheme *runtime.Scheme,
	restMapper meta.RESTMapper,
	client dynamic.Interface,
) *DynamicWatcher

func (*DynamicWatcher) Free

func (dw *DynamicWatcher) Free(owner client.Object) error

Free all watches associated with the given owner.

func (*DynamicWatcher) OwnersForNamespacedGKV

func (dw *DynamicWatcher) OwnersForNamespacedGKV(ngvk namespacedGKV) []OwnerRef

func (*DynamicWatcher) Start

func (dw *DynamicWatcher) Start(ctx context.Context, handler handler.EventHandler, queue workqueue.RateLimitingInterface, predicates ...predicate.Predicate) error

Starts this event source.

func (*DynamicWatcher) Watch

func (dw *DynamicWatcher) Watch(owner client.Object, obj runtime.Object) error

Watch the given object type and associate the watch with the given owner.

type EnqueueWatchingObjects

type EnqueueWatchingObjects struct {
	WatcherRefGetter ownerRefGetter
	// WatcherType is the type of the Owner object to look for in OwnerReferences.  Only Group and Kind are compared.
	WatcherType   runtime.Object
	ClusterScoped bool
	// contains filtered or unexported fields
}

func (*EnqueueWatchingObjects) Create

func (e *EnqueueWatchingObjects) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*EnqueueWatchingObjects) Delete

func (e *EnqueueWatchingObjects) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*EnqueueWatchingObjects) Generic

func (e *EnqueueWatchingObjects) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (*EnqueueWatchingObjects) InjectScheme

func (e *EnqueueWatchingObjects) InjectScheme(s *runtime.Scheme) error

InjectScheme is called by the Controller to provide a singleton scheme to the EnqueueRequestForOwner.

func (*EnqueueWatchingObjects) Update

func (e *EnqueueWatchingObjects) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type OwnerRef

type OwnerRef struct {
	UID       types.UID
	Group     string
	Kind      string
	Name      string
	Namespace string
}