integrator

Documentation

Index

• Constants
• type Alert
• type Integrator
  • func New(cfg *config.Config) *Integrator
  • func (i *Integrator) MonitorWaitingQueue()
  • func (i *Integrator) Run()
  • func (i *Integrator) RunIntegratorSocketServer()
• type Rule

Constants

const (
	DEV = "dev"
)

Types

type Alert

type Alert struct {
	Rule     Rule   `json:"rule,omitempty"`
	Location string `json:"location,omitempty"`
}

type Integrator

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

func New

func New(cfg *config.Config) *Integrator

New creates integrator instance

func (*Integrator) MonitorWaitingQueue

func (i *Integrator) MonitorWaitingQueue()

MonitorWaitingQueue Get waiting queue size every 10 seconds Warning if waiting queue size > maxWorkers configured

func (*Integrator) Run

func (i *Integrator) Run()

Run parsing alerts.json file. if an alert is match with conditions then execute integration command

func (*Integrator) RunIntegratorSocketServer

func (i *Integrator) RunIntegratorSocketServer()

RunIntegratorSocketServer start a unix socket server

type Rule

type Rule struct {
	Level  *int     `json:"level,omitempty"`
	ID     string   `json:"id"`
	Groups []string `json:"groups,omitempty"`
}