topicsender

package
v1.6.12 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 15, 2024 License: GPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL