Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + var ErrEmptySendTopic = errors.New("empty topic for sending messages") + var ErrFetchGenesisTimeFromDb = errors.New("monitor: can't get genesis time from db") + var ErrHeartbeatPidMismatch = errors.New("heartbeat peer id mismatch") + var ErrIntOverflowHeartbeat = fmt.Errorf("proto: integer overflow") + var ErrInvalidDurationToConsiderUnresponsiveInSec = errors.New("value DurationToConsiderUnresponsiveInSec is less than 1") + var ErrInvalidLengthHeartbeat = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidMaxDurationPeerUnresponsive = errors.New("invalid max duration to declare the peer unresponsive") + var ErrInvalidThreshold = errors.New("invalid threshold") + var ErrInvalidTimeDuration = errors.New("invalid time duration") + var ErrInvalidValue = errors.New("invalid value") + 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 ErrNilCacher = errors.New("nil cacher") + var ErrNilCurrentBlockProvider = errors.New("nil current block provider") + var ErrNilDataToProcess = errors.New("nil data to process") + var ErrNilEpochNotifier = errors.New("nil epoch notifier") + var ErrNilHardforkTrigger = errors.New("nil hardfork trigger") + var ErrNilHeartbeatMonitor = errors.New("nil heartbeat monitor") + var ErrNilHeartbeatSenderInfoProvider = errors.New("nil heartbeat sender info provider") + var ErrNilHeartbeatStorer = errors.New("nil heartbeat storer") + var ErrNilMarshaller = errors.New("nil marshaller") + 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 ErrNilNodesCoordinator = errors.New("nil nodes coordinator") + var ErrNilPeerAuthenticationPool = errors.New("nil peer authentication pool") + var ErrNilPeerShardMapper = errors.New("nil peer shard mapper") + var ErrNilPeerSignatureHandler = errors.New("trying to set nil peerSignatureHandler") + 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 ErrNilRandomizer = errors.New("nil randomizer") + var ErrNilRedundancyHandler = errors.New("nil redundancy handler") + var ErrNilRequestHandler = errors.New("nil request handler") + var ErrNilShardCoordinator = errors.New("nil shard coordinator") + var ErrNilTimer = errors.New("nil time getter handler") + var ErrPropertyTooLong = errors.New("property too long in Heartbeat") + var ErrShouldSkipValidator = errors.New("validator should be skipped") + var ErrStoreGenesisTimeToDb = errors.New("monitor: can't store genesis time") + var ErrUnexpectedEndOfGroupHeartbeat = fmt.Errorf("proto: unexpected end of group") + var ErrUnmarshalGenesisTime = errors.New("monitor: can't unmarshal genesis time") + var ErrWrongValues = errors.New("wrong values for heartbeat parameters") + var ErrZeroHeartbeatRefreshIntervalInSec = errors.New("zero heartbeatRefreshInterval") + var ErrZeroHideInactiveValidatorIntervalInSec = errors.New("zero hideInactiveValidatorIntervalInSec") + type CurrentBlockProvider interface + GetCurrentBlockHeader func() data.HeaderHandler + IsInterfaceNil func() bool + 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{} + NotifyTriggerReceivedV2 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) (*heartbeatData.HeartbeatDTO, error) + LoadKeys func() ([][]byte, error) + SaveKeys func(peersSlice [][]byte) error + SavePubkeyData func(pubkey []byte, heartbeat *heartbeatData.HeartbeatDTO) error + UpdateGenesisTime func(genesisTime time.Time) error + type HeartbeatV2 struct + Identity string + NodeDisplayName string + Nonce uint64 + Payload []byte + PeerSubType uint32 + Pubkey []byte + VersionNumber string + func (*HeartbeatV2) Descriptor() ([]byte, []int) + func (*HeartbeatV2) ProtoMessage() + func (m *HeartbeatV2) GetIdentity() string + func (m *HeartbeatV2) GetNodeDisplayName() string + func (m *HeartbeatV2) GetNonce() uint64 + func (m *HeartbeatV2) GetPayload() []byte + func (m *HeartbeatV2) GetPeerSubType() uint32 + func (m *HeartbeatV2) GetPubkey() []byte + func (m *HeartbeatV2) GetVersionNumber() string + func (m *HeartbeatV2) Marshal() (dAtA []byte, err error) + func (m *HeartbeatV2) MarshalTo(dAtA []byte) (int, error) + func (m *HeartbeatV2) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *HeartbeatV2) Reset() + func (m *HeartbeatV2) Size() (n int) + func (m *HeartbeatV2) Unmarshal(dAtA []byte) error + func (m *HeartbeatV2) XXX_DiscardUnknown() + func (m *HeartbeatV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HeartbeatV2) XXX_Merge(src proto.Message) + func (m *HeartbeatV2) XXX_Size() int + func (m *HeartbeatV2) XXX_Unmarshal(b []byte) error + func (this *HeartbeatV2) Equal(that interface{}) bool + func (this *HeartbeatV2) GoString() string + func (this *HeartbeatV2) String() string + type MessageHandler interface + CreateHeartbeatFromP2PMessage func(message p2p.MessageP2P) (*heartbeatData.Heartbeat, error) + IsInterfaceNil func() bool + type NetworkShardingCollector interface + IsInterfaceNil func() bool + PutPeerIdSubType func(pid core.PeerID, peerSubType core.P2PPeerSubType) + UpdatePeerIDInfo func(pid core.PeerID, pk []byte, shardID uint32) + type NodeRedundancyHandler interface + IsInterfaceNil func() bool + IsMainMachineActive func() bool + IsRedundancyNode func() bool + ObserverPrivateKey func() crypto.PrivateKey + type NodesCoordinator interface + GetAllEligibleValidatorsPublicKeys func(epoch uint32) (map[uint32][][]byte, error) + GetAllWaitingValidatorsPublicKeys func(epoch uint32) (map[uint32][][]byte, error) + GetValidatorWithPublicKey func(publicKey []byte) (validator nodesCoordinator.Validator, shardId uint32, err error) + IsInterfaceNil func() bool + 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 + Broadcast func(topic string, buff []byte) + ConnectedPeersOnTopic func(topic string) []core.PeerID + ID func() core.PeerID + IsInterfaceNil func() bool + Sign func(payload []byte) ([]byte, error) + type Payload struct + HardforkMessage string + Timestamp int64 + func (*Payload) Descriptor() ([]byte, []int) + func (*Payload) ProtoMessage() + func (m *Payload) GetHardforkMessage() string + func (m *Payload) GetTimestamp() int64 + func (m *Payload) Marshal() (dAtA []byte, err error) + func (m *Payload) MarshalTo(dAtA []byte) (int, error) + func (m *Payload) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Payload) Reset() + func (m *Payload) Size() (n int) + func (m *Payload) Unmarshal(dAtA []byte) error + func (m *Payload) XXX_DiscardUnknown() + func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Payload) XXX_Merge(src proto.Message) + func (m *Payload) XXX_Size() int + func (m *Payload) XXX_Unmarshal(b []byte) error + func (this *Payload) Equal(that interface{}) bool + func (this *Payload) GoString() string + func (this *Payload) String() string + type PeerAuthentication struct + Payload []byte + PayloadSignature []byte + Pid []byte + Pubkey []byte + Signature []byte + func (*PeerAuthentication) Descriptor() ([]byte, []int) + func (*PeerAuthentication) ProtoMessage() + func (m *PeerAuthentication) GetPayload() []byte + func (m *PeerAuthentication) GetPayloadSignature() []byte + func (m *PeerAuthentication) GetPid() []byte + func (m *PeerAuthentication) GetPubkey() []byte + func (m *PeerAuthentication) GetSignature() []byte + func (m *PeerAuthentication) Marshal() (dAtA []byte, err error) + func (m *PeerAuthentication) MarshalTo(dAtA []byte) (int, error) + func (m *PeerAuthentication) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PeerAuthentication) Reset() + func (m *PeerAuthentication) Size() (n int) + func (m *PeerAuthentication) Unmarshal(dAtA []byte) error + func (m *PeerAuthentication) XXX_DiscardUnknown() + func (m *PeerAuthentication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PeerAuthentication) XXX_Merge(src proto.Message) + func (m *PeerAuthentication) XXX_Size() int + func (m *PeerAuthentication) XXX_Unmarshal(b []byte) error + func (this *PeerAuthentication) Equal(that interface{}) bool + func (this *PeerAuthentication) GoString() string + func (this *PeerAuthentication) String() string + type PeerBlackListHandler interface + Add func(pid core.PeerID) error + Has func(pid core.PeerID) bool + IsInterfaceNil func() bool + Sweep func() + type PeerShardMapper interface + IsInterfaceNil func() bool + PutPeerIdShardId func(pid core.PeerID, shardID uint32) + type PeerTypeProviderHandler interface + ComputeForPubKey func(pubKey []byte) (common.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)