dynamicwatcher

Documentation

Index

• type WatchHandler
  • func NewWatchHandler(k8sClient k8sclient.K8sClientInterface, cfg config.Config) *WatchHandler
  • func (wh *WatchHandler) AddAdaptor(adaptor watcher.Adaptor)
  • func (wh *WatchHandler) Start(ctx context.Context)
  • func (wh *WatchHandler) Stop(_ context.Context)

Types

type WatchHandler

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

func NewWatchHandler

func NewWatchHandler(k8sClient k8sclient.K8sClientInterface, cfg config.Config) *WatchHandler

func (*WatchHandler) AddAdaptor

func (wh *WatchHandler) AddAdaptor(adaptor watcher.Adaptor)

func (*WatchHandler) Start

func (wh *WatchHandler) Start(ctx context.Context)

func (*WatchHandler) Stop

func (wh *WatchHandler) Stop(_ context.Context)