monitorcontroller

Documentation

Index

• type MonitorController
  • func New(config *config.Config, monitoringSender MonitoringSender) (monitor *MonitorController, err error)
  • func (monitor *MonitorController) Close()
  • func (monitor *MonitorController) CloudConnected()
  • func (monitor *MonitorController) CloudDisconnected()
  • func (monitor *MonitorController) SendNodeMonitoring(nodeMonitoring aostypes.NodeMonitoring)
• type MonitoringSender

Types

type MonitorController

type MonitorController struct {
	sync.Mutex
	// contains filtered or unexported fields
}

MonitorController instance.

func New

func New(
	config *config.Config, monitoringSender MonitoringSender,
) (monitor *MonitorController, err error)

New creates new monitor controller instance.

func (*MonitorController) Close

func (monitor *MonitorController) Close()

Close closes monitor controller instance.

func (*MonitorController) CloudConnected

func (monitor *MonitorController) CloudConnected()

CloudConnected indicates unit connected to cloud.

func (*MonitorController) CloudDisconnected

func (monitor *MonitorController) CloudDisconnected()

CloudDisconnected indicates unit disconnected from cloud.

func (*MonitorController) SendNodeMonitoring

func (monitor *MonitorController) SendNodeMonitoring(nodeMonitoring aostypes.NodeMonitoring)

SendNodeMonitoring sends monitoring data.

type MonitoringSender

type MonitoringSender interface {
	SubscribeForConnectionEvents(consumer amqphandler.ConnectionEventsConsumer) error
	UnsubscribeFromConnectionEvents(consumer amqphandler.ConnectionEventsConsumer) error
	SendMonitoringData(monitoringData cloudprotocol.Monitoring) error
}

MonitoringSender sends monitoring data.