daemon

Documentation

Index

• type BodyType
  • func (b BodyType) String() string
• type Daemon
  • func New(ctx context.Context, backlog int, matchers []*Matcher) *Daemon
  • func (d *Daemon) Shutdown(ctx context.Context) error
• type Format
• type Matcher
  • func NewMatcher(id string, numWorkers int, provider providers.Provider, pattern string) (*Matcher, error)
  • func (m *Matcher) Enqueue(msg Message)
• type Message

Types

type BodyType

type BodyType int32

const (
	BodyTypePlain BodyType = iota + 1
	BodyTypeHTML
)

func (BodyType) String

func (b BodyType) String() string

type Daemon

type Daemon struct {
	Queue chan Message
	// contains filtered or unexported fields
}

Daemon orchestrates processing and sending incoming messages

func New

func New(ctx context.Context, backlog int, matchers []*Matcher) *Daemon

New spawns a new sender daemon to process all the incoming messages

func (*Daemon) Shutdown

func (d *Daemon) Shutdown(ctx context.Context) error

Shutdown stops the processing of messages. Any unsent messages will be dropped.

type Format

type Format string

const (
	FormatPlain Format = "PLAIN"
	FormatHTML  Format = "HTML"
)

type Matcher

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

func NewMatcher

func NewMatcher(id string, numWorkers int, provider providers.Provider, pattern string) (*Matcher, error)

NewMatcher creates a new matcher for the provider with its associated queue

func (*Matcher) Enqueue

func (m *Matcher) Enqueue(msg Message)

Enqueue adds the message to the provider's queue

type Message

type Message struct {
	To          []string
	From        string
	Subject     string
	Body        string
	Type        Format
	ReplyTo     *string
	SpanContext trace.SpanContext
}

Message represents an email to be sent to one or more recipients