sender

Documentation

Index

• func NewBootstrapSender(args ArgBootstrapSender) (*bootstrapSender, error)
• func NewPeerShardSender(args ArgPeerShardSender) (*peerShardSender, error)
• func NewSender(args ArgSender) (*sender, error)
• type ArgBootstrapSender
• type ArgPeerShardSender
• type ArgSender

Functions

func NewBootstrapSender

func NewBootstrapSender(args ArgBootstrapSender) (*bootstrapSender, error)

NewBootstrapSender creates a new instance of bootstrapSender

func NewPeerShardSender

func NewPeerShardSender(args ArgPeerShardSender) (*peerShardSender, error)

NewPeerShardSender creates a new instance of peerShardSender

func NewSender

func NewSender(args ArgSender) (*sender, error)

NewSender creates a new instance of sender

Types

type ArgBootstrapSender

type ArgBootstrapSender struct {
	MainMessenger                      heartbeat.P2PMessenger
	FullArchiveMessenger               heartbeat.P2PMessenger
	Marshaller                         marshal.Marshalizer
	HeartbeatTopic                     string
	HeartbeatTimeBetweenSends          time.Duration
	HeartbeatTimeBetweenSendsWhenError time.Duration
	HeartbeatTimeThresholdBetweenSends float64
	VersionNumber                      string
	NodeDisplayName                    string
	Identity                           string
	PeerSubType                        core.P2PPeerSubType
	CurrentBlockProvider               heartbeat.CurrentBlockProvider
	PrivateKey                         crypto.PrivateKey
	RedundancyHandler                  heartbeat.NodeRedundancyHandler
	PeerTypeProvider                   heartbeat.PeerTypeProviderHandler
	TrieSyncStatisticsProvider         heartbeat.TrieSyncStatisticsProvider
}

ArgBootstrapSender represents the arguments for the bootstrap bootstrapSender

type ArgPeerShardSender

type ArgPeerShardSender struct {
	MainMessenger             p2p.Messenger
	FullArchiveMessenger      p2p.Messenger
	Marshaller                marshal.Marshalizer
	ShardCoordinator          sharding.Coordinator
	TimeBetweenSends          time.Duration
	TimeThresholdBetweenSends float64
	NodesCoordinator          processor.NodesCoordinator
}

ArgPeerShardSender represents the arguments for the peer shard sender

type ArgSender

type ArgSender struct {
	MainMessenger                               heartbeat.P2PMessenger
	FullArchiveMessenger                        heartbeat.P2PMessenger
	Marshaller                                  marshal.Marshalizer
	PeerAuthenticationTopic                     string
	HeartbeatTopic                              string
	PeerAuthenticationTimeBetweenSends          time.Duration
	PeerAuthenticationTimeBetweenSendsWhenError time.Duration
	PeerAuthenticationTimeThresholdBetweenSends float64
	HeartbeatTimeBetweenSends                   time.Duration
	HeartbeatTimeBetweenSendsWhenError          time.Duration
	HeartbeatTimeThresholdBetweenSends          float64
	BaseVersionNumber                           string
	VersionNumber                               string
	NodeDisplayName                             string
	Identity                                    string
	PeerSubType                                 core.P2PPeerSubType
	CurrentBlockProvider                        heartbeat.CurrentBlockProvider
	PeerSignatureHandler                        crypto.PeerSignatureHandler
	PrivateKey                                  crypto.PrivateKey
	RedundancyHandler                           heartbeat.NodeRedundancyHandler
	NodesCoordinator                            heartbeat.NodesCoordinator
	HardforkTrigger                             heartbeat.HardforkTrigger
	HardforkTimeBetweenSends                    time.Duration
	HardforkTriggerPubKey                       []byte
	PeerTypeProvider                            heartbeat.PeerTypeProviderHandler
	ManagedPeersHolder                          heartbeat.ManagedPeersHolder
	PeerAuthenticationTimeBetweenChecks         time.Duration
	ShardCoordinator                            heartbeat.ShardCoordinator
}

ArgSender represents the arguments for the sender