dashboard

Documentation

Index

• type Dashboard
  • func New(pool *dbconn.RoPool) (Dashboard, error)
• type MailTrafficPerSenderOverTimeResult
• type Pair
• type Pairs
• type Queryable
• type QueryableRows
• type QueryableScanner

Types

type Dashboard

type Dashboard interface {
	CountByStatus(context.Context, parser.SmtpStatus, timeutil.TimeInterval) (int, error)
	TopBusiestDomains(context.Context, timeutil.TimeInterval) (Pairs, error)
	TopBouncedDomains(context.Context, timeutil.TimeInterval) (Pairs, error)
	TopDeferredDomains(context.Context, timeutil.TimeInterval) (Pairs, error)
	DeliveryStatus(context.Context, timeutil.TimeInterval) (Pairs, error)

	SentMailsByMailbox(context.Context, timeutil.TimeInterval, int) (MailTrafficPerSenderOverTimeResult, error)
	BouncedMailsByMailbox(context.Context, timeutil.TimeInterval, int) (MailTrafficPerSenderOverTimeResult, error)
	DeferredMailsByMailbox(context.Context, timeutil.TimeInterval, int) (MailTrafficPerSenderOverTimeResult, error)
	ExpiredMailsByMailbox(context.Context, timeutil.TimeInterval, int) (MailTrafficPerSenderOverTimeResult, error)
	ReceivedMailsByMailbox(context.Context, timeutil.TimeInterval, int) (MailTrafficPerSenderOverTimeResult, error)
	InboundRepliesByMailbox(context.Context, timeutil.TimeInterval, int) (MailTrafficPerSenderOverTimeResult, error)
}

func New

func New(pool *dbconn.RoPool) (Dashboard, error)

type MailTrafficPerSenderOverTimeResult

type MailTrafficPerSenderOverTimeResult struct {
	Times  []int64            `json:"times"`
	Values map[string][]int64 `json:"values"`
}

type Pair

type Pair struct {
	Key   interface{} `json:"key"`
	Value interface{} `json:"value"`
}

type Pairs

type Pairs []Pair

type Queryable

type Queryable interface {
	QueryContext(ctx context.Context, args ...interface{}) (QueryableRows, error)
}

type QueryableRows

type QueryableRows interface {
	io.Closer
	ForEach(func(QueryableScanner) error) error
}

type QueryableScanner

type QueryableScanner interface {
	Scan(...interface{}) error
}