queue

package

v0.35.5 Latest Latest Go to latest Published: Oct 28, 2025 License: AGPL-3.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewTask[T any](ctx context.Context, id string, data T) *Task[T]

func (t *Task[T]) Cancel()

func (t *Task[T]) Context() context.Context

func (t *Task[T]) IsCancelled() bool

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

func NewTaskQueue[T any]() *TaskQueue[T]

func (tq *TaskQueue[T]) ActiveLength() int

func (tq *TaskQueue[T]) Add(task *Task[T]) error

func (tq *TaskQueue[T]) CancelAll()

func (tq *TaskQueue[T]) CancelTask(taskID string) error

func (tq *TaskQueue[T]) CleanupCancelled() int

func (tq *TaskQueue[T]) Clear()

func (tq *TaskQueue[T]) Close()

func (tq *TaskQueue[T]) Done(taskID string)

func (tq *TaskQueue[T]) Get() (*Task[T], error)

func (tq *TaskQueue[T]) GetTask(taskID string) (*Task[T], error)

func (tq *TaskQueue[T]) IsClosed() bool

func (tq *TaskQueue[T]) Length() int

func (tq *TaskQueue[T]) Peek() (*Task[T], error)

func (tq *TaskQueue[T]) RemoveTask(taskID string) error