memory

package

v0.9.0 Latest Latest Go to latest Published: Jul 28, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewTaskRunner(parallelism int, cleanupDelay time.Duration, cleanupInterval time.Duration) *TaskRunner

func NewTaskRunnerWithQueue(parallelism int, queueSize int, errOnFull bool, cleanupDelay time.Duration, cleanupInterval time.Duration) *TaskRunner

func (r *TaskRunner) CancelTask(ctx context.Context, id task.ID) error

CancelTask implements task.Runner.

func (r *TaskRunner) GetTask(ctx context.Context, id task.ID) (task.Task, error)

GetTask implements task.Runner.

func (r *TaskRunner) GetTaskState(ctx context.Context, id task.ID) (*task.State, error)

GetTaskState implements task.Runner.

func (r *TaskRunner) ListTasks(ctx context.Context) ([]task.StateHeader, error)

ListTasks implements task.Runner.

func (r *TaskRunner) RegisterTask(taskType task.Type, handler task.Handler)

RegisterTask implements task.Runner.

func (r *TaskRunner) Run(ctx context.Context) error

Run implements task.Runner.

func (r *TaskRunner) ScheduleTask(ctx context.Context, tsk task.Task) error

ScheduleTask implements task.Runner.