bqueue

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{}
}

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{})
}