notify

Documentation

Index

• type Direction
• type Email
  • func NewEmail(cfg *service.Email) (*Email, error)
  • func (mailer *Email) Critical(msg *Message) error
  • func (mailer *Email) Info(msg *Message) error
• type EmailTemplateData
• type Kafka
  • func NewKafka(logger log.Logger, cfg *service.KafkaConfig) (*Kafka, error)
  • func (s *Kafka) Critical(msg *Message) error
  • func (s *Kafka) Info(msg *Message) error
• type Message
• type MockSender
  • func (s *MockSender) CapturedMessage() *Message
  • func (s *MockSender) Critical(msg *Message) error
  • func (s *MockSender) CriticalWasCalled() bool
  • func (s *MockSender) Info(msg *Message) error
  • func (s *MockSender) InfoWasCalled() bool
• type MultiSender
  • func NewMultiSender(logger log.Logger, cfg *service.Notifications, ...) (*MultiSender, error)
  • func (ms *MultiSender) Critical(msg *Message) error
  • func (ms *MultiSender) Info(msg *Message) error
• type PagerDuty
  • func NewPagerDuty(cfg *service.PagerDuty) (*PagerDuty, error)
  • func (pd *PagerDuty) Critical(msg *Message) error
  • func (pd *PagerDuty) Info(msg *Message) error
  • func (pd *PagerDuty) Ping() error
• type Sender
• type Slack
  • func NewSlack(cfg *service.Slack) (*Slack, error)
  • func (s *Slack) Critical(msg *Message) error
  • func (s *Slack) Info(msg *Message) error

Types

type Direction

type Direction string

const (
	Upload   Direction = "upload"
	Download Direction = "download"
)

type Email

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

func NewEmail

func NewEmail(cfg *service.Email) (*Email, error)

func (*Email) Critical

func (mailer *Email) Critical(msg *Message) error

func (*Email) Info

func (mailer *Email) Info(msg *Message) error

type EmailTemplateData

type EmailTemplateData struct {
	CompanyName string // e.g. Moov
	Verb        string // e.g. upload, download
	Filename    string // e.g. 20200529-131400.ach
	Hostname    string

	DebitTotal  string
	CreditTotal string

	BatchCount int
	EntryCount int
}

type Kafka

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

func NewKafka

func NewKafka(logger log.Logger, cfg *service.KafkaConfig) (*Kafka, error)

func (*Kafka) Critical

func (s *Kafka) Critical(msg *Message) error

func (*Kafka) Info

func (s *Kafka) Info(msg *Message) error

type Message

type Message struct {
	Direction Direction
	Filename  string
	File      *ach.File
	Hostname  string

	// Contents will be used instead of the above fields
	Contents string
}

type MockSender

type MockSender struct {
	Err error
	// contains filtered or unexported fields
}

func (*MockSender) CapturedMessage

func (s *MockSender) CapturedMessage() *Message

func (*MockSender) Critical

func (s *MockSender) Critical(msg *Message) error

func (*MockSender) CriticalWasCalled

func (s *MockSender) CriticalWasCalled() bool

func (*MockSender) Info

func (s *MockSender) Info(msg *Message) error

func (*MockSender) InfoWasCalled

func (s *MockSender) InfoWasCalled() bool

type MultiSender

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

MultiSender is a Sender which will attempt to send each Message to every included Sender and returns the first error encountered.

func NewMultiSender

func NewMultiSender(logger log.Logger, cfg *service.Notifications, notifiers *service.UploadNotifiers) (*MultiSender, error)

func (*MultiSender) Critical

func (ms *MultiSender) Critical(msg *Message) error

func (*MultiSender) Info

func (ms *MultiSender) Info(msg *Message) error

type PagerDuty

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

func NewPagerDuty

func NewPagerDuty(cfg *service.PagerDuty) (*PagerDuty, error)

func (*PagerDuty) Critical

func (pd *PagerDuty) Critical(msg *Message) error

func (*PagerDuty) Info

func (pd *PagerDuty) Info(msg *Message) error

func (*PagerDuty) Ping

func (pd *PagerDuty) Ping() error

type Sender

type Sender interface {
	Info(msg *Message) error
	Critical(msg *Message) error
}

type Slack

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

func NewSlack

func NewSlack(cfg *service.Slack) (*Slack, error)

func (*Slack) Critical

func (s *Slack) Critical(msg *Message) error

func (*Slack) Info

func (s *Slack) Info(msg *Message) error