taskqueue

package

v0.10.2 Latest Latest Go to latest Published: Oct 7, 2021 License: Apache-2.0, MIT Imports: 5 Imported by: 3

Details

This section is empty.

This section is empty.

This section is empty.

type Executor interface {
	ExecuteTask(ctx context.Context, pid peer.ID, task *peertask.Task) bool
}

Executor runs a single task on the queue

type TaskQueue interface {
	PushTask(p peer.ID, task peertask.Task)
	TaskDone(p peer.ID, task *peertask.Task)
}

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

TaskQueue is a wrapper around peertaskqueue.PeerTaskQueue that manages running workers that pop tasks and execute them

func NewTaskQueue(ctx context.Context) *WorkerTaskQueue

NewTaskQueue initializes a new queue

func (tq *WorkerTaskQueue) PushTask(p peer.ID, task peertask.Task)

PushTask pushes a new task on to the queue

func (tq *WorkerTaskQueue) Shutdown()

Shutdown shuts down all running workers

func (tq *WorkerTaskQueue) Startup(workerCount uint64, executor Executor)

Startup runs the given number of task workers with the given executor

func (tq *WorkerTaskQueue) TaskDone(p peer.ID, task *peertask.Task)

TaskDone marks a task as completed so further tasks can be executed