detective

Documentation

Index

• Constants
• Variables
• type Detective
  • func New(deliveriesConnPool *dbconn.RoPool, rawLogsAccessor rawlogsdb.Accessor) (Detective, error)
• type Message
• type MessageDelivery
  • func (d *MessageDelivery) ExportCSV(queue, messageid string) []string
• type Messages
• type MessagesPage
  • func (p *MessagesPage) ExportCSV() [][]string
• type QueueName
• type Status
  • func (s Status) MarshalJSON() ([]byte, error)
  • func (s *Status) UnmarshalJSON(d []byte) error

Constants

const ResultsPerPage = 100

Variables

var CSVHeader = []string{
	"MailFrom",
	"MailTo",
	"MessageID",
	"Queue",
	"NumberOfAttempts",
	"TimeMin",
	"TimeMax",
	"Status",
	"DSN",
	"Expired",
	"Relays",
	"RawLogMsgs",
}

var ErrNoAvailableLogs = errors.New(`No available logs`)

Types

type Detective

type Detective interface {
	CheckMessageDelivery(ctx context.Context, from, to string, interval timeutil.TimeInterval, status int, someID string, page int, limit int) (*MessagesPage, error)
	OldestAvailableTime(context.Context) (time.Time, error)
}

func New

func New(deliveriesConnPool *dbconn.RoPool, rawLogsAccessor rawlogsdb.Accessor) (Detective, error)

type Message

type Message struct {
	Queue     QueueName         `json:"queue"`
	MessageID string            `json:"message_id"`
	Entries   []MessageDelivery `json:"entries"`
}

type MessageDelivery

type MessageDelivery struct {
	NumberOfAttempts int        `json:"number_of_attempts"`
	TimeMin          time.Time  `json:"time_min"`
	TimeMax          time.Time  `json:"time_max"`
	Status           Status     `json:"status"`
	Dsn              string     `json:"dsn"`
	Relays           []string   `json:"relays"`
	Expired          *time.Time `json:"expired"`
	MailFrom         string     `json:"from"`
	MailTo           []string   `json:"to"`
	RawLogMsgs       []string   `json:"log_msgs"`
}

func (*MessageDelivery) ExportCSV

func (d *MessageDelivery) ExportCSV(queue, messageid string) []string

type Messages

type Messages = []Message

type MessagesPage

type MessagesPage struct {
	PageNumber   int      `json:"page"`
	FirstPage    int      `json:"first_page"`
	LastPage     int      `json:"last_page"`
	TotalResults int      `json:"total"`
	Messages     Messages `json:"messages"`
}

func (*MessagesPage) ExportCSV

func (p *MessagesPage) ExportCSV() [][]string

type QueueName

type QueueName = string

type Status

type Status parser.SmtpStatus

func (Status) MarshalJSON

func (s Status) MarshalJSON() ([]byte, error)

func (*Status) UnmarshalJSON

func (s *Status) UnmarshalJSON(d []byte) error