Versions in this module Expand all Collapse all v0 v0.1.5 Oct 2, 2024 v0.1.4 Sep 27, 2024 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 ErrUnexpectedEndOfGroupTrace = fmt.Errorf("proto: unexpected end of group") + 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 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 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 + Idontwant []*ControlIDontWant + 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) GetIdontwant() []*ControlIDontWant + 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 + Seqno []byte + Signature []byte + Topic *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) GetTopic() 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 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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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_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_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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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 + Idontwant []*TraceEvent_ControlIDontWantMeta + 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) GetIdontwant() []*TraceEvent_ControlIDontWantMeta + 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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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 + ReceivedFrom []byte + Topic *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) GetReceivedFrom() []byte + func (m *TraceEvent_DeliverMessage) GetTopic() string + func (m *TraceEvent_DeliverMessage) Marshal() (dAtA []byte, err error) + func (m *TraceEvent_DeliverMessage) MarshalTo(dAtA []byte) (int, error) + func (m *TraceEvent_DeliverMessage) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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 + Topic *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) GetTopic() string + func (m *TraceEvent_DuplicateMessage) Marshal() (dAtA []byte, err error) + func (m *TraceEvent_DuplicateMessage) MarshalTo(dAtA []byte) (int, error) + func (m *TraceEvent_DuplicateMessage) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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 + Topic *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) GetTopic() string + func (m *TraceEvent_MessageMeta) Marshal() (dAtA []byte, err error) + func (m *TraceEvent_MessageMeta) MarshalTo(dAtA []byte) (int, error) + func (m *TraceEvent_MessageMeta) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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 + Topic *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) GetTopic() string + func (m *TraceEvent_PublishMessage) Marshal() (dAtA []byte, err error) + func (m *TraceEvent_PublishMessage) MarshalTo(dAtA []byte) (int, error) + func (m *TraceEvent_PublishMessage) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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 + Topic *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) GetTopic() string + func (m *TraceEvent_RejectMessage) Marshal() (dAtA []byte, err error) + func (m *TraceEvent_RejectMessage) MarshalTo(dAtA []byte) (int, error) + func (m *TraceEvent_RejectMessage) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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
Go to main page