Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + func NewDirectConnectionProcessor(args ArgsDirectConnectionProcessor) (*directConnectionProcessor, error) + func NewPeerAuthenticationRequestsProcessor(args ArgPeerAuthenticationRequestsProcessor) (*peerAuthenticationRequestsProcessor, error) + type ArgPeerAuthenticationRequestsProcessor struct + DelayBetweenRequests time.Duration + Epoch uint32 + MaxMissingKeysInRequest uint32 + MaxTimeout time.Duration + MinPeersThreshold float32 + NodesCoordinator heartbeat.NodesCoordinator + PeerAuthenticationPool storage.Cacher + Randomizer dataRetriever.IntRandomizer + RequestHandler process.RequestHandler + ShardId uint32 + type ArgsDirectConnectionProcessor struct + BaseCrossShardTopic string + BaseIntraShardTopic string + Messenger heartbeat.P2PMessenger + PeerShardMapper heartbeat.PeerShardMapper + ShardCoordinator sharding.Coordinator + TimeToReadDirectConnections time.Duration + type NodesCoordinator interface + GetOwnPublicKey func() []byte + GetValidatorWithPublicKey func(publicKey []byte) (nodesCoord.Validator, uint32, error) + IsInterfaceNil func() bool