notifier

type Notifier ¶

type Notifier interface {
	Notify(context.Context, *config.Technical, ...*model.Alert) (bool, error)
	String() string
}

Notifier notifies about alerts under constraints of the given context. It returns an error if unsuccessful and a flag whether the error is recoverable. This information is useful for a retry logic.

func NewNotifiers(log *wlog.Logger, nrs *notifiers.Notifiers) ([]Notifier, error)

type Queue ¶

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

func NewQueue(log *wlog.Logger, wait time.Duration, notifiers []Notifier) *Queue

func (q *Queue) Notify(ctx context.Context, onduty *config.Technical, items ...*model.Alert) []*model.Alert

func (q *Queue) Process(ctx context.Context, onduty *config.Technical)

func (q *Queue) Push(v *model.Alert)

func (q *Queue) Stop()