Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pubsub_pb

package

Go to main page

Versions in this module

v1

v1.3.1

Dec 26, 2023

v1.3.0

Dec 23, 2022

v1.1.5

Jun 25, 2024

v1.1.4

Mar 29, 2024

v1.1.3

Sep 5, 2022

v1.1.2

May 17, 2022

v1.1.1

Apr 19, 2022

v1.1.0

Mar 15, 2022

v1.0.0

Aug 26, 2021

v0

v0.0.3

Aug 26, 2021

Changes in this version

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

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

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

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

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

+ 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

+ var TraceEvent_Type_name = map[int32]string

+ var TraceEvent_Type_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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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

+ Backoff *uint64

+ Peers []*PeerInfo

+ TopicID *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ControlPrune) ProtoMessage()

+ func (m *ControlPrune) GetBackoff() uint64

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

+ func (m *ControlPrune) GetTopicID() string

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

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

+ func (m *ControlPrune) MarshalToSizedBuffer(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

+ PubsubUid *string

+ 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) GetPubsubUid() string

+ 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) MarshalToSizedBuffer(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 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) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PeerInfo) Reset()

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

+ func (m *PeerInfo) String() string

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

+ func (m *PeerInfo) XXX_DiscardUnknown()

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

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

+ func (m *PeerInfo) XXX_Size() int

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

+ 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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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

+ 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

+ Peers [][]byte

+ 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) GetPeers() [][]byte

+ 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

+ Topics []string

+ 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) GetTopics() []string

+ 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

+ Topics []string

+ 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) GetTopics() []string

+ 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

+ Topics []string

+ 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) GetTopics() []string

+ 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