middleware

Documentation

Index

• func Notifier(inspector *asynq.Inspector, cfg config.Configuration) func(asynq.Handler) asynq.Handler
• type DataNotification

Functions

func Notifier

func Notifier(inspector *asynq.Inspector, cfg config.Configuration) func(asynq.Handler) asynq.Handler

Notifier is a asynq middleware to handle cancelled jobs and sending out email notification.

Types

type DataNotification

type DataNotification struct {
	ID           string
	State        nmode
	StagerUser   string
	DrUser       string
	SrcURL       string
	DstURL       string
	CreatedAt    time.Time
	CompletedAt  time.Time
	LastFailedAt time.Time
	LastErr      string
	Result       tasks.StagerTaskResult
}