notifier

Documentation

Overview

Package notifier fetches notifications from the database and sends them to the specified remote handler.

Index

• type HTTPNotifier
  • func NewHTTPNotifier(URL string) (*HTTPNotifier, error)
  • func (notifier *HTTPNotifier) Healthcheck() health.Status
  • func (notifier *HTTPNotifier) Run(st *utils.Stopper)
• type Notifier

Types

type HTTPNotifier

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

A HTTPNotifier dispatches notifications to an HTTP endpoint with POST requests

func NewHTTPNotifier

func NewHTTPNotifier(URL string) (*HTTPNotifier, error)

NewHTTPNotifier initializes a new HTTPNotifier

func (*HTTPNotifier) Healthcheck

func (notifier *HTTPNotifier) Healthcheck() health.Status

Healthcheck returns the health of the notifier service

func (*HTTPNotifier) Run

func (notifier *HTTPNotifier) Run(st *utils.Stopper)

Run pops notifications from the database, lock them, send them, mark them as send and unlock them

It uses an exponential backoff when POST requests fail

type Notifier

type Notifier interface {
	Run(*utils.Stopper)
}

A Notifier dispatches notifications