watcher

Documentation

Index

• func Watch(ctx context.Context, watcher watch.Interface, actions ...ActionFunc) error
• func WatchManagedObjects(ctx context.Context, obj runtime.Object, mgr manager.Manager, ...) error
• func WatchObject(ctx context.Context, obj runtime.Object, mgr manager.Manager, ...) error
• func WatchObjects(ctx context.Context, watchClient Watcher, labelSelector, fieldSelector string, ...) error
• func WatchSingleObject(ctx context.Context, watchClient Watcher, obj metav1.Object, ...) error
• type ActionFunc
• type ActionFuncs
• type ActionReconciler
  • func (r *ActionReconciler) InjectClient(c client.Client) error
  • func (r *ActionReconciler) Reconcile(req reconcile.Request) (reconcile.Result, error)
• type EnqueueRequestForObject
  • func (e *EnqueueRequestForObject) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForObject) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForObject) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForObject) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type InfiniteActionFunc
• type Watcher

Functions

func Watch

func Watch(ctx context.Context, watcher watch.Interface, actions ...ActionFunc) error

func WatchManagedObjects

func WatchManagedObjects(ctx context.Context, obj runtime.Object, mgr manager.Manager, action InfiniteActionFunc) error

func WatchObject

func WatchObject(ctx context.Context, obj runtime.Object, mgr manager.Manager, logger *logrus.Entry, action ActionFunc) error

func WatchObjects

func WatchObjects(
	ctx context.Context, watchClient Watcher,
	labelSelector, fieldSelector string,
	actions ...ActionFunc,
) error

func WatchSingleObject

func WatchSingleObject(ctx context.Context, watchClient Watcher, obj metav1.Object, actions ...ActionFunc) error

WatchSingleObject watches changes of the given object, and apply the registered actions for every change

Types

type ActionFunc

type ActionFunc func(obj runtime.Object) (done bool, err error)

type ActionFuncs

type ActionFuncs []ActionFunc

type ActionReconciler

type ActionReconciler struct {
	client.Client
	Action ActionFunc
	Type   runtime.Object
	Done   func()

	Logger *logrus.Entry
	// contains filtered or unexported fields
}

func (*ActionReconciler) InjectClient

func (r *ActionReconciler) InjectClient(c client.Client) error

func (*ActionReconciler) Reconcile

func (r *ActionReconciler) Reconcile(req reconcile.Request) (reconcile.Result, error)

type EnqueueRequestForObject

type EnqueueRequestForObject struct{}

func (*EnqueueRequestForObject) Create

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

Create implements EventHandler

func (*EnqueueRequestForObject) Delete

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

Delete implements EventHandler

func (*EnqueueRequestForObject) Generic

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

Generic implements EventHandler

func (*EnqueueRequestForObject) Update

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

Update implements EventHandler

type InfiniteActionFunc

type InfiniteActionFunc func(obj runtime.Object) error

type Watcher

type Watcher interface {
	Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
}