dynamicwatcher

Documentation

Index

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

Types

type SkipNamespaceFunc

type SkipNamespaceFunc func(string) bool

type WatchHandler

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

func NewWatchHandler

func NewWatchHandler(k8sClient k8sclient.K8sClientInterface, skipNamespaceFunc SkipNamespaceFunc) *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)