Documentation ¶
Index ¶
- func NewDiffPeerListCreator(messenger dataRetriever.MessageHandler, mainTopic string, ...) (*diffPeerListCreator, error)
- func NewTopicRequestSender(args ArgTopicRequestSender) (*topicRequestSender, error)
- func NewTopicResolverSender(arg ArgTopicResolverSender) (*topicResolverSender, error)
- type ArgBaseTopicSender
- type ArgTopicRequestSender
- type ArgTopicResolverSender
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDiffPeerListCreator ¶
func NewDiffPeerListCreator( messenger dataRetriever.MessageHandler, mainTopic string, intraShardTopic string, excludePeersFromTopic string, ) (*diffPeerListCreator, error)
NewDiffPeerListCreator is the constructor for diffPeerListCreator
func NewTopicRequestSender ¶
func NewTopicRequestSender(args ArgTopicRequestSender) (*topicRequestSender, error)
NewTopicRequestSender returns a new topic request sender instance
func NewTopicResolverSender ¶
func NewTopicResolverSender(arg ArgTopicResolverSender) (*topicResolverSender, error)
NewTopicResolverSender returns a new topic resolver instance
Types ¶
type ArgBaseTopicSender ¶
type ArgBaseTopicSender struct { MainMessenger p2p.Messenger FullArchiveMessenger p2p.Messenger TopicName string OutputAntiflooder dataRetriever.P2PAntifloodHandler MainPreferredPeersHolder dataRetriever.PreferredPeersHolderHandler FullArchivePreferredPeersHolder dataRetriever.PreferredPeersHolderHandler TargetShardId uint32 }
ArgBaseTopicSender is the base DTO used to create a new topic sender instance
type ArgTopicRequestSender ¶
type ArgTopicRequestSender struct { ArgBaseTopicSender Marshaller marshal.Marshalizer Randomizer dataRetriever.IntRandomizer PeerListCreator dataRetriever.PeerListCreator NumIntraShardPeers int NumCrossShardPeers int NumFullHistoryPeers int CurrentNetworkEpochProvider dataRetriever.CurrentNetworkEpochProviderHandler SelfShardIdProvider dataRetriever.SelfShardIDProvider PeersRatingHandler dataRetriever.PeersRatingHandler }
ArgTopicRequestSender is the argument structure used to create new topic request sender instance
type ArgTopicResolverSender ¶
type ArgTopicResolverSender struct {
ArgBaseTopicSender
}
ArgTopicResolverSender is the argument structure used to create new TopicResolverSender instance
Click to show internal directories.
Click to hide internal directories.