bolt

Documentation

Index

• func NewBoltDAO(db boltdb.DB) mailer2.Queue
• type BoltQueue
  • func (b *BoltQueue) Close(ctx context.Context) error
  • func (b *BoltQueue) Consume(ctx context.Context, sendHandler func(email *mailer.Mail) error) error
  • func (b *BoltQueue) Init(ctx context.Context) error
  • func (b *BoltQueue) Push(ctx context.Context, email *mailer.Mail) error

Functions

func NewBoltDAO

func NewBoltDAO(db boltdb.DB) mailer2.Queue

Types

type BoltQueue

type BoltQueue struct {
	boltdb.DB
}

BoltQueue defines a queue for the mails backed by a Bolt DB.

func (*BoltQueue) Close

func (b *BoltQueue) Close(ctx context.Context) error

Close closes the DB and delete corresponding file if deleteOnClose flag as been set on creation.

func (*BoltQueue) Consume

func (b *BoltQueue) Consume(ctx context.Context, sendHandler func(email *mailer.Mail) error) error

Consume acquires the lock and send mails that are in the queue by batches, sending at most 100 mails by batch.

func (*BoltQueue) Init

func (b *BoltQueue) Init(ctx context.Context) error

func (*BoltQueue) Push

func (b *BoltQueue) Push(ctx context.Context, email *mailer.Mail) error

Push acquires the lock and add a mail to be sent in the queue.