sender

Documentation

Index

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

Functions

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 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