Versions in this module Expand all Collapse all v0 v0.10.1 Mar 6, 2024 v0.10.0 Mar 6, 2024 v0.0.1 Dec 12, 2021 Changes in this version + var ErrIntOverflowPubsubcollect = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPubsubcollect = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupPubsubcollect = fmt.Errorf("proto: unexpected end of group") + var Msg_MsgType_name = map[int32]string + var Msg_MsgType_value = map[string]int32 + type Error struct + Code uint32 + Message string + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) String() string + func (m *Error) Unmarshal(dAtA []byte) error + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type Intermediate struct + Error *Error + Hit bool + Payload []byte + func (*Intermediate) Descriptor() ([]byte, []int) + func (*Intermediate) ProtoMessage() + func (m *Intermediate) Marshal() (dAtA []byte, err error) + func (m *Intermediate) MarshalTo(dAtA []byte) (int, error) + func (m *Intermediate) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Intermediate) Reset() + func (m *Intermediate) Size() (n int) + func (m *Intermediate) String() string + func (m *Intermediate) Unmarshal(dAtA []byte) error + func (m *Intermediate) XXX_DiscardUnknown() + func (m *Intermediate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Intermediate) XXX_Merge(src proto.Message) + func (m *Intermediate) XXX_Size() int + func (m *Intermediate) XXX_Unmarshal(b []byte) error + type Msg struct + Request *Request + Response *Response + Type Msg_MsgType + func (*Msg) Descriptor() ([]byte, []int) + func (*Msg) ProtoMessage() + func (m *Msg) Marshal() (dAtA []byte, err error) + func (m *Msg) MarshalTo(dAtA []byte) (int, error) + func (m *Msg) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Msg) Reset() + func (m *Msg) Size() (n int) + func (m *Msg) String() string + func (m *Msg) Unmarshal(dAtA []byte) error + func (m *Msg) XXX_DiscardUnknown() + func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Msg) XXX_Merge(src proto.Message) + func (m *Msg) XXX_Size() int + func (m *Msg) XXX_Unmarshal(b []byte) error + type Msg_MsgType int32 + const Msg_Hit + const Msg_Request + const Msg_Response + const Msg_Unknown + func (Msg_MsgType) EnumDescriptor() ([]byte, []int) + func (x Msg_MsgType) String() string + type Request struct + Control RequestControl + Payload []byte + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Request) Reset() + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type RequestControl struct + Hops uint32 + Requester github_com_libp2p_go_libp2p_core_peer.ID + Sender github_com_libp2p_go_libp2p_core_peer.ID + Seqno uint64 + Topic string + func (*RequestControl) Descriptor() ([]byte, []int) + func (*RequestControl) ProtoMessage() + func (m *RequestControl) Marshal() (dAtA []byte, err error) + func (m *RequestControl) MarshalTo(dAtA []byte) (int, error) + func (m *RequestControl) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RequestControl) Reset() + func (m *RequestControl) Size() (n int) + func (m *RequestControl) String() string + func (m *RequestControl) Unmarshal(dAtA []byte) error + func (m *RequestControl) XXX_DiscardUnknown() + func (m *RequestControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RequestControl) XXX_Merge(src proto.Message) + func (m *RequestControl) XXX_Size() int + func (m *RequestControl) XXX_Unmarshal(b []byte) error + type RequestID string + func (r RequestID) String() string + type Response struct + Control ResponseControl + Error *Error + Payload []byte + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Response) Reset() + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type ResponseControl struct + RequestId RequestID + Requester github_com_libp2p_go_libp2p_core_peer.ID + Responser github_com_libp2p_go_libp2p_core_peer.ID + Sender github_com_libp2p_go_libp2p_core_peer.ID + Topic string + func (*ResponseControl) Descriptor() ([]byte, []int) + func (*ResponseControl) ProtoMessage() + func (m *ResponseControl) Marshal() (dAtA []byte, err error) + func (m *ResponseControl) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseControl) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResponseControl) Reset() + func (m *ResponseControl) Size() (n int) + func (m *ResponseControl) String() string + func (m *ResponseControl) Unmarshal(dAtA []byte) error + func (m *ResponseControl) XXX_DiscardUnknown() + func (m *ResponseControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResponseControl) XXX_Merge(src proto.Message) + func (m *ResponseControl) XXX_Size() int + func (m *ResponseControl) XXX_Unmarshal(b []byte) error + type Responses struct + Responses []*Responses + func (*Responses) Descriptor() ([]byte, []int) + func (*Responses) ProtoMessage() + func (m *Responses) Marshal() (dAtA []byte, err error) + func (m *Responses) MarshalTo(dAtA []byte) (int, error) + func (m *Responses) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Responses) Reset() + func (m *Responses) Size() (n int) + func (m *Responses) String() string + func (m *Responses) Unmarshal(dAtA []byte) error + func (m *Responses) XXX_DiscardUnknown() + func (m *Responses) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Responses) XXX_Merge(src proto.Message) + func (m *Responses) XXX_Size() int + func (m *Responses) XXX_Unmarshal(b []byte) error