runtime

Documentation

Index

• type RuntimeMonitor
  • func NewRuntimeMonitor(log logr.Logger) (*RuntimeMonitor, error)
  • func (monitor *RuntimeMonitor) AddModellerChs(profileName string, ch chan uint32)
  • func (monitor *RuntimeMonitor) Close()
  • func (monitor *RuntimeMonitor) CollectExistingTargetContainers() error
  • func (monitor *RuntimeMonitor) DeleteModellerChs(profileName string)
  • func (monitor *RuntimeMonitor) IsMonitoring() (bool, error)
  • func (monitor *RuntimeMonitor) Run(stopCh <-chan struct{})
  • func (monitor *RuntimeMonitor) SetTaskNotifyChs(createCh chan varmortypes.ContainerInfo, ...)

Types

type RuntimeMonitor

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

func NewRuntimeMonitor

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

func (*RuntimeMonitor) AddModellerChs

func (monitor *RuntimeMonitor) AddModellerChs(profileName string, ch chan uint32)

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 the enforcer

func (*RuntimeMonitor) DeleteModellerChs

func (monitor *RuntimeMonitor) DeleteModellerChs(profileName string)

func (*RuntimeMonitor) IsMonitoring

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

func (*RuntimeMonitor) Run

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

func (*RuntimeMonitor) SetTaskNotifyChs

func (monitor *RuntimeMonitor) SetTaskNotifyChs(
	createCh chan varmortypes.ContainerInfo,
	deleteCh chan varmortypes.ContainerInfo,
	deleteSynCh chan bool)