pb

package

Go to main page

Versions in this module

v0

v0.0.12

Apr 9, 2021

v0.0.11

Dec 23, 2020

v0.0.10

Dec 23, 2020

v0.0.9

Dec 10, 2020

Changes in this version

+ var Msg_MsgType_name = map[int32]string

+ var Msg_MsgType_value = map[string]int32

+ 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 RequestControl

+ Topic string

type ResponseControl

+ Topic string

v0.0.8

Dec 2, 2020

v0.0.8-intbfs

Dec 7, 2020

v0.0.7

Dec 1, 2020

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")

+ 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 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

+ 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

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL