watchermanager

Documentation

Index

• Constants
• type IWatcher
• type IWatcherManager
• type WatcherManager
  • func NewWatcherManager() *WatcherManager
  • func (wm *WatcherManager) Start(ctx context.Context) error
  • func (wm *WatcherManager) Stop(ctx context.Context) error

Constants

const (
	// DefaultRefreshRate is the default refresh rate for watchers.
	DefaultRefreshRate = 30 * time.Second
)

Types

type IWatcher

type IWatcher interface {
	// Init, Stop, and Refresh should only be called by watchermanager.
	Init(ctx context.Context) error
	Stop(ctx context.Context) error
	Refresh(ctx context.Context) error
}

type IWatcherManager

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

type WatcherManager

type WatcherManager struct {
	Watchers []IWatcher
	// contains filtered or unexported fields
}

func NewWatcherManager

func NewWatcherManager() *WatcherManager

func (*WatcherManager) Start

func (wm *WatcherManager) Start(ctx context.Context) error

func (*WatcherManager) Stop

func (wm *WatcherManager) Stop(ctx context.Context) error