gossip

type Manager interface {
	// GossipReceived is to be called each time a peer sends a Gossip message.
	// All hashes should be removed from the peer's queue and added to the log.
	GossipReceived(id transport.PeerID, refs ...hash.SHA256Hash)
	// PeerConnected is to be called when a new peer connects. A new gossip queue will then be created for this peer.
	PeerConnected(peer transport.Peer)
	// PeerDisconnected is to be called when a peer disconnects. The gossip queue can then be cleared.
	PeerDisconnected(peer transport.Peer)
	// RegisterSender registers a sender function. The manager will call this function at set intervals to send a gossip message.
	// Senders should not be added after configuration.
	RegisterSender(SenderFunc)
	// TransactionRegistered is to be called when a new transaction is added to the DAG.
	TransactionRegistered(transaction hash.SHA256Hash)
}

type MockManager struct {
	// contains filtered or unexported fields
}

type MockManagerMockRecorder struct {
	// contains filtered or unexported fields
}

type SenderFunc func(id transport.PeerID, refs []hash.SHA256Hash) bool