processor

Documentation

Index

• func NewDirectConnectionProcessor(args ArgsDirectConnectionProcessor) (*directConnectionProcessor, error)
• func NewPeerAuthenticationRequestsProcessor(args ArgPeerAuthenticationRequestsProcessor) (*peerAuthenticationRequestsProcessor, error)
• type ArgPeerAuthenticationRequestsProcessor
• type ArgsDirectConnectionProcessor
• type NodesCoordinator

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