runtime

Documentation

Index

• type RuntimeMonitor
  • func NewRuntimeMonitor(log logr.Logger) (*RuntimeMonitor, error)
  • func (monitor *RuntimeMonitor) AddTaskNotifyChs(subscriber string, startCh *chan varmortypes.ContainerInfo, ...)
  • func (monitor *RuntimeMonitor) Close()
  • func (monitor *RuntimeMonitor) CollectExistingTargetContainers() error
  • func (monitor *RuntimeMonitor) DeleteTaskNotifyChs(subscriber string)
  • func (monitor *RuntimeMonitor) IsMonitoring() (bool, error)
  • func (monitor *RuntimeMonitor) Run(stopCh <-chan struct{})

Types

type RuntimeMonitor

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

func NewRuntimeMonitor

func NewRuntimeMonitor(log logr.Logger) (*RuntimeMonitor, error)

func (*RuntimeMonitor) AddTaskNotifyChs

func (monitor *RuntimeMonitor) AddTaskNotifyChs(
	subscriber string,
	startCh *chan varmortypes.ContainerInfo,
	deleteCh *chan varmortypes.ContainerInfo,
	deleteSynCh *chan bool)

func (*RuntimeMonitor) Close

func (monitor *RuntimeMonitor) Close()

func (*RuntimeMonitor) CollectExistingTargetContainers

func (monitor *RuntimeMonitor) CollectExistingTargetContainers() error

CollectExistingTargetContainers collects all existing containers that should be protected and sends them to subscribers

func (*RuntimeMonitor) DeleteTaskNotifyChs

func (monitor *RuntimeMonitor) DeleteTaskNotifyChs(subscriber string)

func (*RuntimeMonitor) IsMonitoring

func (monitor *RuntimeMonitor) IsMonitoring() (bool, error)

func (*RuntimeMonitor) Run

func (monitor *RuntimeMonitor) Run(stopCh <-chan struct{})