Versions in this module Expand all Collapse all v1 v1.1.66 Jun 17, 2021 v1.1.65 Jun 17, 2021 Changes in this version + var ErrIntOverflowHeartbeat = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthHeartbeat = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupHeartbeat = fmt.Errorf("proto: unexpected end of group") + type DbTimeStamp struct + Timestamp int64 + func (*DbTimeStamp) Descriptor() ([]byte, []int) + func (*DbTimeStamp) ProtoMessage() + func (m *DbTimeStamp) GetTimestamp() int64 + func (m *DbTimeStamp) Marshal() (dAtA []byte, err error) + func (m *DbTimeStamp) MarshalTo(dAtA []byte) (int, error) + func (m *DbTimeStamp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DbTimeStamp) Reset() + func (m *DbTimeStamp) Size() (n int) + func (m *DbTimeStamp) Unmarshal(dAtA []byte) error + func (m *DbTimeStamp) XXX_DiscardUnknown() + func (m *DbTimeStamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DbTimeStamp) XXX_Merge(src proto.Message) + func (m *DbTimeStamp) XXX_Size() int + func (m *DbTimeStamp) XXX_Unmarshal(b []byte) error + func (this *DbTimeStamp) Equal(that interface{}) bool + func (this *DbTimeStamp) GoString() string + func (this *DbTimeStamp) String() string + type Duration struct + func (d *Duration) UnmarshalJSON(b []byte) error + func (d Duration) MarshalJSON() ([]byte, error) + type Heartbeat struct + Identity string + NodeDisplayName string + Nonce uint64 + Payload []byte + Pid []byte + Pubkey []byte + ShardID uint32 + Signature []byte + VersionNumber string + func (*Heartbeat) Descriptor() ([]byte, []int) + func (*Heartbeat) ProtoMessage() + func (m *Heartbeat) GetIdentity() string + func (m *Heartbeat) GetNodeDisplayName() string + func (m *Heartbeat) GetNonce() uint64 + func (m *Heartbeat) GetPayload() []byte + func (m *Heartbeat) GetPid() []byte + func (m *Heartbeat) GetPubkey() []byte + func (m *Heartbeat) GetShardID() uint32 + func (m *Heartbeat) GetSignature() []byte + func (m *Heartbeat) GetVersionNumber() string + func (m *Heartbeat) Marshal() (dAtA []byte, err error) + func (m *Heartbeat) MarshalTo(dAtA []byte) (int, error) + func (m *Heartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Heartbeat) Reset() + func (m *Heartbeat) Size() (n int) + func (m *Heartbeat) Unmarshal(dAtA []byte) error + func (m *Heartbeat) XXX_DiscardUnknown() + func (m *Heartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Heartbeat) XXX_Merge(src proto.Message) + func (m *Heartbeat) XXX_Size() int + func (m *Heartbeat) XXX_Unmarshal(b []byte) error + func (this *Heartbeat) Equal(that interface{}) bool + func (this *Heartbeat) GoString() string + func (this *Heartbeat) String() string + type HeartbeatDTO struct + ComputedShardID uint32 + GenesisTime int64 + Identity string + IsActive bool + IsValidator bool + LastUptimeDowntime int64 + MaxDurationPeerUnresponsive int64 + MaxInactiveTime int64 + NodeDisplayName string + Nonce uint64 + NumInstances uint64 + PeerType string + ReceivedShardID uint32 + TimeStamp int64 + TotalDownTime int64 + TotalUpTime int64 + VersionNumber string + func (*HeartbeatDTO) Descriptor() ([]byte, []int) + func (*HeartbeatDTO) ProtoMessage() + func (m *HeartbeatDTO) GetComputedShardID() uint32 + func (m *HeartbeatDTO) GetGenesisTime() int64 + func (m *HeartbeatDTO) GetIdentity() string + func (m *HeartbeatDTO) GetIsActive() bool + func (m *HeartbeatDTO) GetIsValidator() bool + func (m *HeartbeatDTO) GetLastUptimeDowntime() int64 + func (m *HeartbeatDTO) GetMaxDurationPeerUnresponsive() int64 + func (m *HeartbeatDTO) GetMaxInactiveTime() int64 + func (m *HeartbeatDTO) GetNodeDisplayName() string + func (m *HeartbeatDTO) GetNonce() uint64 + func (m *HeartbeatDTO) GetNumInstances() uint64 + func (m *HeartbeatDTO) GetPeerType() string + func (m *HeartbeatDTO) GetReceivedShardID() uint32 + func (m *HeartbeatDTO) GetTimeStamp() int64 + func (m *HeartbeatDTO) GetTotalDownTime() int64 + func (m *HeartbeatDTO) GetTotalUpTime() int64 + func (m *HeartbeatDTO) GetVersionNumber() string + func (m *HeartbeatDTO) Marshal() (dAtA []byte, err error) + func (m *HeartbeatDTO) MarshalTo(dAtA []byte) (int, error) + func (m *HeartbeatDTO) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *HeartbeatDTO) Reset() + func (m *HeartbeatDTO) Size() (n int) + func (m *HeartbeatDTO) Unmarshal(dAtA []byte) error + func (m *HeartbeatDTO) XXX_DiscardUnknown() + func (m *HeartbeatDTO) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HeartbeatDTO) XXX_Merge(src proto.Message) + func (m *HeartbeatDTO) XXX_Size() int + func (m *HeartbeatDTO) XXX_Unmarshal(b []byte) error + func (this *HeartbeatDTO) Equal(that interface{}) bool + func (this *HeartbeatDTO) GoString() string + func (this *HeartbeatDTO) String() string + type PubKeyHeartbeat struct + ComputedShardID uint32 + Identity string + IsActive bool + MaxInactiveTime Duration + NodeDisplayName string + Nonce uint64 + NumInstances uint64 + PeerType string + PublicKey string + ReceivedShardID uint32 + TimeStamp time.Time + TotalDownTime int64 + TotalUpTime int64 + VersionNumber string