watch

Documentation

Index

• type ResourceWatcher
  • func New() *ResourceWatcher
  • func (w ResourceWatcher) Create(ctx context.Context, event event.CreateEvent, ...)
  • func (w ResourceWatcher) Delete(ctx context.Context, event event.DeleteEvent, ...)
  • func (w ResourceWatcher) Generic(ctx context.Context, event event.GenericEvent, ...)
  • func (w ResourceWatcher) Read(watchedName types.NamespacedName) []types.NamespacedName
  • func (w ResourceWatcher) Update(ctx context.Context, event event.UpdateEvent, ...)
  • func (w ResourceWatcher) Watch(watchedName, dependentName types.NamespacedName)

Types

type ResourceWatcher

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

ResourceWatcher implements handler.EventHandler and is used to trigger reconciliation when a watched object changes. It's designed to only be used for a single type of object. If multiple types should be watched, one ResourceWatcher for each type should be used.

func New

func New() *ResourceWatcher

New will create a new ResourceWatcher with no watched objects.

func (ResourceWatcher) Create

func (w ResourceWatcher) Create(ctx context.Context, event event.CreateEvent, queue workqueue.RateLimitingInterface)

func (ResourceWatcher) Delete

func (w ResourceWatcher) Delete(ctx context.Context, event event.DeleteEvent, queue workqueue.RateLimitingInterface)

func (ResourceWatcher) Generic

func (w ResourceWatcher) Generic(ctx context.Context, event event.GenericEvent, queue workqueue.RateLimitingInterface)

func (ResourceWatcher) Read

func (w ResourceWatcher) Read(watchedName types.NamespacedName) []types.NamespacedName

func (ResourceWatcher) Update

func (w ResourceWatcher) Update(ctx context.Context, event event.UpdateEvent, queue workqueue.RateLimitingInterface)

func (ResourceWatcher) Watch

func (w ResourceWatcher) Watch(watchedName, dependentName types.NamespacedName)

Watch will add a new object to watch.