queue

Documentation

Index

• type AsynqQueue
  • func NewAsynqQueue(cfg *config.QueueConfig) (*AsynqQueue, error)
  • func (q *AsynqQueue) Enqueue(ctx context.Context, taskName string, payload []byte, opts ...asynq.Option) (*asynq.TaskInfo, error)
  • func (q *AsynqQueue) RegisterHandler(pattern string, handler asynq.Handler)
  • func (q *AsynqQueue) Shutdown()
  • func (q *AsynqQueue) Start() error
• type QueueService
  • func NewQueueService(cfg *config.QueueConfig, logger *slog.Logger) (QueueService, error)

Types

type AsynqQueue

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

AsynqQueue implements QueueService using hibiken/asynq (Redis-based).

func NewAsynqQueue

func NewAsynqQueue(cfg *config.QueueConfig) (*AsynqQueue, error)

NewAsynqQueue constructs an asynq-backed queue from the given config.

func (*AsynqQueue) Enqueue

func (q *AsynqQueue) Enqueue(ctx context.Context, taskName string, payload []byte, opts ...asynq.Option) (*asynq.TaskInfo, error)

Enqueue pushes a task onto the queue.

func (*AsynqQueue) RegisterHandler

func (q *AsynqQueue) RegisterHandler(pattern string, handler asynq.Handler)

RegisterHandler registers a task handler under the given pattern.

func (*AsynqQueue) Shutdown

func (q *AsynqQueue) Shutdown()

Shutdown gracefully stops the server and closes the client.

func (*AsynqQueue) Start

func (q *AsynqQueue) Start() error

Start begins processing tasks. Blocks until Shutdown is called.

type QueueService

type QueueService interface {
	Enqueue(ctx context.Context, taskName string, payload []byte, opts ...asynq.Option) (*asynq.TaskInfo, error)
	RegisterHandler(pattern string, handler asynq.Handler)
	Start() error
	Shutdown()
}

QueueService is the interface for async task processing.

func NewQueueService

func NewQueueService(cfg *config.QueueConfig, logger *slog.Logger) (QueueService, error)

NewQueueService creates the task queue from config. Returns nil if disabled.