deltask

Dec 25, 2025

Changes in this version

type Worker

+ func (w *Worker) QueueName() string

Aug 12, 2025

Changes in this version

+ type Context = deltacontext.Context

type Task

+ func NewTaskWithRawPayload(name string, payloadBytes []byte, opts ...task.TaskOption) *Task

Aug 10, 2025

Changes in this version

+ var ManagerOpts managerOptionBuilder

+ var WorkerOpts workerOptionBuilder

+ func Run(ctx context.Context, workers []*Worker, opts ...ManagerOption) error

+ type Manager struct

+ func NewManager(workers []*Worker, opts ...ManagerOption) *Manager

+ func (m *Manager) Run(ctx context.Context) error

+ type ManagerOption func(*managerOptions)

+ type RetryPolicy = internal.RetryPolicy

+ type WorkerOption func(*workerOptions)

Aug 6, 2025

Changes in this version

+ type Client struct

+ func NewClient(b broker.Broker) *Client

+ func (c *Client) Publish(ctx context.Context, task *task.Task, queueName string) error

+ type Task = task.Task

+ func NewTask(name string, payload map[string]any) *Task

+ type TaskHandler = task.Handler

+ type Worker struct

+ func NewWorker(b broker.Broker, queueName string, concurrency int) *Worker

+ func NewWorkerWithLogger(b broker.Broker, queueName string, concurrency int, log *logger.Logger) *Worker

+ func (w *Worker) Register(taskName string, handler task.Handler)

+ func (w *Worker) Run(ctx context.Context) error