Documentation
¶
Index ¶
- func NewDirectConnectionProcessor(args ArgsDirectConnectionProcessor) (*directConnectionProcessor, error)
- func NewPeerAuthenticationRequestsProcessor(args ArgPeerAuthenticationRequestsProcessor) (*peerAuthenticationRequestsProcessor, error)
- type ArgPeerAuthenticationRequestsProcessor
- type ArgsDirectConnectionProcessor
- type NodesCoordinator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDirectConnectionProcessor ¶
func NewDirectConnectionProcessor(args ArgsDirectConnectionProcessor) (*directConnectionProcessor, error)
NewDirectConnectionProcessor will create a new direct connection processor instance
func NewPeerAuthenticationRequestsProcessor ¶
func NewPeerAuthenticationRequestsProcessor(args ArgPeerAuthenticationRequestsProcessor) (*peerAuthenticationRequestsProcessor, error)
NewPeerAuthenticationRequestsProcessor creates a new instance of peerAuthenticationRequestsProcessor
Types ¶
type ArgPeerAuthenticationRequestsProcessor ¶
type ArgPeerAuthenticationRequestsProcessor struct {
RequestHandler process.RequestHandler
NodesCoordinator heartbeat.NodesCoordinator
PeerAuthenticationPool storage.Cacher
ShardId uint32
Epoch uint32
MinPeersThreshold float32
DelayBetweenRequests time.Duration
MaxTimeoutForRequests time.Duration
MaxMissingKeysInRequest uint32
Randomizer dataRetriever.IntRandomizer
}
ArgPeerAuthenticationRequestsProcessor represents the arguments for the peer authentication request processor
type ArgsDirectConnectionProcessor ¶
type ArgsDirectConnectionProcessor struct {
TimeToReadDirectConnections time.Duration
Messenger heartbeat.P2PMessenger
PeerShardMapper heartbeat.PeerShardMapper
ShardCoordinator sharding.Coordinator
BaseIntraShardTopic string
BaseCrossShardTopic string
}
ArgsDirectConnectionProcessor is the argument DTO for the NewDirectConnectionProcessor constructor function
type NodesCoordinator ¶
type NodesCoordinator interface {
GetOwnPublicKey() []byte
GetValidatorWithPublicKey(publicKey []byte) (nodesCoord.Validator, uint32, error)
IsInterfaceNil() bool
}
NodesCoordinator defines the operations for a struct that is able to determine if a key is a validator or not
Source Files
Click to show internal directories.
Click to hide internal directories.