watchers

Documentation

Index

• type DaemonSetWatcher
  • func NewDaemonSetWatcher(client tappv1.DaemonSetInterface, name string) *DaemonSetWatcher
  • func (w *DaemonSetWatcher) Setup(ctx context.Context, fromNow bool, labelSelector string) error
  • func (w *DaemonSetWatcher) Start(ctx context.Context, watchConsumer WatchConsumer) <-chan error
• type WatchConsumer

Types

type DaemonSetWatcher

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

DaemonSetWatcher watches StorageOS related daemonsets.

func NewDaemonSetWatcher

func NewDaemonSetWatcher(client tappv1.DaemonSetInterface, name string) *DaemonSetWatcher

NewDaemonSetWatcher consructs a new daemonset watcher.

func (*DaemonSetWatcher) Setup

func (w *DaemonSetWatcher) Setup(ctx context.Context, fromNow bool, labelSelector string) error

setup configures daemonset watcher with init values.

func (*DaemonSetWatcher) Start

func (w *DaemonSetWatcher) Start(ctx context.Context, watchConsumer WatchConsumer) <-chan error

Start watching daemonsets.

type WatchConsumer

type WatchConsumer func(<-chan watch.Event) error

WatchConsumer consumes watch events.