IgnoreFreezing is an option that can make the task queue ignore freezing and unfreezing.

MaxOutstandingWorkPerPeer is an option that specifies how many tasks a peer can have outstanding with the same Topic as an existing Topic.

New creates a new PeerTaskQueue.

OnPeerAddedHook adds a hook function that gets called whenever the ptq adds a new peer.

OnPeerRemovedHook adds a hook function that gets called whenever the ptq adds a new peer.

PeerComparator is an option that specifies custom peer prioritization logic.

TaskComparator is an option that specifies custom task prioritization logic.

TaskMerger is an option that specifies merge behaviour when pushing a task with the same Topic as an existing Topic.

PeerTaskQueue is a prioritized list of tasks to be executed on peers.

PeerTaskQueueStats captures current stats about the task queue.

Option is a function that configures the peer task queue.