worker

type BatchClient interface {
	Client
	BatchAckDeliveries(context.Context, blockqueue.Topic, string, []blockqueue.BatchAckItem) []blockqueue.DeliveryResult
	BatchNackDeliveries(context.Context, blockqueue.Topic, string, []blockqueue.BatchNackItem) []blockqueue.DeliveryResult
}

type Client interface {
	ClaimWait(context.Context, blockqueue.Topic, string, int, time.Duration) (blockqueue.Deliveries, error)
	AckDelivery(context.Context, blockqueue.Topic, string, string, string) error
	NackDelivery(context.Context, blockqueue.Topic, string, string, string, time.Duration, string) error
	ExtendLease(context.Context, blockqueue.Topic, string, string, string, time.Duration) (time.Time, error)
	CancelClaimedDelivery(context.Context, blockqueue.Topic, string, string, string, string) error
}

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

type Handler interface {
	Handle(context.Context, *Job) error
}

type HandlerFunc func(context.Context, *Job) error

type Job struct {
	blockqueue.Delivery
	// contains filtered or unexported fields
}

type Options struct {
	// Concurrency is the maximum number of active handlers. Default: 1.
	Concurrency int
	// BatchSize caps one claim and is always limited by free concurrency slots.
	// Default: Concurrency.
	BatchSize int
	// LeaseDuration is renewed while a handler is active. Default: 1m.
	LeaseDuration time.Duration
	// HeartbeatInterval is deterministically jittered to avoid a batch
	// stampede. Default: one third of LeaseDuration.
	HeartbeatInterval time.Duration
	// DisableHeartbeat is intended for short tests and specialized consumers.
	DisableHeartbeat bool
	// OperationTimeout bounds automatic ACK/NACK and heartbeat calls.
	// Default: 10s.
	OperationTimeout time.Duration
	// DrainTimeout bounds graceful handler drain after Run context cancellation.
	// Default: 30s.
	DrainTimeout time.Duration
	// HardStopTimeout is a second, bounded wait after DrainTimeout cancels
	// handler contexts. Default: 1s.
	HardStopTimeout time.Duration
	// PausePollInterval controls how often an intentionally paused resource is
	// checked for resume. Pause is logged once, not on every poll. Default: 5s.
	PausePollInterval time.Duration
	// CompletionBatchSize caps set-based ACK/NACK transactions when the client
	// implements BatchClient. Default: 100; also capped by Concurrency.
	CompletionBatchSize int
	// CompletionFlushInterval bounds completion batching latency. Default: 1ms.
	CompletionFlushInterval time.Duration
	// Logger receives operational retry, panic, and completion failures.
	// Default: slog.Default().
	Logger *slog.Logger
	// DisableMetrics makes every worker collector a no-op.
	DisableMetrics bool
	// MetricRegisterer receives worker collectors. Default: Prometheus global
	// registerer.
	MetricRegisterer prometheus.Registerer
}

type TransactionalClient interface {
	Client
	WithTx(context.Context, *sql.TxOptions, func(*sql.Tx) error) error
	AckDeliveryTx(context.Context, *sql.Tx, blockqueue.Topic, string, string, string) error
	CancelClaimedDeliveryTx(context.Context, *sql.Tx, blockqueue.Topic, string, string, string, string) error
}

type TypedHandler[T any] interface {
	Handle(context.Context, *TypedJob[T]) error
}

type TypedHandlerFunc[T any] func(context.Context, *TypedJob[T]) error

type TypedJob[T any] struct {
	*Job
	Args T
}

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