Documentation ¶
Index ¶
Constants ¶
View Source
const NumPeersToQuery = 2
NumPeersToQuery number of peers to send the message
Variables ¶
This section is empty.
Functions ¶
func NewTopicResolverSender ¶
func NewTopicResolverSender(arg ArgTopicResolverSender) (*topicResolverSender, error)
NewTopicResolverSender returns a new topic resolver instance
Types ¶
type ArgTopicResolverSender ¶
type ArgTopicResolverSender struct { Messenger dataRetriever.MessageHandler TopicName string PeerListCreator dataRetriever.PeerListCreator Marshalizer marshal.Marshalizer Randomizer dataRetriever.IntRandomizer TargetShardId uint32 OutputAntiflooder dataRetriever.P2PAntifloodHandler }
ArgTopicResolverSender is the argument structure used to create new TopicResolverSender instance
type DiffPeerListCreator ¶
type DiffPeerListCreator struct {
// contains filtered or unexported fields
}
DiffPeerListCreator can create a peer list by making the set difference between peers on main topic and the exclusion topic. If the resulting list is empty, will return the peers on the main topic.
func NewDiffPeerListCreator ¶
func NewDiffPeerListCreator( messenger dataRetriever.MessageHandler, mainTopic string, excludePeersFromTopic string, ) (*DiffPeerListCreator, error)
NewDiffPeerListCreator is the constructor for DiffPeerListCreator
func (*DiffPeerListCreator) IsInterfaceNil ¶
func (dplc *DiffPeerListCreator) IsInterfaceNil() bool
IsInterfaceNil returns true if there is no value under the interface
func (*DiffPeerListCreator) PeerList ¶
func (dplc *DiffPeerListCreator) PeerList() []p2p.PeerID
PeerList will return the generated list of peers
Click to show internal directories.
Click to hide internal directories.