watch

Documentation

Index

• type GroupedRequestWatcher
  • func (grw *GroupedRequestWatcher) Watch(requests <-chan reconcile.Request) error
• type Watcher
  • func NewGroupedRequestWatcher(subWatcher Watcher) Watcher
• type Watchers
  • func (ws *Watchers) AddWatchers(watcher ...Watcher) Watchers
  • func (ws Watchers) ToSlice() []Watcher

Types

type GroupedRequestWatcher

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

GroupedRequestWatcher groups reconcile.Request based on NamespacedName and sends distinct ones to their goroutines.

func (*GroupedRequestWatcher) Watch

func (grw *GroupedRequestWatcher) Watch(requests <-chan reconcile.Request) error

Watch implements watch.Watcher

type Watcher

type Watcher interface {
	// Watch will be called with request data
	Watch(requests <-chan reconcile.Request) error
}

Watcher defines a logic to execute on reconciliation request It's similar to Reconciler loop but it's unmanaged

func NewGroupedRequestWatcher

func NewGroupedRequestWatcher(subWatcher Watcher) Watcher

NewGroupedRequestWatcher creates a new GroupedRequestWatcher with empty map of channels

type Watchers

type Watchers []Watcher

Watchers is a utility struct to deal with multiple watchers

func (*Watchers) AddWatchers

func (ws *Watchers) AddWatchers(watcher ...Watcher) Watchers

AddWatchers adds passed watchers

func (Watchers) ToSlice

func (ws Watchers) ToSlice() []Watcher

ToSlice converts Watchers to primitive array - []Watcher