processor

Documentation

Index

• func DumpFiredAlerts()
• func RefreshAlertRules()
• func StoreFiredAlerts()
• type Alert
• type Alerts
  • func NewAlerts() Alerts
  • func (alerts Alerts) DumpAlerts()
  • func (alerts Alerts) StoreAlerts()
• type Processor
  • func NewProcessor(mqttClient *mqttclient.MqttClient, statusUpdateSeconds int, smtpServer string) *Processor
  • func (p *Processor) Subscribe(mqttListenTopics []string) error

Functions

func DumpFiredAlerts

func DumpFiredAlerts()

func RefreshAlertRules

func RefreshAlertRules()

func StoreFiredAlerts

func StoreFiredAlerts()

Types

type Alert

type Alert struct {
	IgnoreCount                  int64
	AlertJsonPathOrEventTag      string
	AlertMonitoredActionAndValue string
	Recipients                   string
}

type Alerts

type Alerts struct {
	FiredAlerts map[string][]Alert
}

func NewAlerts

func NewAlerts() Alerts

func (Alerts) DumpAlerts

func (alerts Alerts) DumpAlerts()

func (Alerts) StoreAlerts

func (alerts Alerts) StoreAlerts()

type Processor

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

func NewProcessor

func NewProcessor(mqttClient *mqttclient.MqttClient, statusUpdateSeconds int, smtpServer string) *Processor

func (*Processor) Subscribe

func (p *Processor) Subscribe(mqttListenTopics []string) error