Documentation
¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
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)
Source Files
Click to show internal directories.
Click to hide internal directories.