peertaskqueue

Feb 17, 2023

Changes in this version

type PeerTaskQueue

+ func (ptq *PeerTaskQueue) Clear(p peer.ID)

+ func (ptq *PeerTaskQueue) PushTasksTruncated(n uint, to peer.ID, tasks ...peertask.Task)

Dec 8, 2021

Changes in this version

type PeerTaskQueue

+ func (ptq *PeerTaskQueue) PeerTopics(p peer.ID) *peertracker.PeerTrackerTopics

Oct 12, 2021

Changes in this version

type Option

+ func PeerComparator(pc peertracker.PeerComparator) Option

+ func TaskComparator(tc peertask.QueueTaskComparator) Option

Aug 18, 2021

Changes in this version

type PeerTaskQueue

+ func (ptq *PeerTaskQueue) Stats() *PeerTaskQueueStats

+ type PeerTaskQueueStats struct

+ NumActive int

+ NumPeers int

+ NumPending int

Jul 22, 2021

Changes in this version

type Option

+ func MaxOutstandingWorkPerPeer(count int) Option

Nov 11, 2019

Changes in this version

type Option

+ func TaskMerger(tmfp peertracker.TaskMerger) Option

type PeerTaskQueue

+ func (ptq *PeerTaskQueue) PopTasks(targetMinWork int) (peer.ID, []*peertask.Task, int)

+ func (ptq *PeerTaskQueue) PushTasks(to peer.ID, tasks ...peertask.Task)

+ func (ptq *PeerTaskQueue) TasksDone(to peer.ID, tasks ...*peertask.Task)

May 22, 2019

Changes in this version

+ type Option func(*PeerTaskQueue) Option

+ func IgnoreFreezing(ignoreFreezing bool) Option

+ func OnPeerAddedHook(onPeerAddedHook func(p peer.ID)) Option

+ func OnPeerRemovedHook(onPeerRemovedHook func(p peer.ID)) Option

type PeerTaskQueue

+ func (ptq *PeerTaskQueue) Options(options ...Option) Option

May 10, 2019

Changes in this version

+ type PeerTaskQueue struct

+ func New() *PeerTaskQueue

+ func (ptq *PeerTaskQueue) FullThaw()

+ func (ptq *PeerTaskQueue) PopBlock() *peertask.TaskBlock

+ func (ptq *PeerTaskQueue) PushBlock(to peer.ID, tasks ...peertask.Task)

+ func (ptq *PeerTaskQueue) Remove(identifier peertask.Identifier, p peer.ID)

+ func (ptq *PeerTaskQueue) ThawRound()