rabbitmq

Documentation

Index

• type TaskQueueImpl
  • func New(fs ...TaskQueueImplOpt) (func() error, *TaskQueueImpl)
  • func (t *TaskQueueImpl) AddTask(ctx context.Context, q taskqueue.Queue, task *taskqueue.Task) error
  • func (t *TaskQueueImpl) IsReady() bool
  • func (t *TaskQueueImpl) RegisterTenant(ctx context.Context, tenantId string) error
  • func (t *TaskQueueImpl) Subscribe(q taskqueue.Queue) (func() error, <-chan *taskqueue.Task, error)
• type TaskQueueImplOpt
  • func WithLogger(l *zerolog.Logger) TaskQueueImplOpt
  • func WithURL(url string) TaskQueueImplOpt
• type TaskQueueImplOpts

Types

type TaskQueueImpl

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

TaskQueueImpl implements TaskQueue interface using AMQP.

func New

func New(fs ...TaskQueueImplOpt) (func() error, *TaskQueueImpl)

New creates a new TaskQueueImpl.

func (*TaskQueueImpl) AddTask

func (t *TaskQueueImpl) AddTask(ctx context.Context, q taskqueue.Queue, task *taskqueue.Task) error

AddTask adds a task to the queue.

func (*TaskQueueImpl) IsReady

func (t *TaskQueueImpl) IsReady() bool

func (*TaskQueueImpl) RegisterTenant

func (t *TaskQueueImpl) RegisterTenant(ctx context.Context, tenantId string) error

func (*TaskQueueImpl) Subscribe

func (t *TaskQueueImpl) Subscribe(q taskqueue.Queue) (func() error, <-chan *taskqueue.Task, error)

Subscribe subscribes to the task queue.

type TaskQueueImplOpt

type TaskQueueImplOpt func(*TaskQueueImplOpts)

func WithLogger

func WithLogger(l *zerolog.Logger) TaskQueueImplOpt

func WithURL

func WithURL(url string) TaskQueueImplOpt

type TaskQueueImplOpts

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