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 {
	Messenger                          heartbeat.P2PMessenger
	Marshaller                         marshal.Marshalizer
	HeartbeatTopic                     string
	HeartbeatTimeBetweenSends          time.Duration
	HeartbeatTimeBetweenSendsWhenError time.Duration
	HeartbeatThresholdBetweenSends     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 {
	Messenger             p2p.Messenger
	Marshaller            marshal.Marshalizer
	ShardCoordinator      sharding.Coordinator
	TimeBetweenSends      time.Duration
	ThresholdBetweenSends float64
	NodesCoordinator      processor.NodesCoordinator
}

ArgPeerShardSender represents the arguments for the peer shard sender

type ArgSender

type ArgSender struct {
	Messenger                                   heartbeat.P2PMessenger
	Marshaller                                  marshal.Marshalizer
	PeerAuthenticationTopic                     string
	HeartbeatTopic                              string
	PeerAuthenticationTimeBetweenSends          time.Duration
	PeerAuthenticationTimeBetweenSendsWhenError time.Duration
	PeerAuthenticationThresholdBetweenSends     float64
	HeartbeatTimeBetweenSends                   time.Duration
	HeartbeatTimeBetweenSendsWhenError          time.Duration
	HeartbeatThresholdBetweenSends              float64
	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
}

ArgSender represents the arguments for the sender