queue

Documentation

Index

• type Queue
  • func New(lp *linkpearl.Linkpearl, cfg *config.Manager, log *zerolog.Logger) *Queue
  • func (q *Queue) Add(ctx context.Context, id, from, to, data string, relayOverride ...*url.URL) error
  • func (q *Queue) Process()
  • func (q *Queue) Remove(ctx context.Context, id string) error
  • func (q *Queue) SetSendmail(function func(string, string, string, *url.URL) error)

Types

type Queue

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

Queue manager

func New

func New(lp *linkpearl.Linkpearl, cfg *config.Manager, log *zerolog.Logger) *Queue

New queue

func (*Queue) Add

func (q *Queue) Add(ctx context.Context, id, from, to, data string, relayOverride ...*url.URL) error

Add to queue

func (*Queue) Process

func (q *Queue) Process()

Process queue

func (*Queue) Remove

func (q *Queue) Remove(ctx context.Context, id string) error

Remove from queue

func (*Queue) SetSendmail

func (q *Queue) SetSendmail(function func(string, string, string, *url.URL) error)

SetSendmail func