alerts

Documentation

Overview

Package alerts provides set of API to send system and services alerts

Index

• type Alerts
  • func New(config config.Alerts, sender Sender) (instance *Alerts, err error)
  • func (instance *Alerts) Close()
  • func (instance *Alerts) CloudConnected()
  • func (instance *Alerts) CloudDisconnected()
  • func (instance *Alerts) SendAlert(alert interface{})
• type Sender

Types

type Alerts

type Alerts struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Alerts instance.

func New

func New(config config.Alerts, sender Sender) (instance *Alerts, err error)

New creates new alerts object.

func (*Alerts) Close

func (instance *Alerts) Close()

Close closes logging.

func (*Alerts) CloudConnected

func (instance *Alerts) CloudConnected()

CloudConnected indicates unit connected to cloud.

func (*Alerts) CloudDisconnected

func (instance *Alerts) CloudDisconnected()

CloudDisconnected indicates unit disconnected from cloud.

func (*Alerts) SendAlert

func (instance *Alerts) SendAlert(alert interface{})

SendAlert sends alert.

type Sender

type Sender interface {
	SubscribeForConnectionEvents(consumer amqphandler.ConnectionEventsConsumer) error
	UnsubscribeFromConnectionEvents(consumer amqphandler.ConnectionEventsConsumer) error
	SendAlerts(alerts cloudprotocol.Alerts) error
}

Sender alerts sender to the cloud interface.