taskqueue

type TaskItem[T any] struct {
	// TaskID is the generated ID of the task item
	TaskID string

	// ID is the provided id
	ID string

	// Optional data stored with a task, needs to be serializable
	Data T
}

type TaskQueue[T any] interface {
	Enqueue(ctx context.Context, id string, data *T) (*string, error)
	Dequeue(ctx context.Context, lockTimeout, timeout time.Duration) (*TaskItem[T], error)
	Extend(ctx context.Context, taskID string) error
	Complete(ctx context.Context, taskID string) error
	Data(ctx context.Context, taskID string) (*TaskItem[T], error)
}