processor

package
v0.0.0-...-d3ca417 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 1, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.