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
Source Files
Click to show internal directories.
Click to hide internal directories.