notifications

Documentation

Index

• type IncidentNotifier
  • func NewIncidentNotifier(db *db.DB) *IncidentNotifier
  • func (n *IncidentNotifier) Enqueue(project *db.Project, app *model.Application, ...)
• type NotificationClient
• type Opsgenie
  • func NewOpsgenie(apiKey string, euInstance bool) *Opsgenie
  • func (og *Opsgenie) SendIncident(ctx context.Context, baseUrl string, n *db.IncidentNotification) error
• type Pagerduty
  • func NewPagerduty(integrationKey string) *Pagerduty
  • func (pd *Pagerduty) SendIncident(ctx context.Context, baseUrl string, n *db.IncidentNotification) error
• type Slack
  • func NewSlack(token, channel string) *Slack
  • func (s *Slack) SendDeployment(ctx context.Context, project *db.Project, ds model.ApplicationDeploymentStatus) error
  • func (s *Slack) SendIncident(ctx context.Context, baseUrl string, n *db.IncidentNotification) error
• type Teams
  • func NewTeams(webhookUrl string) *Teams
  • func (t *Teams) SendDeployment(ctx context.Context, project *db.Project, ds model.ApplicationDeploymentStatus) error
  • func (t *Teams) SendIncident(ctx context.Context, baseUrl string, n *db.IncidentNotification) error

Types

type IncidentNotifier

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

func NewIncidentNotifier

func NewIncidentNotifier(db *db.DB) *IncidentNotifier

func (*IncidentNotifier) Enqueue

func (n *IncidentNotifier) Enqueue(project *db.Project, app *model.Application, incident *model.ApplicationIncident, now timeseries.Time)

type NotificationClient

type NotificationClient interface {
	SendIncident(ctx context.Context, baseUrl string, n *db.IncidentNotification) error
}

type Opsgenie

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

func NewOpsgenie

func NewOpsgenie(apiKey string, euInstance bool) *Opsgenie

func (*Opsgenie) SendIncident

func (og *Opsgenie) SendIncident(ctx context.Context, baseUrl string, n *db.IncidentNotification) error

type Pagerduty

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

func NewPagerduty

func NewPagerduty(integrationKey string) *Pagerduty

func (*Pagerduty) SendIncident

func (pd *Pagerduty) SendIncident(ctx context.Context, baseUrl string, n *db.IncidentNotification) error

type Slack

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

func NewSlack

func NewSlack(token, channel string) *Slack

func (*Slack) SendDeployment

func (s *Slack) SendDeployment(ctx context.Context, project *db.Project, ds model.ApplicationDeploymentStatus) error

func (*Slack) SendIncident

func (s *Slack) SendIncident(ctx context.Context, baseUrl string, n *db.IncidentNotification) error

type Teams

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

func NewTeams

func NewTeams(webhookUrl string) *Teams

func (*Teams) SendDeployment

func (t *Teams) SendDeployment(ctx context.Context, project *db.Project, ds model.ApplicationDeploymentStatus) error

func (*Teams) SendIncident

func (t *Teams) SendIncident(ctx context.Context, baseUrl string, n *db.IncidentNotification) error