topicsender

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

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