threading

type BackgroundJob interface {
	Start() <-chan error
	Stop()
	Name() string
}

type ErrorCallback[T any] func(T, error, int)

type Handler[T any] func(T) error

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

type Partitionable interface {
	PartitionKey() string
}

type RetryPolicy int32

type Task[T any] struct {
	// contains filtered or unexported fields
}

type TaskResult[T any] struct {
	Value T
	Error error
}

type WorkItem[T any] struct {
	Item    T
	Retries int
}

type WorkQueue[T any] struct {
	StopOnError        bool
	RetryPolicy        RetryPolicy
	RetryAfterDuration time.Duration
	MaxRetries         int
	ErrorCallback      ErrorCallback[T]

	// Partitioning support (optional)
	// PartitionFunc is an optional function to extract partition keys from items.
	// When set (or when items implement Partitionable), items with the same
	// partition key will be processed by the same worker in FIFO order.
	PartitionFunc func(T) string
	// contains filtered or unexported fields
}