Versions in this module Expand all Collapse all v0 v0.0.1 Nov 7, 2024 Changes in this version + var ErrEmptySendTopic = errors.New("empty topic for sending messages") + var ErrIntOverflowHeartbeat = fmt.Errorf("proto: integer overflow") + var ErrInvalidConfiguration = errors.New("invalid configuration") + var ErrInvalidLengthHeartbeat = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidThreshold = errors.New("invalid threshold") + var ErrInvalidTimeDuration = errors.New("invalid time duration") + var ErrInvalidValue = errors.New("invalid value") + var ErrNilAppStatusHandler = errors.New("nil AppStatusHandler") + var ErrNilCacher = errors.New("nil cacher") + var ErrNilCurrentBlockProvider = errors.New("nil current block provider") + var ErrNilHardforkTrigger = errors.New("nil hardfork trigger") + var ErrNilHeartbeatMonitor = errors.New("nil heartbeat monitor") + var ErrNilHeartbeatSenderInfoProvider = errors.New("nil heartbeat sender info provider") + var ErrNilManagedPeersHolder = errors.New("nil managed peers holder") + var ErrNilMarshaller = errors.New("nil marshaller") + var ErrNilMessenger = errors.New("nil P2P Messenger") + 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 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 ErrNilTrieSyncStatisticsProvider = errors.New("nil trie sync statistics provider") + var ErrPropertyTooLong = errors.New("property too long in Heartbeat") + var ErrShouldSkipValidator = errors.New("validator should be skipped") + var ErrUnexpectedEndOfGroupHeartbeat = fmt.Errorf("proto: unexpected end of group") + type CurrentBlockProvider interface + GetCurrentBlockHeader func() data.HeaderHandler + IsInterfaceNil func() bool + SetCurrentBlockHeaderAndRootHash func(bh data.HeaderHandler, rootHash []byte) error + type HardforkTrigger interface + CreateData func() []byte + IsInterfaceNil func() bool + NotifyTriggerReceivedV2 func() <-chan struct{} + RecordedTriggerMessage func() ([]byte, bool) + TriggerReceived func(payload []byte, data []byte, pkBytes []byte) (bool, error) + type HeartbeatV2 struct + Identity string + NodeDisplayName string + Nonce uint64 + NumTrieNodesSynced 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) GetNumTrieNodesSynced() 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 ManagedPeersHolder interface + AddManagedPeer func(privateKeyBytes []byte) error + GetLoadedKeysByCurrentNode func() [][]byte + GetMachineID func(pkBytes []byte) (string, error) + GetManagedKeysByCurrentNode func() map[string]crypto.PrivateKey + GetNameAndIdentity func(pkBytes []byte) (string, string, error) + GetNextPeerAuthenticationTime func(pkBytes []byte) (time.Time, error) + GetP2PIdentity func(pkBytes []byte) ([]byte, core.PeerID, error) + GetPrivateKey func(pkBytes []byte) (crypto.PrivateKey, error) + IncrementRoundsWithoutReceivedMessages func(pkBytes []byte) + IsInterfaceNil func() bool + IsKeyManagedByCurrentNode func(pkBytes []byte) bool + IsKeyRegistered func(pkBytes []byte) bool + IsKeyValidator func(pkBytes []byte) bool + IsMultiKeyMode func() bool + IsPidManagedByCurrentNode func(pid core.PeerID) bool + ResetRoundsWithoutReceivedMessages func(pkBytes []byte, pid core.PeerID) + SetNextPeerAuthenticationTime func(pkBytes []byte, nextTime time.Time) + SetValidatorState func(pkBytes []byte, state bool) + 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 P2PMessenger interface + Broadcast func(topic string, buff []byte) + BroadcastUsingPrivateKey func(topic string, buff []byte, pid core.PeerID, skBytes []byte) + ConnectedPeersOnTopic func(topic string) []core.PeerID + ID func() core.PeerID + IsInterfaceNil func() bool + Sign func(payload []byte) ([]byte, error) + SignUsingPrivateKey func(skBytes []byte, 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 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 ShardCoordinator interface + ComputeId func(address []byte) uint32 + IsInterfaceNil func() bool + SelfId func() uint32 + type TrieSyncStatisticsProvider interface + IsInterfaceNil func() bool + NumProcessed func() int
Go to main page