queue

Documentation

Overview

Package queue abstracts the various external (or internal) message queues we are using for notifications

Index

• Variables
• func NewDBQueue(r *repo.MySQL) *dbQueue
• type Queue
  • func New(r *repo.MySQL) (Queue, error)

Variables

var (
	// ErrTimeout is returned if receive encounters a timeout
	ErrTimeout = errors.New("timeout occurred")
	// ErrClosed is returned if you try to access a closed queue
	ErrClosed = errors.New("queue is already closed")
)

Functions

func NewDBQueue

func NewDBQueue(r *repo.MySQL) *dbQueue

Types

type Queue

type Queue interface {
	PushConf(team string) error
	PopConf(timeout time.Duration) (string, error)
	PushWork(work *domain.WorkRequest) error
	PopWork(timeout time.Duration) (*domain.WorkRequest, error)
	PushWorkReply(replyQueue string, reply *domain.WorkReply) error
	PopWorkReply(replyQueue string, timeout time.Duration) (*domain.WorkReply, error)
	Close() error
}

Queue abstracts the external / internal queues

func New

func New(r *repo.MySQL) (Queue, error)

New queue is returned depending on environment