manager

Documentation

Index

• type ResourceWatcher
• type ResourceWatcherNew
• type WatchManager
  • func New() *WatchManager
  • func (m *WatchManager) AddResourceWatcher(s ResourceWatcher)
  • func (m *WatchManager) GetListeners() []listener.ClusterChangeListener
  • func (m *WatchManager) GetResourceWatcherByMCControllerName(name string) ResourceWatcher
  • func (m *WatchManager) Start(stop <-chan struct{}) error

Types

type ResourceWatcher

type ResourceWatcher interface {
	reconciler.DWReconciler
	GetMCController() *mc.MultiClusterController
	GetListener() listener.ClusterChangeListener
	Start(stopCh <-chan struct{}) error
}

ResourceWatcher is the interface used by WatchManager to manage multiple resource watchers.

type ResourceWatcherNew

type ResourceWatcherNew func(*schedulerconfig.SchedulerConfiguration) (ResourceWatcher, error)

type WatchManager

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

WatchManager manages number of resource watchers.

func New

func New() *WatchManager

func (*WatchManager) AddResourceWatcher

func (m *WatchManager) AddResourceWatcher(s ResourceWatcher)

AddResourceWatcher adds a resource watcher to the WatchManager.

func (*WatchManager) GetListeners

func (m *WatchManager) GetListeners() []listener.ClusterChangeListener

func (*WatchManager) GetResourceWatcherByMCControllerName

func (m *WatchManager) GetResourceWatcherByMCControllerName(name string) ResourceWatcher

func (*WatchManager) Start

func (m *WatchManager) Start(stop <-chan struct{}) error