status-im
/
go-libp2p-pubsub
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

some minor fixes in trace pb

This commit is contained in:
vyzo 2019-11-11 19:25:35 +02:00
parent 0a25f248ea
commit 040cabe3b0
2 changed files with 125 additions and 124 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

241
pb/trace.pb.go
View File

@ -33,7 +33,7 @@ const (
TraceEvent_SEND_RPC TraceEvent_Type = 7
TraceEvent_DROP_RPC TraceEvent_Type = 8
TraceEvent_JOIN TraceEvent_Type = 9
TraceEvent_LEAE TraceEvent_Type = 10
TraceEvent_LEAVE TraceEvent_Type = 10
TraceEvent_GRAFT TraceEvent_Type = 11
TraceEvent_PRUNE TraceEvent_Type = 12
)
@ -49,7 +49,7 @@ var TraceEvent_Type_name = map[int32]string{
7: "SEND_RPC",
8: "DROP_RPC",
9: "JOIN",
10: "LEAE",
10: "LEAVE",
11: "GRAFT",
12: "PRUNE",
}
@ -64,7 +64,7 @@ var TraceEvent_Type_value = map[string]int32{
"SEND_RPC": 7,
"DROP_RPC": 8,
"JOIN": 9,
"LEAE": 10,
"LEAVE": 10,
"GRAFT": 11,
"PRUNE": 12,
}
@ -86,13 +86,13 @@ func (x *TraceEvent_Type) UnmarshalJSON(data []byte) error {
return nil
}
func (TraceEvent_Type) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 0}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 0}
}
type TraceEvent struct {
Type *TraceEvent_Type `protobuf:"varint,1,opt,name=type,enum=pubsub.pb.TraceEvent_Type" json:"type,omitempty"`
PeerID []byte `protobuf:"bytes,2,opt,name=peerID" json:"peerID,omitempty"`
Timestap *uint64 `protobuf:"varint,3,opt,name=timestap" json:"timestap,omitempty"`
Timestamp *int64 `protobuf:"varint,3,opt,name=timestamp" json:"timestamp,omitempty"`
PublishMessage *TraceEvent_PublishMessage `protobuf:"bytes,4,opt,name=publishMessage" json:"publishMessage,omitempty"`
RejectMessage *TraceEvent_RejectMessage `protobuf:"bytes,5,opt,name=rejectMessage" json:"rejectMessage,omitempty"`
DuplicateMessage *TraceEvent_DuplicateMessage `protobuf:"bytes,6,opt,name=duplicateMessage" json:"duplicateMessage,omitempty"`
@ -115,7 +115,7 @@ func (m *TraceEvent) Reset() { *m = TraceEvent{} }
func (m *TraceEvent) String() string { return proto.CompactTextString(m) }
func (*TraceEvent) ProtoMessage() {}
func (*TraceEvent) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0}
return fileDescriptor_trace_31b365b8afda32be, []int{0}
}
func (m *TraceEvent) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -158,9 +158,9 @@ func (m *TraceEvent) GetPeerID() []byte {
return nil
}
func (m *TraceEvent) GetTimestap() uint64 {
if m != nil && m.Timestap != nil {
return *m.Timestap
func (m *TraceEvent) GetTimestamp() int64 {
if m != nil && m.Timestamp != nil {
return *m.Timestamp
}
return 0
}
@ -267,7 +267,7 @@ func (m *TraceEvent_PublishMessage) Reset() { *m = TraceEvent_PublishMes
func (m *TraceEvent_PublishMessage) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_PublishMessage) ProtoMessage() {}
func (*TraceEvent_PublishMessage) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 0}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 0}
}
func (m *TraceEvent_PublishMessage) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -316,7 +316,7 @@ func (m *TraceEvent_RejectMessage) Reset() { *m = TraceEvent_RejectMessa
func (m *TraceEvent_RejectMessage) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_RejectMessage) ProtoMessage() {}
func (*TraceEvent_RejectMessage) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 1}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 1}
}
func (m *TraceEvent_RejectMessage) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -378,7 +378,7 @@ func (m *TraceEvent_DuplicateMessage) Reset() { *m = TraceEvent_Duplicat
func (m *TraceEvent_DuplicateMessage) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_DuplicateMessage) ProtoMessage() {}
func (*TraceEvent_DuplicateMessage) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 2}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 2}
}
func (m *TraceEvent_DuplicateMessage) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -432,7 +432,7 @@ func (m *TraceEvent_DeliverMessage) Reset() { *m = TraceEvent_DeliverMes
func (m *TraceEvent_DeliverMessage) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_DeliverMessage) ProtoMessage() {}
func (*TraceEvent_DeliverMessage) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 3}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 3}
}
func (m *TraceEvent_DeliverMessage) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -480,7 +480,7 @@ func (m *TraceEvent_AddPeer) Reset() { *m = TraceEvent_AddPeer{} }
func (m *TraceEvent_AddPeer) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_AddPeer) ProtoMessage() {}
func (*TraceEvent_AddPeer) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 4}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 4}
}
func (m *TraceEvent_AddPeer) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -534,7 +534,7 @@ func (m *TraceEvent_RemovePeer) Reset() { *m = TraceEvent_RemovePeer{} }
func (m *TraceEvent_RemovePeer) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_RemovePeer) ProtoMessage() {}
func (*TraceEvent_RemovePeer) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 5}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 5}
}
func (m *TraceEvent_RemovePeer) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -582,7 +582,7 @@ func (m *TraceEvent_RecvRPC) Reset() { *m = TraceEvent_RecvRPC{} }
func (m *TraceEvent_RecvRPC) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_RecvRPC) ProtoMessage() {}
func (*TraceEvent_RecvRPC) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 6}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 6}
}
func (m *TraceEvent_RecvRPC) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -637,7 +637,7 @@ func (m *TraceEvent_SendRPC) Reset() { *m = TraceEvent_SendRPC{} }
func (m *TraceEvent_SendRPC) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_SendRPC) ProtoMessage() {}
func (*TraceEvent_SendRPC) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 7}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 7}
}
func (m *TraceEvent_SendRPC) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -692,7 +692,7 @@ func (m *TraceEvent_DropRPC) Reset() { *m = TraceEvent_DropRPC{} }
func (m *TraceEvent_DropRPC) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_DropRPC) ProtoMessage() {}
func (*TraceEvent_DropRPC) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 8}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 8}
}
func (m *TraceEvent_DropRPC) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -746,7 +746,7 @@ func (m *TraceEvent_Join) Reset() { *m = TraceEvent_Join{} }
func (m *TraceEvent_Join) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_Join) ProtoMessage() {}
func (*TraceEvent_Join) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 9}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 9}
}
func (m *TraceEvent_Join) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -793,7 +793,7 @@ func (m *TraceEvent_Leave) Reset() { *m = TraceEvent_Leave{} }
func (m *TraceEvent_Leave) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_Leave) ProtoMessage() {}
func (*TraceEvent_Leave) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 10}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 10}
}
func (m *TraceEvent_Leave) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -841,7 +841,7 @@ func (m *TraceEvent_Graft) Reset() { *m = TraceEvent_Graft{} }
func (m *TraceEvent_Graft) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_Graft) ProtoMessage() {}
func (*TraceEvent_Graft) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 11}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 11}
}
func (m *TraceEvent_Graft) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -896,7 +896,7 @@ func (m *TraceEvent_Prune) Reset() { *m = TraceEvent_Prune{} }
func (m *TraceEvent_Prune) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_Prune) ProtoMessage() {}
func (*TraceEvent_Prune) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 12}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 12}
}
func (m *TraceEvent_Prune) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -941,8 +941,8 @@ func (m *TraceEvent_Prune) GetTopic() string {
type TraceEvent_RPCMeta struct {
MessageIDs [][]byte `protobuf:"bytes,1,rep,name=messageIDs" json:"messageIDs,omitempty"`
SubMeta []*TraceEvent_SubMeta `protobuf:"bytes,2,rep,name=subMeta" json:"subMeta,omitempty"`
ControlMeta *TraceEvent_ControlMeta `protobuf:"bytes,3,opt,name=controlMeta" json:"controlMeta,omitempty"`
Subscription []*TraceEvent_SubMeta `protobuf:"bytes,2,rep,name=subscription" json:"subscription,omitempty"`
Control *TraceEvent_ControlMeta `protobuf:"bytes,3,opt,name=control" json:"control,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
@ -952,7 +952,7 @@ func (m *TraceEvent_RPCMeta) Reset() { *m = TraceEvent_RPCMeta{} }
func (m *TraceEvent_RPCMeta) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_RPCMeta) ProtoMessage() {}
func (*TraceEvent_RPCMeta) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 13}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 13}
}
func (m *TraceEvent_RPCMeta) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -988,16 +988,16 @@ func (m *TraceEvent_RPCMeta) GetMessageIDs() [][]byte {
return nil
}
func (m *TraceEvent_RPCMeta) GetSubMeta() []*TraceEvent_SubMeta {
func (m *TraceEvent_RPCMeta) GetSubscription() []*TraceEvent_SubMeta {
if m != nil {
return m.SubMeta
return m.Subscription
}
return nil
}
func (m *TraceEvent_RPCMeta) GetControlMeta() *TraceEvent_ControlMeta {
func (m *TraceEvent_RPCMeta) GetControl() *TraceEvent_ControlMeta {
if m != nil {
return m.ControlMeta
return m.Control
}
return nil
}
@ -1014,7 +1014,7 @@ func (m *TraceEvent_SubMeta) Reset() { *m = TraceEvent_SubMeta{} }
func (m *TraceEvent_SubMeta) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_SubMeta) ProtoMessage() {}
func (*TraceEvent_SubMeta) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 14}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 14}
}
func (m *TraceEvent_SubMeta) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1071,7 +1071,7 @@ func (m *TraceEvent_ControlMeta) Reset() { *m = TraceEvent_ControlMeta{}
func (m *TraceEvent_ControlMeta) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_ControlMeta) ProtoMessage() {}
func (*TraceEvent_ControlMeta) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 15}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 15}
}
func (m *TraceEvent_ControlMeta) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1140,7 +1140,7 @@ func (m *TraceEvent_ControlIHaveMeta) Reset() { *m = TraceEvent_ControlI
func (m *TraceEvent_ControlIHaveMeta) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_ControlIHaveMeta) ProtoMessage() {}
func (*TraceEvent_ControlIHaveMeta) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 16}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 16}
}
func (m *TraceEvent_ControlIHaveMeta) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1194,7 +1194,7 @@ func (m *TraceEvent_ControlIWantMeta) Reset() { *m = TraceEvent_ControlI
func (m *TraceEvent_ControlIWantMeta) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_ControlIWantMeta) ProtoMessage() {}
func (*TraceEvent_ControlIWantMeta) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 17}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 17}
}
func (m *TraceEvent_ControlIWantMeta) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1241,7 +1241,7 @@ func (m *TraceEvent_ControlGraftMeta) Reset() { *m = TraceEvent_ControlG
func (m *TraceEvent_ControlGraftMeta) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_ControlGraftMeta) ProtoMessage() {}
func (*TraceEvent_ControlGraftMeta) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 18}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 18}
}
func (m *TraceEvent_ControlGraftMeta) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1288,7 +1288,7 @@ func (m *TraceEvent_ControlPruneMeta) Reset() { *m = TraceEvent_ControlP
func (m *TraceEvent_ControlPruneMeta) String() string { return proto.CompactTextString(m) }
func (*TraceEvent_ControlPruneMeta) ProtoMessage() {}
func (*TraceEvent_ControlPruneMeta) Descriptor() ([]byte, []int) {
return fileDescriptor_trace_c3fa177daeafa133, []int{0, 19}
return fileDescriptor_trace_31b365b8afda32be, []int{0, 19}
}
func (m *TraceEvent_ControlPruneMeta) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1374,10 +1374,10 @@ func (m *TraceEvent) MarshalTo(dAtA []byte) (int, error) {
i = encodeVarintTrace(dAtA, i, uint64(len(m.PeerID)))
i += copy(dAtA[i:], m.PeerID)
}
if m.Timestap != nil {
if m.Timestamp != nil {
dAtA[i] = 0x18
i++
i = encodeVarintTrace(dAtA, i, uint64(*m.Timestap))
i = encodeVarintTrace(dAtA, i, uint64(*m.Timestamp))
}
if m.PublishMessage != nil {
dAtA[i] = 0x22
@ -1957,8 +1957,8 @@ func (m *TraceEvent_RPCMeta) MarshalTo(dAtA []byte) (int, error) {
i += copy(dAtA[i:], b)
}
}
if len(m.SubMeta) > 0 {
for _, msg := range m.SubMeta {
if len(m.Subscription) > 0 {
for _, msg := range m.Subscription {
dAtA[i] = 0x12
i++
i = encodeVarintTrace(dAtA, i, uint64(msg.Size()))
@ -1969,11 +1969,11 @@ func (m *TraceEvent_RPCMeta) MarshalTo(dAtA []byte) (int, error) {
i += n
}
}
if m.ControlMeta != nil {
if m.Control != nil {
dAtA[i] = 0x1a
i++
i = encodeVarintTrace(dAtA, i, uint64(m.ControlMeta.Size()))
n17, err := m.ControlMeta.MarshalTo(dAtA[i:])
i = encodeVarintTrace(dAtA, i, uint64(m.Control.Size()))
n17, err := m.Control.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
@ -2231,8 +2231,8 @@ func (m *TraceEvent) Size() (n int) {
l = len(m.PeerID)
n += 1 + l + sovTrace(uint64(l))
}
if m.Timestap != nil {
n += 1 + sovTrace(uint64(*m.Timestap))
if m.Timestamp != nil {
n += 1 + sovTrace(uint64(*m.Timestamp))
}
if m.PublishMessage != nil {
l = m.PublishMessage.Size()
@ -2548,14 +2548,14 @@ func (m *TraceEvent_RPCMeta) Size() (n int) {
n += 1 + l + sovTrace(uint64(l))
}
}
if len(m.SubMeta) > 0 {
for _, e := range m.SubMeta {
if len(m.Subscription) > 0 {
for _, e := range m.Subscription {
l = e.Size()
n += 1 + l + sovTrace(uint64(l))
}
}
if m.ControlMeta != nil {
l = m.ControlMeta.Size()
if m.Control != nil {
l = m.Control.Size()
n += 1 + l + sovTrace(uint64(l))
}
if m.XXX_unrecognized != nil {
@ -2786,9 +2786,9 @@ func (m *TraceEvent) Unmarshal(dAtA []byte) error {
iNdEx = postIndex
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Timestap", wireType)
return fmt.Errorf("proto: wrong wireType = %d for field Timestamp", wireType)
}
var v uint64
var v int64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowTrace
@ -2798,12 +2798,12 @@ func (m *TraceEvent) Unmarshal(dAtA []byte) error {
}
b := dAtA[iNdEx]
iNdEx++
v |= (uint64(b) & 0x7F) << shift
v |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.Timestap = &v
m.Timestamp = &v
case 4:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PublishMessage", wireType)
@ -4660,7 +4660,7 @@ func (m *TraceEvent_RPCMeta) Unmarshal(dAtA []byte) error {
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field SubMeta", wireType)
return fmt.Errorf("proto: wrong wireType = %d for field Subscription", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
@ -4684,14 +4684,14 @@ func (m *TraceEvent_RPCMeta) Unmarshal(dAtA []byte) error {
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.SubMeta = append(m.SubMeta, &TraceEvent_SubMeta{})
if err := m.SubMeta[len(m.SubMeta)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
m.Subscription = append(m.Subscription, &TraceEvent_SubMeta{})
if err := m.Subscription[len(m.Subscription)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ControlMeta", wireType)
return fmt.Errorf("proto: wrong wireType = %d for field Control", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
@ -4715,10 +4715,10 @@ func (m *TraceEvent_RPCMeta) Unmarshal(dAtA []byte) error {
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.ControlMeta == nil {
m.ControlMeta = &TraceEvent_ControlMeta{}
if m.Control == nil {
m.Control = &TraceEvent_ControlMeta{}
}
if err := m.ControlMeta.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
if err := m.Control.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
@ -5478,66 +5478,67 @@ var (
ErrIntOverflowTrace = fmt.Errorf("proto: integer overflow")
)
func init() { proto.RegisterFile("trace.proto", fileDescriptor_trace_c3fa177daeafa133) }
func init() { proto.RegisterFile("trace.proto", fileDescriptor_trace_31b365b8afda32be) }
var fileDescriptor_trace_c3fa177daeafa133 = []byte{
// 922 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x96, 0xd1, 0x8e, 0xda, 0x46,
0x14, 0x86, 0x6b, 0x30, 0x0b, 0x1c, 0x58, 0xd6, 0x9d, 0xa6, 0x95, 0xe5, 0x26, 0x88, 0x6e, 0xa3,
0x88, 0x2b, 0xa4, 0xac, 0x54, 0xe5, 0x26, 0x95, 0x4a, 0xf0, 0x64, 0x97, 0x15, 0xec, 0x5a, 0x07,
0x76, 0x7b, 0xb9, 0x35, 0x30, 0x4d, 0x1c, 0x81, 0x6d, 0xd9, 0x86, 0x2a, 0x0f, 0xd0, 0x67, 0xe9,
0xab, 0xf4, 0xaa, 0xea, 0x23, 0x54, 0x7b, 0xd3, 0xd7, 0xa8, 0x66, 0xc6, 0x36, 0x98, 0x18, 0x6f,
0xda, 0xe6, 0xce, 0x67, 0xe6, 0xff, 0xce, 0xcc, 0x99, 0xfd, 0xcf, 0x59, 0xa0, 0x11, 0x05, 0xf6,
0x9c, 0xf5, 0xfc, 0xc0, 0x8b, 0x3c, 0x52, 0xf7, 0xd7, 0xb3, 0x70, 0x3d, 0xeb, 0xf9, 0xb3, 0xd3,
0xbf, 0x1f, 0x01, 0x4c, 0xf9, 0x16, 0xdd, 0x30, 0x37, 0x22, 0x3d, 0x50, 0xa3, 0xf7, 0x3e, 0xd3,
0x95, 0x8e, 0xd2, 0x6d, 0x9d, 0x19, 0xbd, 0x54, 0xd8, 0xdb, 0x8a, 0x7a, 0xd3, 0xf7, 0x3e, 0x43,
0xa1, 0x23, 0x5f, 0xc1, 0x91, 0xcf, 0x58, 0x30, 0x34, 0xf5, 0x52, 0x47, 0xe9, 0x36, 0x31, 0x8e,
0x88, 0x01, 0xb5, 0xc8, 0x59, 0xb1, 0x30, 0xb2, 0x7d, 0xbd, 0xdc, 0x51, 0xba, 0x2a, 0xa6, 0x31,
0x19, 0x41, 0xcb, 0x5f, 0xcf, 0x96, 0x4e, 0xf8, 0x76, 0xcc, 0xc2, 0xd0, 0x7e, 0xc3, 0x74, 0xb5,
0xa3, 0x74, 0x1b, 0x67, 0x4f, 0xf3, 0x4f, 0xb3, 0x32, 0x5a, 0xdc, 0x63, 0xc9, 0x10, 0x8e, 0x03,
0xf6, 0x8e, 0xcd, 0xa3, 0x24, 0x59, 0x45, 0x24, 0xfb, 0x36, 0x3f, 0x19, 0xee, 0x4a, 0x31, 0x4b,
0x12, 0x04, 0x6d, 0xb1, 0xf6, 0x97, 0xce, 0xdc, 0x8e, 0x58, 0x92, 0xed, 0x48, 0x64, 0x7b, 0x96,
0x9f, 0xcd, 0xdc, 0x53, 0xe3, 0x07, 0x3c, 0x2f, 0x76, 0xc1, 0x96, 0xce, 0x86, 0x05, 0x49, 0xc6,
0x6a, 0x51, 0xb1, 0x66, 0x46, 0x8b, 0x7b, 0x2c, 0x79, 0x01, 0x55, 0x7b, 0xb1, 0xb0, 0x18, 0x0b,
0xf4, 0x9a, 0x48, 0xf3, 0x24, 0x3f, 0x4d, 0x5f, 0x8a, 0x30, 0x51, 0x93, 0x1f, 0x00, 0x02, 0xb6,
0xf2, 0x36, 0x4c, 0xb0, 0x75, 0xc1, 0x76, 0x0e, 0x3d, 0x51, 0xa2, 0xc3, 0x1d, 0x86, 0x1f, 0x1d,
0xb0, 0xf9, 0x06, 0xad, 0x81, 0x0e, 0x45, 0x47, 0xa3, 0x14, 0x61, 0xa2, 0xe6, 0x60, 0xc8, 0xdc,
0x05, 0x07, 0x1b, 0x45, 0xe0, 0x44, 0x8a, 0x30, 0x51, 0x73, 0x70, 0x11, 0x78, 0x3e, 0x07, 0x9b,
0x45, 0xa0, 0x29, 0x45, 0x98, 0xa8, 0xb9, 0x89, 0xdf, 0x79, 0x8e, 0xab, 0x1f, 0x0b, 0xea, 0x80,
0x89, 0x2f, 0x3d, 0xc7, 0x45, 0xa1, 0x23, 0xcf, 0xa1, 0xb2, 0x64, 0xf6, 0x86, 0xe9, 0x2d, 0x01,
0x7c, 0x9d, 0x0f, 0x8c, 0xb8, 0x04, 0xa5, 0x92, 0x23, 0x6f, 0x02, 0xfb, 0xe7, 0x48, 0x3f, 0x29,
0x42, 0xce, 0xb9, 0x04, 0xa5, 0x92, 0x23, 0x7e, 0xb0, 0x76, 0x99, 0xae, 0x15, 0x21, 0x16, 0x97,
0xa0, 0x54, 0x1a, 0x3d, 0x68, 0x65, 0xdd, 0x4f, 0x1e, 0x43, 0x7d, 0x25, 0x3f, 0x87, 0xa6, 0x68,
0xd2, 0x26, 0x6e, 0x17, 0x0c, 0x07, 0x8e, 0x33, 0x06, 0x2f, 0x96, 0x93, 0x53, 0x68, 0x06, 0x6c,
0xce, 0x9c, 0x0d, 0x5b, 0xbc, 0x0e, 0xbc, 0x55, 0xdc, 0xc2, 0x99, 0x35, 0xde, 0xe0, 0x01, 0xb3,
0x43, 0xcf, 0x15, 0x6d, 0x5c, 0xc7, 0x38, 0x32, 0xa6, 0xa0, 0xed, 0xbb, 0xff, 0xff, 0x9f, 0xc6,
0x0b, 0xce, 0x76, 0xc0, 0x03, 0x05, 0xbf, 0x80, 0x6a, 0x6c, 0xf5, 0x9d, 0x49, 0xa4, 0x64, 0x26,
0xd1, 0x23, 0xfe, 0xec, 0x5e, 0xe4, 0x89, 0xf3, 0xea, 0x28, 0x03, 0xe3, 0x29, 0xc0, 0xd6, 0xe7,
0x87, 0x58, 0xe3, 0x27, 0xa8, 0xc6, 0x76, 0xfe, 0xe0, 0xf6, 0x4a, 0xce, 0x5b, 0x3d, 0x07, 0x75,
0xc5, 0x22, 0x5b, 0x9c, 0x74, 0xb8, 0x3f, 0xac, 0xc1, 0x98, 0x45, 0x36, 0x0a, 0xa9, 0x31, 0x85,
0x6a, 0xec, 0x7b, 0x7e, 0x09, 0xee, 0xfc, 0xa9, 0x97, 0x5c, 0x42, 0x46, 0xff, 0x31, 0x6b, 0xdc,
0x14, 0x9f, 0x32, 0xeb, 0x63, 0x50, 0x79, 0xd3, 0xf0, 0x17, 0x8d, 0x3c, 0xdf, 0x99, 0x8b, 0x8c,
0x75, 0x94, 0x81, 0xf1, 0x04, 0x2a, 0xa2, 0x43, 0xb6, 0xdb, 0xa5, 0xdd, 0xed, 0xef, 0xa0, 0x22,
0xba, 0xa1, 0xe8, 0xef, 0x94, 0x8f, 0x89, 0x8e, 0xf8, 0x97, 0xd8, 0x6f, 0x0a, 0x54, 0xe3, 0xcb,
0x93, 0x36, 0x40, 0x6a, 0x98, 0x50, 0x57, 0x3a, 0xe5, 0x6e, 0x13, 0x77, 0x56, 0xc4, 0x7c, 0x5a,
0xcf, 0xc6, 0xf2, 0x31, 0xca, 0x05, 0xf3, 0x49, 0x8a, 0x30, 0x51, 0x93, 0x01, 0x34, 0xe6, 0x9e,
0x1b, 0x05, 0xde, 0x52, 0xc0, 0x65, 0xf1, 0x92, 0xdf, 0xe4, 0xc3, 0x83, 0xad, 0x10, 0x77, 0x29,
0xe3, 0x7b, 0xa8, 0xc6, 0x89, 0xb9, 0xd5, 0xc3, 0xf5, 0x2c, 0x9c, 0x07, 0xce, 0x4c, 0xfe, 0x03,
0xae, 0xe1, 0x76, 0xe1, 0x40, 0xa1, 0xbf, 0x96, 0xa0, 0xb1, 0x93, 0x9b, 0xbc, 0x84, 0x8a, 0xf3,
0x96, 0x8f, 0x32, 0x45, 0x94, 0xf2, 0xac, 0xf0, 0x36, 0xc3, 0x0b, 0x7b, 0xc3, 0xc4, 0x95, 0x24,
0x24, 0xe8, 0x5f, 0x6c, 0x37, 0x8a, 0x1f, 0xe2, 0x01, 0xfa, 0x47, 0xdb, 0x8d, 0x62, 0x9a, 0x43,
0x9c, 0x96, 0x33, 0xb1, 0xfc, 0x11, 0xb4, 0x30, 0x83, 0xa4, 0xe5, 0x78, 0x7c, 0x99, 0x8c, 0x47,
0xf5, 0x23, 0x68, 0xe1, 0x09, 0x49, 0xcb, 0x49, 0x79, 0x01, 0xda, 0x7e, 0x51, 0xf9, 0x3e, 0xdd,
0xb3, 0x43, 0x69, 0xdf, 0x0e, 0xc6, 0xd9, 0x36, 0x53, 0x52, 0xe0, 0x43, 0x16, 0x32, 0xba, 0x29,
0x93, 0x96, 0x75, 0xa0, 0x4b, 0xb6, 0xca, 0xb4, 0x84, 0x7c, 0xe5, 0xe9, 0x1f, 0x0a, 0xa8, 0xfc,
0x87, 0x16, 0xf9, 0x02, 0x4e, 0xac, 0x9b, 0x57, 0xa3, 0xe1, 0xe4, 0xe2, 0x6e, 0x4c, 0x27, 0x93,
0xfe, 0x39, 0xd5, 0x3e, 0x23, 0x04, 0x5a, 0x48, 0x2f, 0xe9, 0x60, 0x9a, 0xae, 0x29, 0xe4, 0x4b,
0xf8, 0xdc, 0xbc, 0xb1, 0x46, 0xc3, 0x41, 0x7f, 0x4a, 0xd3, 0xe5, 0x12, 0xe7, 0x4d, 0x3a, 0x1a,
0xde, 0x52, 0x4c, 0x17, 0xcb, 0xa4, 0x09, 0xb5, 0xbe, 0x69, 0xde, 0x59, 0x94, 0xa2, 0xa6, 0x92,
0x13, 0x68, 0x20, 0x1d, 0x5f, 0xdf, 0x52, 0xb9, 0x50, 0xe1, 0xdb, 0x48, 0x07, 0xb7, 0x77, 0x68,
0x0d, 0xb4, 0x23, 0x1e, 0x4d, 0xe8, 0x95, 0x29, 0xa2, 0x2a, 0x8f, 0x4c, 0xbc, 0xb6, 0x44, 0x54,
0x23, 0x35, 0x50, 0x2f, 0xaf, 0x87, 0x57, 0x5a, 0x9d, 0x7f, 0x8d, 0x68, 0x9f, 0x6a, 0x40, 0xea,
0x50, 0x39, 0xc7, 0xfe, 0xeb, 0xa9, 0xd6, 0xe0, 0x9f, 0x16, 0xde, 0x5c, 0x51, 0xad, 0xf9, 0xaa,
0xf9, 0xfb, 0x7d, 0x5b, 0xf9, 0xf3, 0xbe, 0xad, 0xfc, 0x75, 0xdf, 0x56, 0xfe, 0x09, 0x00, 0x00,
0xff, 0xff, 0x73, 0xdd, 0x78, 0x2b, 0x90, 0x0a, 0x00, 0x00,
var fileDescriptor_trace_31b365b8afda32be = []byte{
// 931 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x96, 0xcd, 0x6e, 0xdb, 0x46,
0x10, 0xc7, 0x4b, 0x7d, 0x58, 0xd2, 0x88, 0x96, 0xd9, 0x6d, 0x5a, 0x10, 0x6c, 0x62, 0xa8, 0x6e,
0x10, 0xe8, 0x24, 0x20, 0x06, 0x8a, 0x1c, 0x9a, 0x02, 0x55, 0xc4, 0x8d, 0x2d, 0x43, 0xb6, 0x89,
0x91, 0xec, 0x1e, 0x5d, 0x4a, 0xda, 0x26, 0x0c, 0x24, 0x92, 0x20, 0x57, 0x2a, 0xf2, 0x00, 0x7d,
0x98, 0xbe, 0x49, 0x6f, 0xed, 0x23, 0x14, 0x3e, 0xf7, 0x21, 0x8a, 0xdd, 0x25, 0x25, 0x51, 0xa1,
0xe8, 0xf4, 0xe3, 0xc6, 0x99, 0xfd, 0xff, 0x66, 0x77, 0xd6, 0xff, 0x59, 0x0b, 0x9a, 0x3c, 0x72,
0xa7, 0xac, 0x1b, 0x46, 0x01, 0x0f, 0x48, 0x23, 0x5c, 0x4e, 0xe2, 0xe5, 0xa4, 0x1b, 0x4e, 0x4e,
0xfe, 0x7a, 0x04, 0x30, 0x16, 0x4b, 0x74, 0xc5, 0x7c, 0x4e, 0xba, 0x50, 0xe1, 0xef, 0x43, 0x66,
0x6a, 0x6d, 0xad, 0xd3, 0x3a, 0xb5, 0xba, 0x6b, 0x61, 0x77, 0x23, 0xea, 0x8e, 0xdf, 0x87, 0x0c,
0xa5, 0x8e, 0x7c, 0x01, 0x07, 0x21, 0x63, 0xd1, 0xc0, 0x36, 0x4b, 0x6d, 0xad, 0xa3, 0x63, 0x12,
0x91, 0xc7, 0xd0, 0xe0, 0xde, 0x82, 0xc5, 0xdc, 0x5d, 0x84, 0x66, 0xb9, 0xad, 0x75, 0xca, 0xb8,
0x49, 0x90, 0x21, 0xb4, 0xc2, 0xe5, 0x64, 0xee, 0xc5, 0x6f, 0x2f, 0x59, 0x1c, 0xbb, 0x6f, 0x98,
0x59, 0x69, 0x6b, 0x9d, 0xe6, 0xe9, 0xd3, 0xfc, 0xfd, 0x9c, 0x8c, 0x16, 0x77, 0x58, 0x32, 0x80,
0xc3, 0x88, 0xbd, 0x63, 0x53, 0x9e, 0x16, 0xab, 0xca, 0x62, 0x5f, 0xe7, 0x17, 0xc3, 0x6d, 0x29,
0x66, 0x49, 0x82, 0x60, 0xcc, 0x96, 0xe1, 0xdc, 0x9b, 0xba, 0x9c, 0xa5, 0xd5, 0x0e, 0x64, 0xb5,
0x67, 0xf9, 0xd5, 0xec, 0x1d, 0x35, 0x7e, 0xc0, 0x8b, 0x66, 0x67, 0x6c, 0xee, 0xad, 0x58, 0x94,
0x56, 0xac, 0x15, 0x35, 0x6b, 0x67, 0xb4, 0xb8, 0xc3, 0x92, 0x17, 0x50, 0x73, 0x67, 0x33, 0x87,
0xb1, 0xc8, 0xac, 0xcb, 0x32, 0x4f, 0xf2, 0xcb, 0xf4, 0x94, 0x08, 0x53, 0x35, 0xf9, 0x1e, 0x20,
0x62, 0x8b, 0x60, 0xc5, 0x24, 0xdb, 0x90, 0x6c, 0x7b, 0xdf, 0x15, 0xa5, 0x3a, 0xdc, 0x62, 0xc4,
0xd6, 0x11, 0x9b, 0xae, 0xd0, 0xe9, 0x9b, 0x50, 0xb4, 0x35, 0x2a, 0x11, 0xa6, 0x6a, 0x01, 0xc6,
0xcc, 0x9f, 0x09, 0xb0, 0x59, 0x04, 0x8e, 0x94, 0x08, 0x53, 0xb5, 0x00, 0x67, 0x51, 0x10, 0x0a,
0x50, 0x2f, 0x02, 0x6d, 0x25, 0xc2, 0x54, 0x2d, 0x6c, 0xfc, 0x2e, 0xf0, 0x7c, 0xf3, 0x50, 0x52,
0x7b, 0x6c, 0x7c, 0x11, 0x78, 0x3e, 0x4a, 0x1d, 0x79, 0x0e, 0xd5, 0x39, 0x73, 0x57, 0xcc, 0x6c,
0x49, 0xe0, 0xcb, 0x7c, 0x60, 0x28, 0x24, 0xa8, 0x94, 0x02, 0x79, 0x13, 0xb9, 0x3f, 0x71, 0xf3,
0xa8, 0x08, 0x39, 0x13, 0x12, 0x54, 0x4a, 0x81, 0x84, 0xd1, 0xd2, 0x67, 0xa6, 0x51, 0x84, 0x38,
0x42, 0x82, 0x4a, 0x69, 0x75, 0xa1, 0x95, 0x75, 0xbf, 0x98, 0xac, 0x85, 0xfa, 0x1c, 0xd8, 0x72,
0x4c, 0x75, 0xdc, 0x24, 0x2c, 0x0f, 0x0e, 0x33, 0x06, 0x2f, 0x96, 0x93, 0x13, 0xd0, 0x23, 0x36,
0x65, 0xde, 0x8a, 0xcd, 0x5e, 0x47, 0xc1, 0x22, 0x19, 0xe2, 0x4c, 0x4e, 0x8c, 0x78, 0xc4, 0xdc,
0x38, 0xf0, 0xe5, 0x1c, 0x37, 0x30, 0x89, 0xac, 0x31, 0x18, 0xbb, 0xee, 0xff, 0xef, 0xbb, 0x89,
0x86, 0xb3, 0x13, 0xf0, 0x40, 0xc3, 0x2f, 0xa0, 0x96, 0x58, 0x7d, 0xeb, 0x2d, 0xd2, 0x32, 0x6f,
0xd1, 0x23, 0x71, 0xed, 0x01, 0x0f, 0xe4, 0x7e, 0x0d, 0x54, 0x81, 0xf5, 0x14, 0x60, 0xe3, 0xf3,
0x7d, 0xac, 0xf5, 0x23, 0xd4, 0x12, 0x3b, 0x7f, 0x70, 0x7a, 0x2d, 0xe7, 0xae, 0x9e, 0x43, 0x65,
0xc1, 0xb8, 0x2b, 0x77, 0xda, 0x3f, 0x1f, 0x4e, 0xff, 0x92, 0x71, 0x17, 0xa5, 0xd4, 0x1a, 0x43,
0x2d, 0xf1, 0xbd, 0x38, 0x84, 0x70, 0xfe, 0x38, 0x48, 0x0f, 0xa1, 0xa2, 0x7f, 0x59, 0x35, 0x19,
0x8a, 0xff, 0xb3, 0xea, 0x63, 0xa8, 0x88, 0xa1, 0x11, 0x37, 0xca, 0x83, 0xd0, 0x9b, 0xca, 0x8a,
0x0d, 0x54, 0x81, 0xf5, 0x04, 0xaa, 0x72, 0x42, 0x36, 0xcb, 0xa5, 0xed, 0xe5, 0x6f, 0xa0, 0x2a,
0xa7, 0xa1, 0xe8, 0xef, 0x94, 0x8f, 0xc9, 0x89, 0xf8, 0x87, 0xd8, 0xaf, 0x1a, 0xd4, 0x92, 0xc3,
0x93, 0x63, 0x80, 0xb5, 0x61, 0x62, 0x53, 0x6b, 0x97, 0x3b, 0x3a, 0x6e, 0x65, 0x48, 0x0f, 0xf4,
0x78, 0x39, 0x89, 0xa7, 0x91, 0x17, 0x72, 0x2f, 0xf0, 0xcd, 0x52, 0xbb, 0x5c, 0xf0, 0x48, 0x2d,
0x27, 0xf2, 0x46, 0x32, 0x08, 0xf9, 0x16, 0x6a, 0xd3, 0xc0, 0xe7, 0x51, 0x30, 0x97, 0x53, 0xd2,
0x3c, 0xfd, 0x2a, 0x9f, 0xee, 0x2b, 0x91, 0xac, 0x90, 0x12, 0xd6, 0x77, 0x50, 0x4b, 0xaa, 0x0a,
0xb3, 0x27, 0x75, 0x27, 0xea, 0x9f, 0x70, 0x1d, 0x37, 0x89, 0x3d, 0xad, 0xfe, 0x52, 0x82, 0xe6,
0x56, 0x5d, 0xf2, 0x12, 0xaa, 0xde, 0x5b, 0xf1, 0x98, 0x69, 0xb2, 0x8f, 0x67, 0x85, 0x27, 0x19,
0x9c, 0xbb, 0x2b, 0x26, 0x8f, 0xa3, 0x20, 0x49, 0xff, 0xec, 0xfa, 0x3c, 0xb9, 0x85, 0x07, 0xe8,
0x1f, 0x5c, 0x9f, 0x27, 0xb4, 0x80, 0x04, 0xad, 0x5e, 0xc5, 0xf2, 0x47, 0xd0, 0xd2, 0x0e, 0x8a,
0x56, 0x0f, 0xe4, 0xcb, 0xf4, 0x81, 0xac, 0x7c, 0x04, 0x2d, 0x5d, 0xa1, 0x68, 0xf5, 0x56, 0x9e,
0x83, 0xb1, 0xdb, 0x54, 0xbe, 0x53, 0x77, 0x0c, 0x51, 0xda, 0x35, 0x84, 0x75, 0xba, 0xa9, 0x94,
0x36, 0xf8, 0x90, 0x89, 0xac, 0xce, 0x9a, 0x59, 0xb7, 0xb5, 0x67, 0x4e, 0x36, 0xca, 0x75, 0x0b,
0xf9, 0xca, 0x93, 0xdf, 0x35, 0xa8, 0x88, 0x1f, 0x5b, 0xe4, 0x33, 0x38, 0x72, 0x6e, 0x5e, 0x0d,
0x07, 0xa3, 0xf3, 0xbb, 0x4b, 0x3a, 0x1a, 0xf5, 0xce, 0xa8, 0xf1, 0x09, 0x21, 0xd0, 0x42, 0x7a,
0x41, 0xfb, 0xe3, 0x75, 0x4e, 0x23, 0x9f, 0xc3, 0xa7, 0xf6, 0x8d, 0x33, 0x1c, 0xf4, 0x7b, 0x63,
0xba, 0x4e, 0x97, 0x04, 0x6f, 0xd3, 0xe1, 0xe0, 0x96, 0xe2, 0x3a, 0x59, 0x26, 0x3a, 0xd4, 0x7b,
0xb6, 0x7d, 0xe7, 0x50, 0x8a, 0x46, 0x85, 0x1c, 0x41, 0x13, 0xe9, 0xe5, 0xf5, 0x2d, 0x55, 0x89,
0xaa, 0x58, 0x46, 0xda, 0xbf, 0xbd, 0x43, 0xa7, 0x6f, 0x1c, 0x88, 0x68, 0x44, 0xaf, 0x6c, 0x19,
0xd5, 0x44, 0x64, 0xe3, 0xb5, 0x23, 0xa3, 0x3a, 0xa9, 0x43, 0xe5, 0xe2, 0x7a, 0x70, 0x65, 0x34,
0x48, 0x03, 0xaa, 0x43, 0xda, 0xbb, 0xa5, 0x06, 0x88, 0xcf, 0x33, 0xec, 0xbd, 0x1e, 0x1b, 0x4d,
0xf1, 0xe9, 0xe0, 0xcd, 0x15, 0x35, 0xf4, 0x57, 0xfa, 0x6f, 0xf7, 0xc7, 0xda, 0x1f, 0xf7, 0xc7,
0xda, 0x9f, 0xf7, 0xc7, 0xda, 0xdf, 0x01, 0x00, 0x00, 0xff, 0xff, 0xf8, 0x22, 0x93, 0xfa, 0x95,
0x0a, 0x00, 0x00,
}

8
pb/trace.proto
View File

@ -5,7 +5,7 @@ package pubsub.pb;
message TraceEvent {
optional Type type = 1;
optional bytes peerID = 2;
optional uint64 timestap = 3;
optional int64 timestamp = 3;
optional PublishMessage publishMessage = 4;
optional RejectMessage rejectMessage = 5;
@ -32,7 +32,7 @@ message TraceEvent {
SEND_RPC = 7;
DROP_RPC = 8;
JOIN = 9;
LEAE = 10;
LEAVE = 10;
GRAFT = 11;
PRUNE = 12;
}
@ -100,8 +100,8 @@ message TraceEvent {
message RPCMeta {
repeated bytes messageIDs = 1;
repeated SubMeta subMeta = 2;
optional ControlMeta controlMeta = 3;
repeated SubMeta subscription = 2;
optional ControlMeta control = 3;
}
message SubMeta {