pubsub_pb

package

Go to main page

Versions in this module

v0

v0.10.0

Nov 1, 2023

v0.9.3

Mar 15, 2023

v0.9.2

Mar 1, 2023

v0.9.1

Feb 21, 2023

v0.9.0

Feb 10, 2023

v0.8.3

Jan 24, 2023

v0.8.2

Dec 1, 2022

v0.8.1

Sep 8, 2022

v0.8.0

Aug 26, 2022

v0.7.1

Jul 1, 2022

v0.7.0

May 30, 2022

v0.6.1

Jan 13, 2022

v0.6.0

Nov 11, 2021

v0.5.6

Oct 29, 2021

v0.5.5

Sep 22, 2021

v0.5.4

Jul 30, 2021

v0.5.3

Jul 28, 2021

v0.5.2

Jul 28, 2021

v0.5.1

Jul 27, 2021

v0.5.0

Jul 13, 2021

v0.4.2

Jul 16, 2021

v0.4.1

Jan 12, 2021

Changes in this version

type TraceEvent_DeliverMessage

+ ReceivedFrom []byte

+ func (m *TraceEvent_DeliverMessage) GetReceivedFrom() []byte

v0.4.0

Nov 12, 2020

v0.3.6

Oct 8, 2020

Changes in this version

type Message

+ Topic *string

+ func (m *Message) GetTopic() string

type TraceEvent_DeliverMessage

+ Topic *string

+ func (m *TraceEvent_DeliverMessage) GetTopic() string

type TraceEvent_DuplicateMessage

+ Topic *string

+ func (m *TraceEvent_DuplicateMessage) GetTopic() string

type TraceEvent_MessageMeta

+ Topic *string

+ func (m *TraceEvent_MessageMeta) GetTopic() string

type TraceEvent_PublishMessage

+ Topic *string

+ func (m *TraceEvent_PublishMessage) GetTopic() string

type TraceEvent_RejectMessage

+ Topic *string

+ func (m *TraceEvent_RejectMessage) GetTopic() string

v0.3.5

Aug 25, 2020

Changes in this version

type PeerInfo

+ func (m *PeerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

v0.3.4

Aug 10, 2020

Changes in this version

type TraceEvent_DeliverMessage

+ Topics []string

+ func (m *TraceEvent_DeliverMessage) GetTopics() []string

type TraceEvent_DuplicateMessage

+ Topics []string

+ func (m *TraceEvent_DuplicateMessage) GetTopics() []string

type TraceEvent_RejectMessage

+ Topics []string

+ func (m *TraceEvent_RejectMessage) GetTopics() []string

v0.3.3

Jul 30, 2020

v0.3.2

Jun 3, 2020

v0.3.1

May 26, 2020

v0.3.0

May 20, 2020

Changes in this version

type ControlPrune

+ Backoff *uint64

+ Peers []*PeerInfo

+ func (m *ControlPrune) GetBackoff() uint64

+ func (m *ControlPrune) GetPeers() []*PeerInfo

+ type PeerInfo struct

+ PeerID []byte

+ SignedPeerRecord []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PeerInfo) Descriptor() ([]byte, []int)

+ func (*PeerInfo) ProtoMessage()

+ func (m *PeerInfo) GetPeerID() []byte

+ func (m *PeerInfo) GetSignedPeerRecord() []byte

+ func (m *PeerInfo) Marshal() (dAtA []byte, err error)

+ func (m *PeerInfo) MarshalTo(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

type TraceEvent_ControlPruneMeta

+ Peers [][]byte

+ func (m *TraceEvent_ControlPruneMeta) GetPeers() [][]byte

v0.2.7

Apr 13, 2020

v0.2.6

Feb 11, 2020

v0.2.5

Dec 16, 2019

v0.2.4

Dec 2, 2019

Changes in this version

+ var ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupTrace = fmt.Errorf("proto: unexpected end of group")

type ControlGraft

+ func (m *ControlGraft) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ControlIHave

+ func (m *ControlIHave) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ControlIWant

+ func (m *ControlIWant) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ControlMessage

+ func (m *ControlMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ControlPrune

+ func (m *ControlPrune) MarshalToSizedBuffer(dAtA []byte) (int, error)

type Message

+ func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RPC

+ func (m *RPC) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RPC_SubOpts

+ func (m *RPC_SubOpts) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TopicDescriptor

+ func (m *TopicDescriptor) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TopicDescriptor_AuthOpts

+ func (m *TopicDescriptor_AuthOpts) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TopicDescriptor_EncOpts

+ func (m *TopicDescriptor_EncOpts) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent

+ func (m *TraceEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEventBatch

+ func (m *TraceEventBatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_AddPeer

+ func (m *TraceEvent_AddPeer) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_ControlGraftMeta

+ func (m *TraceEvent_ControlGraftMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_ControlIHaveMeta

+ func (m *TraceEvent_ControlIHaveMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_ControlIWantMeta

+ func (m *TraceEvent_ControlIWantMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_ControlMeta

+ func (m *TraceEvent_ControlMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_ControlPruneMeta

+ func (m *TraceEvent_ControlPruneMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_DeliverMessage

+ func (m *TraceEvent_DeliverMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_DropRPC

+ func (m *TraceEvent_DropRPC) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_DuplicateMessage

+ func (m *TraceEvent_DuplicateMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_Graft

+ func (m *TraceEvent_Graft) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_Join

+ func (m *TraceEvent_Join) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_Leave

+ func (m *TraceEvent_Leave) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_MessageMeta

+ func (m *TraceEvent_MessageMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_Prune

+ func (m *TraceEvent_Prune) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_PublishMessage

+ func (m *TraceEvent_PublishMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_RPCMeta

+ func (m *TraceEvent_RPCMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_RecvRPC

+ func (m *TraceEvent_RecvRPC) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_RejectMessage

+ func (m *TraceEvent_RejectMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_RemovePeer

+ func (m *TraceEvent_RemovePeer) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_SendRPC

+ func (m *TraceEvent_SendRPC) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceEvent_SubMeta

+ func (m *TraceEvent_SubMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

v0.2.3

Nov 19, 2019

Changes in this version

+ var ErrIntOverflowTrace = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthTrace = fmt.Errorf("proto: negative length found during unmarshaling")

+ var TraceEvent_Type_name = map[int32]string

+ var TraceEvent_Type_value = map[string]int32

+ type TraceEvent struct

+ AddPeer *TraceEvent_AddPeer

+ DeliverMessage *TraceEvent_DeliverMessage

+ DropRPC *TraceEvent_DropRPC

+ DuplicateMessage *TraceEvent_DuplicateMessage

+ Graft *TraceEvent_Graft

+ Join *TraceEvent_Join

+ Leave *TraceEvent_Leave

+ PeerID []byte

+ Prune *TraceEvent_Prune

+ PublishMessage *TraceEvent_PublishMessage

+ RecvRPC *TraceEvent_RecvRPC

+ RejectMessage *TraceEvent_RejectMessage

+ RemovePeer *TraceEvent_RemovePeer

+ SendRPC *TraceEvent_SendRPC

+ Timestamp *int64

+ Type *TraceEvent_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent) Descriptor() ([]byte, []int)

+ func (*TraceEvent) ProtoMessage()

+ func (m *TraceEvent) GetAddPeer() *TraceEvent_AddPeer

+ func (m *TraceEvent) GetDeliverMessage() *TraceEvent_DeliverMessage

+ func (m *TraceEvent) GetDropRPC() *TraceEvent_DropRPC

+ func (m *TraceEvent) GetDuplicateMessage() *TraceEvent_DuplicateMessage

+ func (m *TraceEvent) GetGraft() *TraceEvent_Graft

+ func (m *TraceEvent) GetJoin() *TraceEvent_Join

+ func (m *TraceEvent) GetLeave() *TraceEvent_Leave

+ func (m *TraceEvent) GetPeerID() []byte

+ func (m *TraceEvent) GetPrune() *TraceEvent_Prune

+ func (m *TraceEvent) GetPublishMessage() *TraceEvent_PublishMessage

+ func (m *TraceEvent) GetRecvRPC() *TraceEvent_RecvRPC

+ func (m *TraceEvent) GetRejectMessage() *TraceEvent_RejectMessage

+ func (m *TraceEvent) GetRemovePeer() *TraceEvent_RemovePeer

+ func (m *TraceEvent) GetSendRPC() *TraceEvent_SendRPC

+ func (m *TraceEvent) GetTimestamp() int64

+ func (m *TraceEvent) GetType() TraceEvent_Type

+ func (m *TraceEvent) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent) Reset()

+ func (m *TraceEvent) Size() (n int)

+ func (m *TraceEvent) String() string

+ func (m *TraceEvent) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent) XXX_DiscardUnknown()

+ func (m *TraceEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent) XXX_Merge(src proto.Message)

+ func (m *TraceEvent) XXX_Size() int

+ func (m *TraceEvent) XXX_Unmarshal(b []byte) error

+ type TraceEventBatch struct

+ Batch []*TraceEvent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEventBatch) Descriptor() ([]byte, []int)

+ func (*TraceEventBatch) ProtoMessage()

+ func (m *TraceEventBatch) GetBatch() []*TraceEvent

+ func (m *TraceEventBatch) Marshal() (dAtA []byte, err error)

+ func (m *TraceEventBatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEventBatch) Reset()

+ func (m *TraceEventBatch) Size() (n int)

+ func (m *TraceEventBatch) String() string

+ func (m *TraceEventBatch) Unmarshal(dAtA []byte) error

+ func (m *TraceEventBatch) XXX_DiscardUnknown()

+ func (m *TraceEventBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEventBatch) XXX_Merge(src proto.Message)

+ func (m *TraceEventBatch) XXX_Size() int

+ func (m *TraceEventBatch) XXX_Unmarshal(b []byte) error

+ type TraceEvent_AddPeer struct

+ PeerID []byte

+ Proto *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_AddPeer) Descriptor() ([]byte, []int)

+ func (*TraceEvent_AddPeer) ProtoMessage()

+ func (m *TraceEvent_AddPeer) GetPeerID() []byte

+ func (m *TraceEvent_AddPeer) GetProto() string

+ func (m *TraceEvent_AddPeer) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_AddPeer) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_AddPeer) Reset()

+ func (m *TraceEvent_AddPeer) Size() (n int)

+ func (m *TraceEvent_AddPeer) String() string

+ func (m *TraceEvent_AddPeer) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_AddPeer) XXX_DiscardUnknown()

+ func (m *TraceEvent_AddPeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_AddPeer) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_AddPeer) XXX_Size() int

+ func (m *TraceEvent_AddPeer) XXX_Unmarshal(b []byte) error

+ type TraceEvent_ControlGraftMeta struct

+ Topic *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_ControlGraftMeta) Descriptor() ([]byte, []int)

+ func (*TraceEvent_ControlGraftMeta) ProtoMessage()

+ func (m *TraceEvent_ControlGraftMeta) GetTopic() string

+ func (m *TraceEvent_ControlGraftMeta) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_ControlGraftMeta) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_ControlGraftMeta) Reset()

+ func (m *TraceEvent_ControlGraftMeta) Size() (n int)

+ func (m *TraceEvent_ControlGraftMeta) String() string

+ func (m *TraceEvent_ControlGraftMeta) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_ControlGraftMeta) XXX_DiscardUnknown()

+ func (m *TraceEvent_ControlGraftMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_ControlGraftMeta) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_ControlGraftMeta) XXX_Size() int

+ func (m *TraceEvent_ControlGraftMeta) XXX_Unmarshal(b []byte) error

+ type TraceEvent_ControlIHaveMeta struct

+ MessageIDs [][]byte

+ Topic *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_ControlIHaveMeta) Descriptor() ([]byte, []int)

+ func (*TraceEvent_ControlIHaveMeta) ProtoMessage()

+ func (m *TraceEvent_ControlIHaveMeta) GetMessageIDs() [][]byte

+ func (m *TraceEvent_ControlIHaveMeta) GetTopic() string

+ func (m *TraceEvent_ControlIHaveMeta) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_ControlIHaveMeta) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_ControlIHaveMeta) Reset()

+ func (m *TraceEvent_ControlIHaveMeta) Size() (n int)

+ func (m *TraceEvent_ControlIHaveMeta) String() string

+ func (m *TraceEvent_ControlIHaveMeta) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_ControlIHaveMeta) XXX_DiscardUnknown()

+ func (m *TraceEvent_ControlIHaveMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_ControlIHaveMeta) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_ControlIHaveMeta) XXX_Size() int

+ func (m *TraceEvent_ControlIHaveMeta) XXX_Unmarshal(b []byte) error

+ type TraceEvent_ControlIWantMeta struct

+ MessageIDs [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_ControlIWantMeta) Descriptor() ([]byte, []int)

+ func (*TraceEvent_ControlIWantMeta) ProtoMessage()

+ func (m *TraceEvent_ControlIWantMeta) GetMessageIDs() [][]byte

+ func (m *TraceEvent_ControlIWantMeta) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_ControlIWantMeta) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_ControlIWantMeta) Reset()

+ func (m *TraceEvent_ControlIWantMeta) Size() (n int)

+ func (m *TraceEvent_ControlIWantMeta) String() string

+ func (m *TraceEvent_ControlIWantMeta) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_ControlIWantMeta) XXX_DiscardUnknown()

+ func (m *TraceEvent_ControlIWantMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_ControlIWantMeta) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_ControlIWantMeta) XXX_Size() int

+ func (m *TraceEvent_ControlIWantMeta) XXX_Unmarshal(b []byte) error

+ type TraceEvent_ControlMeta struct

+ Graft []*TraceEvent_ControlGraftMeta

+ Ihave []*TraceEvent_ControlIHaveMeta

+ Iwant []*TraceEvent_ControlIWantMeta

+ Prune []*TraceEvent_ControlPruneMeta

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_ControlMeta) Descriptor() ([]byte, []int)

+ func (*TraceEvent_ControlMeta) ProtoMessage()

+ func (m *TraceEvent_ControlMeta) GetGraft() []*TraceEvent_ControlGraftMeta

+ func (m *TraceEvent_ControlMeta) GetIhave() []*TraceEvent_ControlIHaveMeta

+ func (m *TraceEvent_ControlMeta) GetIwant() []*TraceEvent_ControlIWantMeta

+ func (m *TraceEvent_ControlMeta) GetPrune() []*TraceEvent_ControlPruneMeta

+ func (m *TraceEvent_ControlMeta) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_ControlMeta) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_ControlMeta) Reset()

+ func (m *TraceEvent_ControlMeta) Size() (n int)

+ func (m *TraceEvent_ControlMeta) String() string

+ func (m *TraceEvent_ControlMeta) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_ControlMeta) XXX_DiscardUnknown()

+ func (m *TraceEvent_ControlMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_ControlMeta) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_ControlMeta) XXX_Size() int

+ func (m *TraceEvent_ControlMeta) XXX_Unmarshal(b []byte) error

+ type TraceEvent_ControlPruneMeta struct

+ Topic *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_ControlPruneMeta) Descriptor() ([]byte, []int)

+ func (*TraceEvent_ControlPruneMeta) ProtoMessage()

+ func (m *TraceEvent_ControlPruneMeta) GetTopic() string

+ func (m *TraceEvent_ControlPruneMeta) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_ControlPruneMeta) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_ControlPruneMeta) Reset()

+ func (m *TraceEvent_ControlPruneMeta) Size() (n int)

+ func (m *TraceEvent_ControlPruneMeta) String() string

+ func (m *TraceEvent_ControlPruneMeta) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_ControlPruneMeta) XXX_DiscardUnknown()

+ func (m *TraceEvent_ControlPruneMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_ControlPruneMeta) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_ControlPruneMeta) XXX_Size() int

+ func (m *TraceEvent_ControlPruneMeta) XXX_Unmarshal(b []byte) error

+ type TraceEvent_DeliverMessage struct

+ MessageID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_DeliverMessage) Descriptor() ([]byte, []int)

+ func (*TraceEvent_DeliverMessage) ProtoMessage()

+ func (m *TraceEvent_DeliverMessage) GetMessageID() []byte

+ func (m *TraceEvent_DeliverMessage) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_DeliverMessage) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_DeliverMessage) Reset()

+ func (m *TraceEvent_DeliverMessage) Size() (n int)

+ func (m *TraceEvent_DeliverMessage) String() string

+ func (m *TraceEvent_DeliverMessage) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_DeliverMessage) XXX_DiscardUnknown()

+ func (m *TraceEvent_DeliverMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_DeliverMessage) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_DeliverMessage) XXX_Size() int

+ func (m *TraceEvent_DeliverMessage) XXX_Unmarshal(b []byte) error

+ type TraceEvent_DropRPC struct

+ Meta *TraceEvent_RPCMeta

+ SendTo []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_DropRPC) Descriptor() ([]byte, []int)

+ func (*TraceEvent_DropRPC) ProtoMessage()

+ func (m *TraceEvent_DropRPC) GetMeta() *TraceEvent_RPCMeta

+ func (m *TraceEvent_DropRPC) GetSendTo() []byte

+ func (m *TraceEvent_DropRPC) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_DropRPC) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_DropRPC) Reset()

+ func (m *TraceEvent_DropRPC) Size() (n int)

+ func (m *TraceEvent_DropRPC) String() string

+ func (m *TraceEvent_DropRPC) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_DropRPC) XXX_DiscardUnknown()

+ func (m *TraceEvent_DropRPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_DropRPC) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_DropRPC) XXX_Size() int

+ func (m *TraceEvent_DropRPC) XXX_Unmarshal(b []byte) error

+ type TraceEvent_DuplicateMessage struct

+ MessageID []byte

+ ReceivedFrom []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_DuplicateMessage) Descriptor() ([]byte, []int)

+ func (*TraceEvent_DuplicateMessage) ProtoMessage()

+ func (m *TraceEvent_DuplicateMessage) GetMessageID() []byte

+ func (m *TraceEvent_DuplicateMessage) GetReceivedFrom() []byte

+ func (m *TraceEvent_DuplicateMessage) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_DuplicateMessage) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_DuplicateMessage) Reset()

+ func (m *TraceEvent_DuplicateMessage) Size() (n int)

+ func (m *TraceEvent_DuplicateMessage) String() string

+ func (m *TraceEvent_DuplicateMessage) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_DuplicateMessage) XXX_DiscardUnknown()

+ func (m *TraceEvent_DuplicateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_DuplicateMessage) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_DuplicateMessage) XXX_Size() int

+ func (m *TraceEvent_DuplicateMessage) XXX_Unmarshal(b []byte) error

+ type TraceEvent_Graft struct

+ PeerID []byte

+ Topic *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_Graft) Descriptor() ([]byte, []int)

+ func (*TraceEvent_Graft) ProtoMessage()

+ func (m *TraceEvent_Graft) GetPeerID() []byte

+ func (m *TraceEvent_Graft) GetTopic() string

+ func (m *TraceEvent_Graft) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_Graft) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_Graft) Reset()

+ func (m *TraceEvent_Graft) Size() (n int)

+ func (m *TraceEvent_Graft) String() string

+ func (m *TraceEvent_Graft) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_Graft) XXX_DiscardUnknown()

+ func (m *TraceEvent_Graft) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_Graft) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_Graft) XXX_Size() int

+ func (m *TraceEvent_Graft) XXX_Unmarshal(b []byte) error

+ type TraceEvent_Join struct

+ Topic *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_Join) Descriptor() ([]byte, []int)

+ func (*TraceEvent_Join) ProtoMessage()

+ func (m *TraceEvent_Join) GetTopic() string

+ func (m *TraceEvent_Join) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_Join) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_Join) Reset()

+ func (m *TraceEvent_Join) Size() (n int)

+ func (m *TraceEvent_Join) String() string

+ func (m *TraceEvent_Join) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_Join) XXX_DiscardUnknown()

+ func (m *TraceEvent_Join) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_Join) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_Join) XXX_Size() int

+ func (m *TraceEvent_Join) XXX_Unmarshal(b []byte) error

+ type TraceEvent_Leave struct

+ Topic *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_Leave) Descriptor() ([]byte, []int)

+ func (*TraceEvent_Leave) ProtoMessage()

+ func (m *TraceEvent_Leave) GetTopic() string

+ func (m *TraceEvent_Leave) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_Leave) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_Leave) Reset()

+ func (m *TraceEvent_Leave) Size() (n int)

+ func (m *TraceEvent_Leave) String() string

+ func (m *TraceEvent_Leave) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_Leave) XXX_DiscardUnknown()

+ func (m *TraceEvent_Leave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_Leave) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_Leave) XXX_Size() int

+ func (m *TraceEvent_Leave) XXX_Unmarshal(b []byte) error

+ type TraceEvent_MessageMeta struct

+ MessageID []byte

+ Topics []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_MessageMeta) Descriptor() ([]byte, []int)

+ func (*TraceEvent_MessageMeta) ProtoMessage()

+ func (m *TraceEvent_MessageMeta) GetMessageID() []byte

+ func (m *TraceEvent_MessageMeta) GetTopics() []string

+ func (m *TraceEvent_MessageMeta) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_MessageMeta) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_MessageMeta) Reset()

+ func (m *TraceEvent_MessageMeta) Size() (n int)

+ func (m *TraceEvent_MessageMeta) String() string

+ func (m *TraceEvent_MessageMeta) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_MessageMeta) XXX_DiscardUnknown()

+ func (m *TraceEvent_MessageMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_MessageMeta) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_MessageMeta) XXX_Size() int

+ func (m *TraceEvent_MessageMeta) XXX_Unmarshal(b []byte) error

+ type TraceEvent_Prune struct

+ PeerID []byte

+ Topic *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_Prune) Descriptor() ([]byte, []int)

+ func (*TraceEvent_Prune) ProtoMessage()

+ func (m *TraceEvent_Prune) GetPeerID() []byte

+ func (m *TraceEvent_Prune) GetTopic() string

+ func (m *TraceEvent_Prune) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_Prune) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_Prune) Reset()

+ func (m *TraceEvent_Prune) Size() (n int)

+ func (m *TraceEvent_Prune) String() string

+ func (m *TraceEvent_Prune) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_Prune) XXX_DiscardUnknown()

+ func (m *TraceEvent_Prune) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_Prune) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_Prune) XXX_Size() int

+ func (m *TraceEvent_Prune) XXX_Unmarshal(b []byte) error

+ type TraceEvent_PublishMessage struct

+ MessageID []byte

+ Topics []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_PublishMessage) Descriptor() ([]byte, []int)

+ func (*TraceEvent_PublishMessage) ProtoMessage()

+ func (m *TraceEvent_PublishMessage) GetMessageID() []byte

+ func (m *TraceEvent_PublishMessage) GetTopics() []string

+ func (m *TraceEvent_PublishMessage) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_PublishMessage) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_PublishMessage) Reset()

+ func (m *TraceEvent_PublishMessage) Size() (n int)

+ func (m *TraceEvent_PublishMessage) String() string

+ func (m *TraceEvent_PublishMessage) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_PublishMessage) XXX_DiscardUnknown()

+ func (m *TraceEvent_PublishMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_PublishMessage) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_PublishMessage) XXX_Size() int

+ func (m *TraceEvent_PublishMessage) XXX_Unmarshal(b []byte) error

+ type TraceEvent_RPCMeta struct

+ Control *TraceEvent_ControlMeta

+ Messages []*TraceEvent_MessageMeta

+ Subscription []*TraceEvent_SubMeta

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_RPCMeta) Descriptor() ([]byte, []int)

+ func (*TraceEvent_RPCMeta) ProtoMessage()

+ func (m *TraceEvent_RPCMeta) GetControl() *TraceEvent_ControlMeta

+ func (m *TraceEvent_RPCMeta) GetMessages() []*TraceEvent_MessageMeta

+ func (m *TraceEvent_RPCMeta) GetSubscription() []*TraceEvent_SubMeta

+ func (m *TraceEvent_RPCMeta) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_RPCMeta) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_RPCMeta) Reset()

+ func (m *TraceEvent_RPCMeta) Size() (n int)

+ func (m *TraceEvent_RPCMeta) String() string

+ func (m *TraceEvent_RPCMeta) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_RPCMeta) XXX_DiscardUnknown()

+ func (m *TraceEvent_RPCMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_RPCMeta) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_RPCMeta) XXX_Size() int

+ func (m *TraceEvent_RPCMeta) XXX_Unmarshal(b []byte) error

+ type TraceEvent_RecvRPC struct

+ Meta *TraceEvent_RPCMeta

+ ReceivedFrom []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_RecvRPC) Descriptor() ([]byte, []int)

+ func (*TraceEvent_RecvRPC) ProtoMessage()

+ func (m *TraceEvent_RecvRPC) GetMeta() *TraceEvent_RPCMeta

+ func (m *TraceEvent_RecvRPC) GetReceivedFrom() []byte

+ func (m *TraceEvent_RecvRPC) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_RecvRPC) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_RecvRPC) Reset()

+ func (m *TraceEvent_RecvRPC) Size() (n int)

+ func (m *TraceEvent_RecvRPC) String() string

+ func (m *TraceEvent_RecvRPC) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_RecvRPC) XXX_DiscardUnknown()

+ func (m *TraceEvent_RecvRPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_RecvRPC) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_RecvRPC) XXX_Size() int

+ func (m *TraceEvent_RecvRPC) XXX_Unmarshal(b []byte) error

+ type TraceEvent_RejectMessage struct

+ MessageID []byte

+ Reason *string

+ ReceivedFrom []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_RejectMessage) Descriptor() ([]byte, []int)

+ func (*TraceEvent_RejectMessage) ProtoMessage()

+ func (m *TraceEvent_RejectMessage) GetMessageID() []byte

+ func (m *TraceEvent_RejectMessage) GetReason() string

+ func (m *TraceEvent_RejectMessage) GetReceivedFrom() []byte

+ func (m *TraceEvent_RejectMessage) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_RejectMessage) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_RejectMessage) Reset()

+ func (m *TraceEvent_RejectMessage) Size() (n int)

+ func (m *TraceEvent_RejectMessage) String() string

+ func (m *TraceEvent_RejectMessage) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_RejectMessage) XXX_DiscardUnknown()

+ func (m *TraceEvent_RejectMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_RejectMessage) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_RejectMessage) XXX_Size() int

+ func (m *TraceEvent_RejectMessage) XXX_Unmarshal(b []byte) error

+ type TraceEvent_RemovePeer struct

+ PeerID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_RemovePeer) Descriptor() ([]byte, []int)

+ func (*TraceEvent_RemovePeer) ProtoMessage()

+ func (m *TraceEvent_RemovePeer) GetPeerID() []byte

+ func (m *TraceEvent_RemovePeer) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_RemovePeer) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_RemovePeer) Reset()

+ func (m *TraceEvent_RemovePeer) Size() (n int)

+ func (m *TraceEvent_RemovePeer) String() string

+ func (m *TraceEvent_RemovePeer) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_RemovePeer) XXX_DiscardUnknown()

+ func (m *TraceEvent_RemovePeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_RemovePeer) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_RemovePeer) XXX_Size() int

+ func (m *TraceEvent_RemovePeer) XXX_Unmarshal(b []byte) error

+ type TraceEvent_SendRPC struct

+ Meta *TraceEvent_RPCMeta

+ SendTo []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_SendRPC) Descriptor() ([]byte, []int)

+ func (*TraceEvent_SendRPC) ProtoMessage()

+ func (m *TraceEvent_SendRPC) GetMeta() *TraceEvent_RPCMeta

+ func (m *TraceEvent_SendRPC) GetSendTo() []byte

+ func (m *TraceEvent_SendRPC) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_SendRPC) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_SendRPC) Reset()

+ func (m *TraceEvent_SendRPC) Size() (n int)

+ func (m *TraceEvent_SendRPC) String() string

+ func (m *TraceEvent_SendRPC) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_SendRPC) XXX_DiscardUnknown()

+ func (m *TraceEvent_SendRPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_SendRPC) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_SendRPC) XXX_Size() int

+ func (m *TraceEvent_SendRPC) XXX_Unmarshal(b []byte) error

+ type TraceEvent_SubMeta struct

+ Subscribe *bool

+ Topic *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceEvent_SubMeta) Descriptor() ([]byte, []int)

+ func (*TraceEvent_SubMeta) ProtoMessage()

+ func (m *TraceEvent_SubMeta) GetSubscribe() bool

+ func (m *TraceEvent_SubMeta) GetTopic() string

+ func (m *TraceEvent_SubMeta) Marshal() (dAtA []byte, err error)

+ func (m *TraceEvent_SubMeta) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceEvent_SubMeta) Reset()

+ func (m *TraceEvent_SubMeta) Size() (n int)

+ func (m *TraceEvent_SubMeta) String() string

+ func (m *TraceEvent_SubMeta) Unmarshal(dAtA []byte) error

+ func (m *TraceEvent_SubMeta) XXX_DiscardUnknown()

+ func (m *TraceEvent_SubMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TraceEvent_SubMeta) XXX_Merge(src proto.Message)

+ func (m *TraceEvent_SubMeta) XXX_Size() int

+ func (m *TraceEvent_SubMeta) XXX_Unmarshal(b []byte) error

+ type TraceEvent_Type int32

+ const TraceEvent_ADD_PEER

+ const TraceEvent_DELIVER_MESSAGE

+ const TraceEvent_DROP_RPC

+ const TraceEvent_DUPLICATE_MESSAGE

+ const TraceEvent_GRAFT

+ const TraceEvent_JOIN

+ const TraceEvent_LEAVE

+ const TraceEvent_PRUNE

+ const TraceEvent_PUBLISH_MESSAGE

+ const TraceEvent_RECV_RPC

+ const TraceEvent_REJECT_MESSAGE

+ const TraceEvent_REMOVE_PEER

+ const TraceEvent_SEND_RPC

+ func (TraceEvent_Type) EnumDescriptor() ([]byte, []int)

+ func (x *TraceEvent_Type) UnmarshalJSON(data []byte) error

+ func (x TraceEvent_Type) Enum() *TraceEvent_Type

+ func (x TraceEvent_Type) String() string

v0.2.2

Nov 15, 2019

v0.2.1

Nov 4, 2019

v0.2.0

Oct 31, 2019

v0.1.1

Aug 7, 2019

v0.1.0

May 26, 2019

v0.0.6

May 24, 2019

v0.0.5

May 22, 2019

v0.0.4

May 22, 2019

v0.0.3

May 15, 2019

v0.0.2

May 2, 2019

v0.0.1

Mar 2, 2019

Changes in this version

+ var ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")

+ var TopicDescriptor_AuthOpts_AuthMode_name = map[int32]string

+ var TopicDescriptor_AuthOpts_AuthMode_value = map[string]int32

+ var TopicDescriptor_EncOpts_EncMode_name = map[int32]string

+ var TopicDescriptor_EncOpts_EncMode_value = map[string]int32

+ type ControlGraft struct

+ TopicID *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ControlGraft) Descriptor() ([]byte, []int)

+ func (*ControlGraft) ProtoMessage()

+ func (m *ControlGraft) GetTopicID() string

+ func (m *ControlGraft) Marshal() (dAtA []byte, err error)

+ func (m *ControlGraft) MarshalTo(dAtA []byte) (int, error)

+ func (m *ControlGraft) Reset()

+ func (m *ControlGraft) Size() (n int)

+ func (m *ControlGraft) String() string

+ func (m *ControlGraft) Unmarshal(dAtA []byte) error

+ func (m *ControlGraft) XXX_DiscardUnknown()

+ func (m *ControlGraft) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ControlGraft) XXX_Merge(src proto.Message)

+ func (m *ControlGraft) XXX_Size() int

+ func (m *ControlGraft) XXX_Unmarshal(b []byte) error

+ type ControlIHave struct

+ MessageIDs []string

+ TopicID *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ControlIHave) Descriptor() ([]byte, []int)

+ func (*ControlIHave) ProtoMessage()

+ func (m *ControlIHave) GetMessageIDs() []string

+ func (m *ControlIHave) GetTopicID() string

+ func (m *ControlIHave) Marshal() (dAtA []byte, err error)

+ func (m *ControlIHave) MarshalTo(dAtA []byte) (int, error)

+ func (m *ControlIHave) Reset()

+ func (m *ControlIHave) Size() (n int)

+ func (m *ControlIHave) String() string

+ func (m *ControlIHave) Unmarshal(dAtA []byte) error

+ func (m *ControlIHave) XXX_DiscardUnknown()

+ func (m *ControlIHave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ControlIHave) XXX_Merge(src proto.Message)

+ func (m *ControlIHave) XXX_Size() int

+ func (m *ControlIHave) XXX_Unmarshal(b []byte) error

+ type ControlIWant struct

+ MessageIDs []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ControlIWant) Descriptor() ([]byte, []int)

+ func (*ControlIWant) ProtoMessage()

+ func (m *ControlIWant) GetMessageIDs() []string

+ func (m *ControlIWant) Marshal() (dAtA []byte, err error)

+ func (m *ControlIWant) MarshalTo(dAtA []byte) (int, error)

+ func (m *ControlIWant) Reset()

+ func (m *ControlIWant) Size() (n int)

+ func (m *ControlIWant) String() string

+ func (m *ControlIWant) Unmarshal(dAtA []byte) error

+ func (m *ControlIWant) XXX_DiscardUnknown()

+ func (m *ControlIWant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ControlIWant) XXX_Merge(src proto.Message)

+ func (m *ControlIWant) XXX_Size() int

+ func (m *ControlIWant) XXX_Unmarshal(b []byte) error

+ type ControlMessage struct

+ Graft []*ControlGraft

+ Ihave []*ControlIHave

+ Iwant []*ControlIWant

+ Prune []*ControlPrune

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ControlMessage) Descriptor() ([]byte, []int)

+ func (*ControlMessage) ProtoMessage()

+ func (m *ControlMessage) GetGraft() []*ControlGraft

+ func (m *ControlMessage) GetIhave() []*ControlIHave

+ func (m *ControlMessage) GetIwant() []*ControlIWant

+ func (m *ControlMessage) GetPrune() []*ControlPrune

+ func (m *ControlMessage) Marshal() (dAtA []byte, err error)

+ func (m *ControlMessage) MarshalTo(dAtA []byte) (int, error)

+ func (m *ControlMessage) Reset()

+ func (m *ControlMessage) Size() (n int)

+ func (m *ControlMessage) String() string

+ func (m *ControlMessage) Unmarshal(dAtA []byte) error

+ func (m *ControlMessage) XXX_DiscardUnknown()

+ func (m *ControlMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ControlMessage) XXX_Merge(src proto.Message)

+ func (m *ControlMessage) XXX_Size() int

+ func (m *ControlMessage) XXX_Unmarshal(b []byte) error

+ type ControlPrune struct

+ TopicID *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ControlPrune) Descriptor() ([]byte, []int)

+ func (*ControlPrune) ProtoMessage()

+ func (m *ControlPrune) GetTopicID() string

+ func (m *ControlPrune) Marshal() (dAtA []byte, err error)

+ func (m *ControlPrune) MarshalTo(dAtA []byte) (int, error)

+ func (m *ControlPrune) Reset()

+ func (m *ControlPrune) Size() (n int)

+ func (m *ControlPrune) String() string

+ func (m *ControlPrune) Unmarshal(dAtA []byte) error

+ func (m *ControlPrune) XXX_DiscardUnknown()

+ func (m *ControlPrune) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ControlPrune) XXX_Merge(src proto.Message)

+ func (m *ControlPrune) XXX_Size() int

+ func (m *ControlPrune) XXX_Unmarshal(b []byte) error

+ type Message struct

+ Data []byte

+ From []byte

+ Key []byte

+ Seqno []byte

+ Signature []byte

+ TopicIDs []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Message) Descriptor() ([]byte, []int)

+ func (*Message) ProtoMessage()

+ func (m *Message) GetData() []byte

+ func (m *Message) GetFrom() []byte

+ func (m *Message) GetKey() []byte

+ func (m *Message) GetSeqno() []byte

+ func (m *Message) GetSignature() []byte

+ func (m *Message) GetTopicIDs() []string

+ func (m *Message) Marshal() (dAtA []byte, err error)

+ func (m *Message) MarshalTo(dAtA []byte) (int, error)

+ func (m *Message) Reset()

+ func (m *Message) Size() (n int)

+ func (m *Message) String() string

+ func (m *Message) Unmarshal(dAtA []byte) error

+ func (m *Message) XXX_DiscardUnknown()

+ func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Message) XXX_Merge(src proto.Message)

+ func (m *Message) XXX_Size() int

+ func (m *Message) XXX_Unmarshal(b []byte) error

+ type RPC struct

+ Control *ControlMessage

+ Publish []*Message

+ Subscriptions []*RPC_SubOpts

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RPC) Descriptor() ([]byte, []int)

+ func (*RPC) ProtoMessage()

+ func (m *RPC) GetControl() *ControlMessage

+ func (m *RPC) GetPublish() []*Message

+ func (m *RPC) GetSubscriptions() []*RPC_SubOpts

+ func (m *RPC) Marshal() (dAtA []byte, err error)

+ func (m *RPC) MarshalTo(dAtA []byte) (int, error)

+ func (m *RPC) Reset()

+ func (m *RPC) Size() (n int)

+ func (m *RPC) String() string

+ func (m *RPC) Unmarshal(dAtA []byte) error

+ func (m *RPC) XXX_DiscardUnknown()

+ func (m *RPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RPC) XXX_Merge(src proto.Message)

+ func (m *RPC) XXX_Size() int

+ func (m *RPC) XXX_Unmarshal(b []byte) error

+ type RPC_SubOpts struct

+ Subscribe *bool

+ Topicid *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RPC_SubOpts) Descriptor() ([]byte, []int)

+ func (*RPC_SubOpts) ProtoMessage()

+ func (m *RPC_SubOpts) GetSubscribe() bool

+ func (m *RPC_SubOpts) GetTopicid() string

+ func (m *RPC_SubOpts) Marshal() (dAtA []byte, err error)

+ func (m *RPC_SubOpts) MarshalTo(dAtA []byte) (int, error)

+ func (m *RPC_SubOpts) Reset()

+ func (m *RPC_SubOpts) Size() (n int)

+ func (m *RPC_SubOpts) String() string

+ func (m *RPC_SubOpts) Unmarshal(dAtA []byte) error

+ func (m *RPC_SubOpts) XXX_DiscardUnknown()

+ func (m *RPC_SubOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RPC_SubOpts) XXX_Merge(src proto.Message)

+ func (m *RPC_SubOpts) XXX_Size() int

+ func (m *RPC_SubOpts) XXX_Unmarshal(b []byte) error

+ type TopicDescriptor struct

+ Auth *TopicDescriptor_AuthOpts

+ Enc *TopicDescriptor_EncOpts

+ Name *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TopicDescriptor) Descriptor() ([]byte, []int)

+ func (*TopicDescriptor) ProtoMessage()

+ func (m *TopicDescriptor) GetAuth() *TopicDescriptor_AuthOpts

+ func (m *TopicDescriptor) GetEnc() *TopicDescriptor_EncOpts

+ func (m *TopicDescriptor) GetName() string

+ func (m *TopicDescriptor) Marshal() (dAtA []byte, err error)

+ func (m *TopicDescriptor) MarshalTo(dAtA []byte) (int, error)

+ func (m *TopicDescriptor) Reset()

+ func (m *TopicDescriptor) Size() (n int)

+ func (m *TopicDescriptor) String() string

+ func (m *TopicDescriptor) Unmarshal(dAtA []byte) error

+ func (m *TopicDescriptor) XXX_DiscardUnknown()

+ func (m *TopicDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TopicDescriptor) XXX_Merge(src proto.Message)

+ func (m *TopicDescriptor) XXX_Size() int

+ func (m *TopicDescriptor) XXX_Unmarshal(b []byte) error

+ type TopicDescriptor_AuthOpts struct

+ Keys [][]byte

+ Mode *TopicDescriptor_AuthOpts_AuthMode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TopicDescriptor_AuthOpts) Descriptor() ([]byte, []int)

+ func (*TopicDescriptor_AuthOpts) ProtoMessage()

+ func (m *TopicDescriptor_AuthOpts) GetKeys() [][]byte

+ func (m *TopicDescriptor_AuthOpts) GetMode() TopicDescriptor_AuthOpts_AuthMode

+ func (m *TopicDescriptor_AuthOpts) Marshal() (dAtA []byte, err error)

+ func (m *TopicDescriptor_AuthOpts) MarshalTo(dAtA []byte) (int, error)

+ func (m *TopicDescriptor_AuthOpts) Reset()

+ func (m *TopicDescriptor_AuthOpts) Size() (n int)

+ func (m *TopicDescriptor_AuthOpts) String() string

+ func (m *TopicDescriptor_AuthOpts) Unmarshal(dAtA []byte) error

+ func (m *TopicDescriptor_AuthOpts) XXX_DiscardUnknown()

+ func (m *TopicDescriptor_AuthOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TopicDescriptor_AuthOpts) XXX_Merge(src proto.Message)

+ func (m *TopicDescriptor_AuthOpts) XXX_Size() int

+ func (m *TopicDescriptor_AuthOpts) XXX_Unmarshal(b []byte) error

+ type TopicDescriptor_AuthOpts_AuthMode int32

+ const TopicDescriptor_AuthOpts_KEY

+ const TopicDescriptor_AuthOpts_NONE

+ const TopicDescriptor_AuthOpts_WOT

+ func (TopicDescriptor_AuthOpts_AuthMode) EnumDescriptor() ([]byte, []int)

+ func (x *TopicDescriptor_AuthOpts_AuthMode) UnmarshalJSON(data []byte) error

+ func (x TopicDescriptor_AuthOpts_AuthMode) Enum() *TopicDescriptor_AuthOpts_AuthMode

+ func (x TopicDescriptor_AuthOpts_AuthMode) String() string

+ type TopicDescriptor_EncOpts struct

+ KeyHashes [][]byte

+ Mode *TopicDescriptor_EncOpts_EncMode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TopicDescriptor_EncOpts) Descriptor() ([]byte, []int)

+ func (*TopicDescriptor_EncOpts) ProtoMessage()

+ func (m *TopicDescriptor_EncOpts) GetKeyHashes() [][]byte

+ func (m *TopicDescriptor_EncOpts) GetMode() TopicDescriptor_EncOpts_EncMode

+ func (m *TopicDescriptor_EncOpts) Marshal() (dAtA []byte, err error)

+ func (m *TopicDescriptor_EncOpts) MarshalTo(dAtA []byte) (int, error)

+ func (m *TopicDescriptor_EncOpts) Reset()

+ func (m *TopicDescriptor_EncOpts) Size() (n int)

+ func (m *TopicDescriptor_EncOpts) String() string

+ func (m *TopicDescriptor_EncOpts) Unmarshal(dAtA []byte) error

+ func (m *TopicDescriptor_EncOpts) XXX_DiscardUnknown()

+ func (m *TopicDescriptor_EncOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TopicDescriptor_EncOpts) XXX_Merge(src proto.Message)

+ func (m *TopicDescriptor_EncOpts) XXX_Size() int

+ func (m *TopicDescriptor_EncOpts) XXX_Unmarshal(b []byte) error

+ type TopicDescriptor_EncOpts_EncMode int32

+ const TopicDescriptor_EncOpts_NONE

+ const TopicDescriptor_EncOpts_SHAREDKEY

+ const TopicDescriptor_EncOpts_WOT

+ func (TopicDescriptor_EncOpts_EncMode) EnumDescriptor() ([]byte, []int)

+ func (x *TopicDescriptor_EncOpts_EncMode) UnmarshalJSON(data []byte) error

+ func (x TopicDescriptor_EncOpts_EncMode) Enum() *TopicDescriptor_EncOpts_EncMode

+ func (x TopicDescriptor_EncOpts_EncMode) String() string

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