bqueue

Documentation

Index

• Constants
• type Broadcast
• type Queue
  • func New(manager *peering.Manager, reqQueue rqueue.Queue) Queue

Constants

const Size = 1000

Size defines the default size of the broadcast queue.

Types

type Broadcast

type Broadcast struct {
	// The byte encoded transaction data to broadcast.
	TxData []byte
	// The requested transaction hash.
	RequestedTxHash hornet.Hash
	// The IDs of the peers to exclude from broadcasting.
	ExcludePeers map[string]struct{}
}

Broadcast defines a transaction and requested transaction hash which should be broadcasted.

type Queue

type Queue interface {
	// EnqueueForBroadcast enqueues the given broadcast to be sent to all peers.
	EnqueueForBroadcast(b *Broadcast)
	// Run runs the broadcast queue.
	Run(shutdownSignal <-chan struct{})
}

Queue implements a queue which broadcasts its elements to all wanted peers.

func New

func New(manager *peering.Manager, reqQueue rqueue.Queue) Queue

New creates a new Queue.