Versions in this module Expand all Collapse all v0 v0.0.1 Sep 5, 2023 Changes in this version + var ErrIntOverflowPeerShardMessage = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPeerShardMessage = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupPeerShardMessage = fmt.Errorf("proto: unexpected end of group") + type Message struct + DataField []byte + FromField []byte + KeyField []byte + PayloadField []byte + PeerField core.PeerID + SeqNoField []byte + SignatureField []byte + TimestampField int64 + TopicField string + func (m *Message) Data() []byte + func (m *Message) From() []byte + func (m *Message) IsInterfaceNil() bool + func (m *Message) Key() []byte + func (m *Message) Payload() []byte + func (m *Message) Peer() core.PeerID + func (m *Message) SeqNo() []byte + func (m *Message) Signature() []byte + func (m *Message) Timestamp() int64 + func (m *Message) Topic() string + type PeerShard struct + ShardId string + func (*PeerShard) Descriptor() ([]byte, []int) + func (*PeerShard) ProtoMessage() + func (m *PeerShard) GetShardId() string + func (m *PeerShard) Marshal() (dAtA []byte, err error) + func (m *PeerShard) MarshalTo(dAtA []byte) (int, error) + func (m *PeerShard) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PeerShard) Reset() + func (m *PeerShard) Size() (n int) + func (m *PeerShard) Unmarshal(dAtA []byte) error + func (m *PeerShard) XXX_DiscardUnknown() + func (m *PeerShard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PeerShard) XXX_Merge(src proto.Message) + func (m *PeerShard) XXX_Size() int + func (m *PeerShard) XXX_Unmarshal(b []byte) error + func (this *PeerShard) Equal(that interface{}) bool + func (this *PeerShard) GoString() string + func (this *PeerShard) String() string