topicResolverSender

Documentation

Index

• func NewTopicResolverSender(arg ArgTopicResolverSender) (*topicResolverSender, error)
• type ArgTopicResolverSender
• type DiffPeerListCreator
  • func NewDiffPeerListCreator(messenger dataRetriever.MessageHandler, mainTopic string, ...) (*DiffPeerListCreator, error)
  • func (dplc *DiffPeerListCreator) IntraShardPeerList() []core.PeerID
  • func (dplc *DiffPeerListCreator) IsInterfaceNil() bool
  • func (dplc *DiffPeerListCreator) PeerList() []core.PeerID

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
	NumIntraShardPeers int
	NumCrossShardPeers int
}

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,
	intraShardTopic string,
	excludePeersFromTopic string,
) (*DiffPeerListCreator, error)

NewDiffPeerListCreator is the constructor for DiffPeerListCreator

func (*DiffPeerListCreator) IntraShardPeerList

func (dplc *DiffPeerListCreator) IntraShardPeerList() []core.PeerID

IntraShardPeerList returns the intra shard peer list

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() []core.PeerID

PeerList will return the generated list of peers