Versions in this module Expand all Collapse all v0 v0.0.2 Oct 31, 2023 Changes in this version + var ErrNilPeerSignatureHandler = errors.New("trying to set nil peerSignatureHandler") v0.0.1 Oct 30, 2023 Changes in this version + var ErrFetchGenesisTimeFromDb = errors.New("monitor: can't get genesis time from db") + var ErrHeartbeatPidMismatch = errors.New("heartbeat peer id mismatch") + var ErrInvalidDurationToConsiderUnresponsiveInSec = errors.New("value DurationToConsiderUnresponsiveInSec is less than 1") + var ErrInvalidMaxDurationPeerUnresponsive = errors.New("invalid max duration to declare the peer unresponsive") + var ErrMarshalGenesisTime = errors.New("monitor: can't marshal genesis time") + var ErrNegativeMaxTimeToWaitBetweenBroadcastsInSec = errors.New("value MaxTimeToWaitBetweenBroadcastsInSec is less than 1") + var ErrNegativeMinTimeToWaitBetweenBroadcastsInSec = errors.New("value MinTimeToWaitBetweenBroadcastsInSec is less than 1") + var ErrNilAntifloodHandler = errors.New("nil antiflood handler") + var ErrNilAppStatusHandler = errors.New("nil AppStatusHandler") + var ErrNilDataToProcess = errors.New("nil data to process") + var ErrNilHardforkTrigger = errors.New("nil hardfork trigger") + var ErrNilHeartbeatStorer = errors.New("nil heartbeat storer") + var ErrNilKeyGenerator = errors.New("key generator is nil") + var ErrNilMarshalizer = errors.New("nil marshalizer") + var ErrNilMessage = errors.New("nil message") + var ErrNilMessageHandler = errors.New("nil message handler") + var ErrNilMessenger = errors.New("nil P2P Messenger") + var ErrNilMonitorDb = errors.New("nil monitor db") + var ErrNilNetworkShardingCollector = errors.New("nil network sharding collector") + var ErrNilPeerTypeProvider = errors.New("nil peer type provider") + var ErrNilPrivateKey = errors.New("nil private key") + var ErrNilPubkeyConverter = errors.New("trying to use a nil pubkey converter") + var ErrNilPublicKeysMap = errors.New("nil public keys map") + var ErrNilShardCoordinator = errors.New("nil shard coordinator") + var ErrNilSingleSigner = errors.New("nil single signer") + var ErrNilTimer = errors.New("nil time getter handler") + var ErrPropertyTooLong = errors.New("property too long in Heartbeat") + var ErrStoreGenesisTimeToDb = errors.New("monitor: can't store genesis time") + var ErrUnmarshalGenesisTime = errors.New("monitor: can't unmarshal genesis time") + var ErrValidatorAlreadySet = errors.New("topic validator has already been set") + var ErrWrongValues = errors.New("wrong values for heartbeat parameters") + var ErrZeroHeartbeatRefreshIntervalInSec = errors.New("zero heartbeatRefreshInterval") + var ErrZeroHideInactiveValidatorIntervalInSec = errors.New("zero hideInactiveValidatorIntervalInSec") + type EligibleListProvider interface + GetAllEligibleValidatorsPublicKeys func(epoch uint32) (map[uint32][][]byte, error) + GetAllWaitingValidatorsPublicKeys func(epoch uint32) (map[uint32][][]byte, error) + IsInterfaceNil func() bool + type HardforkTrigger interface + CreateData func() []byte + IsInterfaceNil func() bool + NotifyTriggerReceived func() <-chan struct{} + RecordedTriggerMessage func() ([]byte, bool) + TriggerReceived func(payload []byte, data []byte, pkBytes []byte) (bool, error) + type HeartbeatStorageHandler interface + IsInterfaceNil func() bool + LoadGenesisTime func() (time.Time, error) + LoadHeartBeatDTO func(pubKey string) (*data.HeartbeatDTO, error) + LoadKeys func() ([][]byte, error) + SaveKeys func(peersSlice [][]byte) error + SavePubkeyData func(pubkey []byte, heartbeat *data.HeartbeatDTO) error + UpdateGenesisTime func(genesisTime time.Time) error + type MessageHandler interface + CreateHeartbeatFromP2PMessage func(message p2p.MessageP2P) (*data.Heartbeat, error) + IsInterfaceNil func() bool + type NetworkShardingCollector interface + IsInterfaceNil func() bool + UpdatePeerIdPublicKey func(pid core.PeerID, pk []byte) + UpdatePeerIdShardId func(pid core.PeerID, shardId uint32) + UpdatePublicKeyShardId func(pk []byte, shardId uint32) + type P2PAntifloodHandler interface + BlacklistPeer func(peer core.PeerID, reason string, duration time.Duration) + CanProcessMessage func(message p2p.MessageP2P, fromConnectedPeer core.PeerID) error + CanProcessMessagesOnTopic func(peer core.PeerID, topic string, numMessages uint32, totalSize uint64, ...) error + IsInterfaceNil func() bool + type P2PMessenger interface + Bootstrap func() error + Broadcast func(topic string, buff []byte) + BroadcastOnChannel func(channel string, topic string, buff []byte) + BroadcastOnChannelBlocking func(channel string, topic string, buff []byte) error + CreateTopic func(name string, createChannelForTopic bool) error + HasTopic func(name string) bool + HasTopicValidator func(name string) bool + ID func() core.PeerID + IsConnectedToTheNetwork func() bool + IsInterfaceNil func() bool + PeerAddresses func(pid core.PeerID) []string + RegisterMessageProcessor func(topic string, handler p2p.MessageProcessor) error + type PeerBlackListHandler interface + Add func(pid core.PeerID) error + Has func(pid core.PeerID) bool + IsInterfaceNil func() bool + Sweep func() + type PeerTypeProviderHandler interface + ComputeForPubKey func(pubKey []byte) (core.PeerType, uint32, error) + GetAllPeerTypeInfos func() []*state.PeerTypeInfo + IsInterfaceNil func() bool + type Timer interface + IsInterfaceNil func() bool + Now func() time.Time + type ValidatorStatisticsProcessor interface + GetValidatorInfoForRootHash func(rootHash []byte) (map[uint32][]*state.ValidatorInfo, error) + IsInterfaceNil func() bool + RootHash func() ([]byte, error)