watcher

type CreateWatchObject ¶

type CreateWatchObject func(namespace string) (WatchObject, error)

CreateWatchObject - A function that creates a WatchObject to be watched (monitored)

type ObjectMonitor ¶

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

ObjectMonitor - Watches a particular kubernetes object through k8s API

func NewObjectMonitor(ctx context.Context, name string, namespace string, handler WatchEventHandler, create CreateWatchObject) (*ObjectMonitor, error)

func (om *ObjectMonitor) Start(ctx context.Context)

func (om *ObjectMonitor) Stop(ctx context.Context)

type ObjectMonitorInterface ¶

type ObjectMonitorInterface interface {
	Start(ctx context.Context)
	Stop(ctx context.Context)
}

type ObjectMonitorManager ¶

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

ObjectMonitorManager - Allows watching multiple k8s objects of the same type in the same namespace through k8s API

func NewObjectMonitorManager(ctx context.Context, namespace string, handler WatchEventHandler, create CreateWatchObject) *ObjectMonitorManager

func (omm *ObjectMonitorManager) Manage(ctx context.Context, names []string)

type ObjectMonitorManagerInterface ¶

type ObjectMonitorManagerInterface interface {
	Manage(ctx context.Context, names []string)
}

type WatchEventHandler ¶

type WatchEventHandler interface {
	Handle(ctx context.Context, event *watch.Event)
	End(ctx context.Context, namespace, name string)
}

WatchEventHandler - Handles watch events relayed by Monitor TODO: check if End() could be changed to accept *watch.Event

type WatchObject ¶

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

WatchObject - Is a wrapper around Watch (implemented by v1.SecretInterface, v1.PodInterface etc.)