queue

Documentation

Index

• type Item
• type Queue
  • func New(db *bbolt.DB, log *logger.Logger) (*Queue, error)
  • func (q *Queue) Add(item *Item) error
  • func (q *Queue) Process()
  • func (q *Queue) SetPing(function func() bool)
  • func (q *Queue) SetSendmail(function func(*Item) error)

Types

type Item

type Item struct {
	Username string // Second command: AUTH
	Password string
	MailFrom string // Third command: MAIL
	MailOpts smtp.MailOptions
	Rcpt     []string // Fourth command: RCPT (can be called multiple times)
	Data     []byte   // Fifth command: DATA
}

Item i a snapshot of SMTP commands

type Queue

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

func New

func New(db *bbolt.DB, log *logger.Logger) (*Queue, error)

New queue

func (*Queue) Add

func (q *Queue) Add(item *Item) error

Add item to cache

func (*Queue) Process

func (q *Queue) Process()

Process the queue

func (*Queue) SetPing

func (q *Queue) SetPing(function func() bool)

SetPing function

func (*Queue) SetSendmail

func (q *Queue) SetSendmail(function func(*Item) error)

SetSendmail function