queue

type Config struct {
	// TODO: support json marshal for duration
	Hostname               string        `json:"hostname"`
	Directory              string        `json:"directory"`
	DisableSSLVerification bool          `json:"disable-ssl-verification"`
	InitialInterval        time.Duration `json:"-"`
	RandomizationFactor    float64       `json:"randomization_factor"`
	Multiplier             float64       `json:"multiplier"`
	MaxInterval            time.Duration `json:"-"`
	MaxAttempts            int           `json:"max_attempts"`
	Jitter                 bool          `json:"jitter"`

	// Map domain names to DKIM config for that domain
	DKIMConfigs map[string]DKIMConfig `json:"dkim-configs"`
	// ProcessFunc allow you to define custom process function for message.
	ProcessFunc ProcessFunc `json:"-"`
	// ProcessFailFunc allow you to define processor if message failed with 5xx status.
	ProcessFailFunc ProcessFailFunc `json:"-"`
}

type DKIMConfig struct {
	PrivateKey       string `json:"private-key"`
	Selector         string `json:"selector"`
	Canonicalization string `json:"canonicalization"`
}

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

type HostStatus struct {
	Active bool `json:"active"`
	Length int  `json:"length"`
}

type MailServerFinder interface {
	// Attempt to find the mail servers for the specified host. MX records are
	// checked first. If one or more were found, the records are converted into an
	// array of strings (sorted by priority). If none were found, the original host
	// is returned.
	FindServers(host string) ([]string, error)
}

type Message struct {
	Host    string   `json:"host"`
	From    string   `json:"from"`
	To      []string `json:"to"`
	Attempt int      `json:"attempt"`
	// Metadata can store any data useful for custom processors.
	Metadata map[string]string `json:"metadata"`
	// contains filtered or unexported fields
}

type ProcessFailFunc func(m *Message, s *Storage, err error) error

type ProcessFunc func(m *Message, s *Storage) error

type Queue struct {
	Storage *Storage
	// contains filtered or unexported fields
}

type QueueStatus struct {
	Uptime int                    `json:"uptime"`
	Hosts  map[string]*HostStatus `json:"hosts"`
}

type SMTPError struct {
	Err error
}

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