logalerting

Documentation

Index

• type Config
• type Listener
  • func (l *Listener) Config() interface{}
  • func (l *Listener) Init(context api.Context) error
  • func (l *Listener) Name() string
  • func (l *Listener) Start() error
  • func (l *Listener) Stop()
  • func (l *Listener) Subscribe(event eventbus.Event)

Types

type Config

type Config struct {
	AlertManagerAddress []string      `yaml:"alertManagerAddress,omitempty" validate:"required"`
	BufferSize          int           `yaml:"bufferSize,omitempty" default:"100"`
	BatchTimeout        time.Duration `yaml:"batchTimeout,omitempty" default:"10s"`
	BatchSize           int           `yaml:"batchSize,omitempty" default:"10"`
}

type Listener

type Listener struct {
	SendBatch []*eventbus.Event
	// contains filtered or unexported fields
}

func (*Listener) Config

func (l *Listener) Config() interface{}

func (*Listener) Init

func (l *Listener) Init(context api.Context) error

func (*Listener) Name

func (l *Listener) Name() string

func (*Listener) Start

func (l *Listener) Start() error

func (*Listener) Stop

func (l *Listener) Stop()

func (*Listener) Subscribe

func (l *Listener) Subscribe(event eventbus.Event)