pubsub_pb

Aug 16, 2024

Changes in this version

+ type ControlIDontWant struct

+ MessageIDs []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ControlIDontWant) ProtoMessage()

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

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

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

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

+ func (m *ControlIDontWant) Reset()

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

+ func (m *ControlIDontWant) String() string

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

+ func (m *ControlIDontWant) XXX_DiscardUnknown()

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

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

+ func (m *ControlIDontWant) XXX_Size() int

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

type ControlMessage

+ Idontwant []*ControlIDontWant

+ func (m *ControlMessage) GetIdontwant() []*ControlIDontWant

+ type TraceEvent_ControlIDontWantMeta struct

+ MessageIDs [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TraceEvent_ControlIDontWantMeta) ProtoMessage()

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

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

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

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

+ func (m *TraceEvent_ControlIDontWantMeta) Reset()

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

+ func (m *TraceEvent_ControlIDontWantMeta) String() string

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

+ func (m *TraceEvent_ControlIDontWantMeta) XXX_DiscardUnknown()

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

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

+ func (m *TraceEvent_ControlIDontWantMeta) XXX_Size() int

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

type TraceEvent_ControlMeta

+ Idontwant []*TraceEvent_ControlIDontWantMeta

+ func (m *TraceEvent_ControlMeta) GetIdontwant() []*TraceEvent_ControlIDontWantMeta

Jan 12, 2021

Changes in this version

type TraceEvent_DeliverMessage

+ ReceivedFrom []byte

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

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

Aug 25, 2020

Changes in this version

type PeerInfo

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

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

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

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)

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

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