Versions in this module Expand all Collapse all v1 v1.3.1 Dec 27, 2023 v1.3.0 Dec 23, 2022 Changes in this version + var DiscoveryMsg_Type_name = map[int32]string + var DiscoveryMsg_Type_value = map[string]int32 + var ErrIntOverflowDiscoveryMsg = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowMessageRoutingMsg = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowPeerInfo = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthDiscoveryMsg = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthMessageRoutingMsg = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthPeerInfo = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupDiscoveryMsg = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupMessageRoutingMsg = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupPeerInfo = fmt.Errorf("proto: unexpected end of group") + var MessageRoutingMsg_Type_name = map[int32]string + var MessageRoutingMsg_Type_value = map[string]int32 + type DiscoveryMsg struct + PInfo []*PeerInfo + Size_ uint32 + Type DiscoveryMsg_Type + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DiscoveryMsg) Descriptor() ([]byte, []int) + func (*DiscoveryMsg) ProtoMessage() + func (m *DiscoveryMsg) GetPInfo() []*PeerInfo + func (m *DiscoveryMsg) GetSize_() uint32 + func (m *DiscoveryMsg) GetType() DiscoveryMsg_Type + func (m *DiscoveryMsg) Marshal() (dAtA []byte, err error) + func (m *DiscoveryMsg) MarshalTo(dAtA []byte) (int, error) + func (m *DiscoveryMsg) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DiscoveryMsg) Reset() + func (m *DiscoveryMsg) Size() (n int) + func (m *DiscoveryMsg) String() string + func (m *DiscoveryMsg) Unmarshal(dAtA []byte) error + func (m *DiscoveryMsg) XXX_DiscardUnknown() + func (m *DiscoveryMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DiscoveryMsg) XXX_Merge(src proto.Message) + func (m *DiscoveryMsg) XXX_Size() int + func (m *DiscoveryMsg) XXX_Unmarshal(b []byte) error + type DiscoveryMsg_Type int32 + const DiscoveryMsg_Announce + const DiscoveryMsg_FindReq + const DiscoveryMsg_FindRes + const DiscoveryMsg_HEARTBEAT + const DiscoveryMsg_HEARTBEATRes + func (DiscoveryMsg_Type) EnumDescriptor() ([]byte, []int) + func (x DiscoveryMsg_Type) String() string + type MessageRoutingMsg struct + CallMe bool + Data []byte + From *PeerInfo + HopCount int64 + Id string + RespMsgId string + ResponseMe bool + SendTime int64 + Sender string + SenderKey []byte + SenderSign []byte + To string + Type MessageRoutingMsg_Type + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MessageRoutingMsg) Descriptor() ([]byte, []int) + func (*MessageRoutingMsg) ProtoMessage() + func (m *MessageRoutingMsg) GetCallMe() bool + func (m *MessageRoutingMsg) GetData() []byte + func (m *MessageRoutingMsg) GetFrom() *PeerInfo + func (m *MessageRoutingMsg) GetHopCount() int64 + func (m *MessageRoutingMsg) GetId() string + func (m *MessageRoutingMsg) GetRespMsgId() string + func (m *MessageRoutingMsg) GetResponseMe() bool + func (m *MessageRoutingMsg) GetSendTime() int64 + func (m *MessageRoutingMsg) GetSender() string + func (m *MessageRoutingMsg) GetSenderKey() []byte + func (m *MessageRoutingMsg) GetSenderSign() []byte + func (m *MessageRoutingMsg) GetTo() string + func (m *MessageRoutingMsg) GetType() MessageRoutingMsg_Type + func (m *MessageRoutingMsg) Marshal() (dAtA []byte, err error) + func (m *MessageRoutingMsg) MarshalTo(dAtA []byte) (int, error) + func (m *MessageRoutingMsg) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MessageRoutingMsg) Reset() + func (m *MessageRoutingMsg) Size() (n int) + func (m *MessageRoutingMsg) String() string + func (m *MessageRoutingMsg) Unmarshal(dAtA []byte) error + func (m *MessageRoutingMsg) XXX_DiscardUnknown() + func (m *MessageRoutingMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MessageRoutingMsg) XXX_Merge(src proto.Message) + func (m *MessageRoutingMsg) XXX_Size() int + func (m *MessageRoutingMsg) XXX_Unmarshal(b []byte) error + type MessageRoutingMsg_Type int32 + const MessageRoutingMsg_MsgReq + const MessageRoutingMsg_MsgResp + func (MessageRoutingMsg_Type) EnumDescriptor() ([]byte, []int) + func (x MessageRoutingMsg_Type) String() string + type PeerInfo struct + Addrs []string + Pid string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PeerInfo) Descriptor() ([]byte, []int) + func (*PeerInfo) ProtoMessage() + func (m *PeerInfo) GetAddrs() []string + func (m *PeerInfo) GetPid() string + func (m *PeerInfo) Marshal() (dAtA []byte, err error) + func (m *PeerInfo) MarshalTo(dAtA []byte) (int, error) + func (m *PeerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PeerInfo) Reset() + func (m *PeerInfo) Size() (n int) + func (m *PeerInfo) String() string + func (m *PeerInfo) Unmarshal(dAtA []byte) error + func (m *PeerInfo) XXX_DiscardUnknown() + func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PeerInfo) XXX_Merge(src proto.Message) + func (m *PeerInfo) XXX_Size() int + func (m *PeerInfo) XXX_Unmarshal(b []byte) error
Go to main page