Versions in this module Expand all Collapse all v0 v0.16.2 Dec 14, 2023 v0.16.1 Dec 14, 2023 Changes in this version + type Executor interface + ExecuteTask func(ctx context.Context, pid peer.ID, task *peertask.Task) bool + type TaskQueue interface + PushTask func(p peer.ID, task peertask.Task) + Remove func(t peertask.Topic, p peer.ID) + Stats func() graphsync.RequestStats + TaskDone func(p peer.ID, task *peertask.Task) + WithPeerTopics func(p peer.ID, f func(*peertracker.PeerTrackerTopics)) + type WorkerTaskQueue struct + func NewTaskQueue(ctx context.Context, ptqopts ...peertaskqueue.Option) *WorkerTaskQueue + func (tq *WorkerTaskQueue) PushTask(p peer.ID, task peertask.Task) + func (tq *WorkerTaskQueue) Shutdown() + func (tq *WorkerTaskQueue) Startup(workerCount uint64, executor Executor) + func (tq *WorkerTaskQueue) Stats() graphsync.RequestStats + func (tq *WorkerTaskQueue) TaskDone(p peer.ID, task *peertask.Task) + func (tq *WorkerTaskQueue) WaitForNoActiveTasks() + func (tq *WorkerTaskQueue) WithPeerTopics(p peer.ID, withPeerTopics func(*peertracker.PeerTrackerTopics))
Go to main page