leasequeue

package

v1.0.0 Latest Latest Go to latest Published: Aug 26, 2026 License: MIT Imports: 5 Imported by: 0

Details

Package leasequeue integrates fenced leases with queue workers.

This section is empty.

This section is empty.

func TokenFromContext(ctx context.Context) (lease.Token, bool)

TokenFromContext returns the fencing token for protected-resource writes.

type KeyFunc func(core.TaskMessage) (lease.Key, error)

KeyFunc derives a bounded lease key from a delivered queue message.

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

Worker adds unique-job and non-overlap admission to a queue worker.

func NewWorker(
	inner core.Worker,
	client *lease.Client,
	policy lease.Policy,
	key KeyFunc,
) (*Worker, error)

NewWorker wraps a caller-owned worker with fenced lease admission.

func (worker *Worker) Queue(task core.TaskMessage) error

Queue delegates to the caller-owned worker.

func (worker *Worker) Request() (core.TaskMessage, error)

Request delegates to the caller-owned worker.

func (worker *Worker) Run(ctx context.Context, task core.TaskMessage) error

Run acquires the message lease and exposes its fence through context.

func (worker *Worker) Shutdown() error

Shutdown delegates to the caller-owned worker.