qui

type CreateTaskParams[T any] struct {
	Payload  T
	Priority int
}

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

type GenericTask[T any] struct {
	ID      string
	Status  TaskStatus
	Payload T
}

type NewGenericQueueParams struct {
	Name   string
	Broker TaskBroker
}

type Task struct {
	ID      string
	Status  TaskStatus
	Payload []byte
}

type TaskBroker interface {
	GetTask(ctx context.Context, queueName string) (Task, error)
	CreateTask(ctx context.Context, queueName string, task Task) (Task, error)
	CompleteTask(ctx context.Context, queueName string, id string) error
	FailTask(ctx context.Context, queueName string, id string) error
}

type TaskStatus string