mailout

type Database interface {
	ExecContext(context.Context, string, ...any) (sql.Result, error)
	QueryContext(context.Context, string, ...any) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...any) *sql.Row
}

type DeliveryJob struct {
	Message Message
}

type DirectSender struct {
	Hostname    string
	DialTimeout time.Duration
}

type Message struct {
	MessageID string
	Kind      string
	From      string
	To        string
	Subject   string
	Body      string
	HTMLBody  string
}

type PermanentError struct {
	Err error
}

type Record struct {
	Task
	Status      string
	Attempts    int
	NextAttempt time.Time
	SentAt      time.Time
	LastError   string
}

type Result struct {
	ID          string
	Status      string
	Attempts    int
	NextAttempt time.Time
	Err         error
}

type Sender func(context.Context, Message) error

type Task struct {
	ID             string
	InstallationID string
	Kind           string
	Route          string
	Message        Message
	CreatedAt      time.Time
	ExpiresAt      time.Time
	Accepted       chan error
	Reply          chan Result
	Done           <-chan struct{}
}