queue

Documentation

Overview

Package queue provides a job queue abstraction. The default runs jobs in-process (async goroutines); a Redis/NATS-backed queue ships as a plugin.

Index

• type Handler
• type Queue
  • func NewMemory(onError func(error)) Queue

Types

type Handler

type Handler func(ctx context.Context, payload any) error

Handler processes a dispatched job payload.

type Queue

type Queue interface {
	Handle(name string, h Handler)
	Dispatch(ctx context.Context, name string, payload any) error
}

Queue dispatches named jobs to registered handlers.

func NewMemory

func NewMemory(onError func(error)) Queue

NewMemory returns an in-process queue. onError (optional) receives async errors.