Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
What's new
10
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Open sidebar
p2p
go-p2p-pubsub
Commits
4f972a14
Commit
4f972a14
authored
Dec 16, 2020
by
vyzo
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
add receivedFrom field in delivery trace
parent
98f86117
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
118 additions
and
64 deletions
+118
-64
pb/trace.pb.go
pb/trace.pb.go
+117
-64
pb/trace.proto
pb/trace.proto
+1
-0
No files found.
pb/trace.pb.go
View file @
4f972a14
...
...
@@ -454,6 +454,7 @@ func (m *TraceEvent_DuplicateMessage) GetTopic() string {
type TraceEvent_DeliverMessage struct {
MessageID []byte `protobuf:"bytes,1,opt,name=messageID" json:"messageID,omitempty"`
Topic *string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
ReceivedFrom []byte `protobuf:"bytes,3,opt,name=receivedFrom" json:"receivedFrom,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
...
...
@@ -506,6 +507,13 @@ func (m *TraceEvent_DeliverMessage) GetTopic() string {
return ""
}
func (m *TraceEvent_DeliverMessage) GetReceivedFrom() []byte {
if m != nil {
return m.ReceivedFrom
}
return nil
}
type TraceEvent_AddPeer struct {
PeerID []byte `protobuf:"bytes,1,opt,name=peerID" json:"peerID,omitempty"`
Proto *string `protobuf:"bytes,2,opt,name=proto" json:"proto,omitempty"`
...
...
@@ -1502,70 +1510,70 @@ func init() {
func init() { proto.RegisterFile("trace.proto", fileDescriptor_0571941a1d628a80) }
var fileDescriptor_0571941a1d628a80 = []byte{
// 99
3
bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x96, 0x
cf
, 0x6
e
, 0xd
b
, 0x
4
6,
0x1
0
, 0xc
6
, 0x
4b
, 0x
4b
, 0x
b2
, 0x
a4
, 0x
91
, 0x
2c
, 0x
b3
, 0xd
b
, 0x
24
, 0x
20
, 0x
d4
, 0x
c4
, 0x5
0
, 0x
dd
,
0x2
0, 0x10, 0x50
, 0x4
0
, 0x4
0
, 0x
0c
, 0x
1
4, 0x
3
9, 0x
34
, 0x
09
, 0x
2
a, 0x
8b
, 0x
8
c, 0x2
d
, 0x4
3
, 0xb
6
,
0x
89
, 0xb
1
, 0x
e
c, 0x
1e
, 0x
5
d, 0x
4a
, 0x
da
, 0xc
6
, 0x
34
, 0x
24
, 0x
92
, 0x
20
, 0x
57
, 0x
2a
, 0x
72
, 0xe
a
,
0x
a9
, 0x
6f
, 0xd
5
, 0x
07
, 0x
c8
, 0x
ad
, 0x
7d
, 0x
84
, 0x
c2
, 0x
4f
, 0x
52
, 0x
ec
, 0x
2e
, 0x
ff
, 0x
ca
, 0xa
4
,
0x
92
, 0x
1a
, 0x
b9
, 0x
71
, 0x
56
, 0x
df
, 0x
6f
, 0x
76
, 0x
66
, 0x7
7
, 0x
be
, 0x
85
, 0x
a0
, 0x
c1
, 0x
7c
, 0x6
b
,
0x
4a
, 0x
7b
, 0x
9e
, 0xe
f
, 0x
3
2, 0x
97
, 0x
d4
, 0x
bd
, 0x
e5
, 0x
24
, 0x
58
, 0x
4e
, 0x
7a
, 0x
de
, 0x
64
, 0x
ff
,
0x
af, 0x27
, 0x
0
0, 0x
63
, 0xf
e
, 0x
9
3, 0x
b1
, 0x
a2
, 0x
0e
, 0x
23
, 0x3
d
, 0x
28
, 0x
b3
, 0x
0f
, 0x
1e
, 0xd
5
,
0x
94, 0x8e
, 0xd
2
, 0x
6
d, 0x
1d
, 0x
b4
, 0x7
b
, 0x
b
1, 0x
b0
, 0x
97
, 0x
88
, 0x
7a
, 0xe3, 0x
0f
, 0x1
e
, 0x
45
,
0x
a1
, 0x
2
3, 0x
4f
, 0x
60
, 0x
db
, 0x
a3
, 0x
d4
, 0x
1f
, 0x
ea
, 0xd
a
, 0x5
6
, 0x
47
, 0x
e9
, 0x
36
, 0x3
1
, 0x
8c
,
0x
c8
, 0x
53
, 0x
a8
, 0x
33
, 0x
7b
, 0x
41
, 0x
03
, 0x
66
, 0x
2d
, 0x
3c
, 0x
ad
, 0x
d
4, 0x
51
, 0x
ba
, 0x
2
5, 0x
4c
,
0x
1
6, 0x
c8
, 0x0
8
, 0x
5a
, 0x
de
, 0x
72
, 0x
32
, 0x
b7
, 0x
83
, 0x9
b
, 0x
53
, 0x
1a
, 0x
04
, 0xd
6
, 0x
7b
, 0x
a
a,
0x
95
, 0x
3b
, 0x
4a
, 0xb
7
, 0x7
1
, 0x
f0
, 0x
3c
, 0x
7
f, 0x
3f
, 0x
33
, 0x
a3
, 0x
c5
, 0x
35
, 0x
96
, 0x0
c
, 0x
61
,
0x
c7
, 0x
a7
, 0x
b7
, 0x
74
, 0x
ca
, 0x
a
2, 0x
64
, 0x
15
, 0x
91
, 0x
ec
, 0x
fb
, 0x
fc
, 0x
6
4, 0x
98
, 0x
96
, 0x
62
,
0x
96
, 0x
2
4, 0x
08
, 0x
e
a, 0x
6c
, 0x
e9
, 0x
cd
, 0x
ed
, 0x
a9
, 0x
c5
, 0x
68
, 0x
94
, 0x
6d
, 0x
5
b, 0x
64
, 0x
7b
,
0x
91
, 0x
9f
, 0x
4d, 0x5
f, 0x
53
, 0x
e3
, 0x3
d
, 0x
9
e, 0x
37
, 0x
3b
, 0x
a3
, 0x
73
, 0x
7b
, 0x
4
5, 0x
fd
, 0x
2
8,
0x
63
, 0x
75
, 0x
53
, 0x
b3
, 0x
7a
, 0x
46
, 0x
8b
, 0x
6
b, 0x
2c
, 0x
79
, 0x
05
, 0x
55
, 0x
6b
, 0x
36
, 0x
33
, 0x
29
,
0x
f5
, 0x
b5
, 0x
9a
, 0x
48
, 0x
f3
, 0x
2c
, 0x3
f
, 0x
4d
, 0x
5f
, 0x8
a
, 0x
30
, 0x5
2
, 0x
93
, 0x9f, 0x
01, 0x7
c,
0x
ba
, 0x
70
, 0x
57
, 0x5
4
, 0xb0, 0x
75
, 0xc
1
, 0x
76
, 0x8a, 0x
8e
, 0x
2
8, 0x
d2, 0x61
, 0x8
a
, 0x
e1
, 0x
5b
,
0x
fb
, 0x
74
, 0x
ba
, 0x
42
, 0x
73
, 0x
a
0, 0x
c1
, 0x
a
6, 0x
ad
, 0x
51
, 0x8
a
, 0x
30
, 0x
52
, 0x
73
, 0x
30
, 0x
a0
,
0x
c
e, 0x
8c
, 0x
83
, 0x8
d
, 0x4
d
, 0x
e0
, 0x8
5
, 0x
1
4, 0x
6
1, 0x
a4
, 0x
e6
, 0xe
0
, 0xc
c, 0x7
7, 0x
3d
, 0x
0e
,
0x36, 0x
37
, 0x
81
, 0x
ba
, 0x
14
, 0x
61
, 0x
a4
, 0x
e6
, 0x
63
, 0x
7
c, 0x
e
b, 0xd
a
, 0x
8e
, 0x
b6
, 0x
23
, 0x
a8
,
0x
82
, 0x
31
, 0x
3
e, 0x
71
, 0x
6d
, 0x0
7
, 0x
85
, 0x
8e
, 0x
bc
, 0x
84
, 0x
ca
, 0x
9c
, 0x
5a
, 0x
2
b, 0x
aa
, 0x
b5
,
0x
04
, 0xf
0
, 0x6
d
, 0x
3e
, 0x
30
, 0x
e
2, 0x
1
2, 0x9
4
, 0x
4a
, 0x
8e
, 0xb
c
, 0xf
7
, 0x
ad
, 0xd
f
, 0x
98
, 0xb
6
,
0x
bb
, 0x
09
, 0x
39
, 0x
e
2, 0x
1
2, 0x9
4
, 0x
4a
, 0x
8e
, 0x
78
, 0x
fe
, 0x
d2
, 0x
a1
, 0x
9a
, 0x
ba
, 0x
09
, 0x
31
,
0x
b9
, 0x
0
4, 0x
a5
, 0x
b2
, 0x
ad
, 0x4
3
, 0x
2b
, 0x
3b
, 0x
fd
, 0x
dc
, 0x
59
, 0x
0b
, 0xf
9
, 0x
39
, 0x
d4
, 0x
85
,
0x
4
d, 0x
9b
, 0x
98
, 0x
2c
, 0x
90
, 0x4
7
, 0x
50
, 0x
61
, 0x
ae
, 0x
67
, 0x
4f
, 0x
85
, 0x
1d
, 0x
eb
, 0x
28
, 0x
83
,
0x
f6
, 0x
1f
, 0x
b0
, 0x
93
, 0x
19
, 0x
fb
, 0x4
f
, 0x
24
, 0x
d9
, 0x
87
, 0x
a6
, 0x
4f
, 0x
a7
, 0x
d4
, 0x
5e
, 0x
d1
,
0x
d9
, 0x
3b
, 0x
df
, 0x
5d
, 0x
84
, 0x
d6
, 0x
ce
, 0x
a
c, 0x
71
, 0x
e
3, 0x
f
b, 0x
d4
, 0x
0a
, 0x
5c
, 0x
47
, 0x
b8
,
0x
bb
, 0x8
e
, 0x
61
, 0x
94
, 0x
14
, 0x
50
, 0x
4e
, 0x
17
, 0x
7
0, 0x
0b
, 0x
ea
, 0x
ba
, 0x5
3
, 0x
be
, 0x
40
, 0x
0d
,
0xf
1
, 0x
5e
, 0x
a5
, 0xf
4
, 0x5
e
, 0x
3a
, 0x
b
4, 0x
b2
, 0x
1e
, 0x
7a
, 0x
d0
, 0x
91
, 0x
b
d, 0x
82
, 0x
6a
, 0x
68
,
0x
a1
, 0x
d4
, 0x1
b
, 0x
a7
, 0x
6
4, 0x
de
, 0x
b8
, 0x
47
, 0x
fc
, 0x
3a
, 0x5
d
, 0xe
6
, 0x
46
, 0x
a0
, 0x
08
, 0x
da
,
0x
cf
, 0x
01
, 0x
1
2, 0x
ff
, 0x
14
, 0x
b1
, 0x
ed
, 0x5
f
, 0x
a1
, 0x
1a
, 0xd
a
, 0xe
4
, 0x
5
e, 0x
a7, 0x4a
, 0x
4
e,
0xa
7
, 0x
2f
, 0x
a
1, 0x
bc
, 0x
a0
, 0x
cc
, 0x1
2
, 0x
3b
, 0x1
5
, 0x
fb
, 0x
ce
, 0x
1
c, 0x
9c
, 0x
52
, 0x
66
, 0x
a1
,
0x
90
, 0x
b6
, 0x
c7
, 0x5
0
, 0x
0d
, 0x
fd
, 0x
c4
, 0x
8b
, 0x
e0
, 0x
8e
, 0x
1a
, 0x
bb
, 0x
51
, 0x
11
, 0x
32
, 0x
7
a,
0x
60
, 0x
d6
, 0x
d0
, 0x
6c
, 0x
5f
, 0x
32
, 0x
eb
, 0x
53
, 0x
28
, 0x
73
, 0x
33
, 0x
26
, 0x
57
, 0x
a1
, 0x
a4
, 0x
af
,
0x
e2
, 0x
19
, 0x
54
, 0x
84, 0xf3
, 0x
0a
, 0x
6
e, 0x
e
a, 0x
47
, 0x
a
8, 0x0
8
, 0x
9
7, 0x6
d
, 0x
ba
, 0x
a7
, 0x
7c
,
0x
4c
, 0x
38
, 0xe
d
, 0x
7f
, 0x
62
, 0x
1f
, 0x
15
, 0x
a
8, 0x
86
, 0x
c5
, 0x
93
, 0x
37
, 0x5
0
, 0x
0b
, 0x
c
7, 0x
28
,
0x
d0
, 0x
94
, 0x
4e
, 0x
a
9, 0x
db
, 0x
38
, 0x
f8
, 0x
2e
, 0x
bf
, 0x
db
, 0x
70
, 0x
10
, 0x
45
, 0x
c7
, 0x
31
, 0x
42
,
0x
fa
, 0x
d0
, 0x
0c
, 0x
96
, 0x
9
3, 0x
60
, 0x
e
a, 0x
db
, 0x1
e
, 0x
b
3, 0x
5d
, 0x
47
, 0xdb, 0x1
2, 0x29
, 0x
8a
,
0xd
e
, 0x
c6
, 0x
e5
, 0x
44
, 0x
e0
, 0x
19
, 0x
84
, 0x
f
c, 0x
04
, 0x
d
5, 0x
a9
, 0x
eb
, 0x
30
, 0x
d
f, 0x
9d
, 0x
0b
,
0x
0f
, 0x
14
, 0x
16
, 0x
30
, 0x9
0
, 0x
22
, 0x
9
1, 0x
21
, 0x2
2
, 0x
d
a, 0x7
d
, 0x
68
, 0x
a4
, 0x
0a
, 0x
7b
, 0x
90
,
0x
4
b, 0x
de
, 0x4
0
, 0x
35
, 0x
2c
, 0x
8
c, 0xe
3
, 0x
61
, 0x
6
9, 0x
1
3, 0x
f9
, 0x
f7
, 0x
a
1, 0x
8
6, 0x
c9, 0x42
,
0x
01
, 0xf
e
, 0x
e7
, 0x
16
, 0x
34
, 0x5
2
, 0x
a5
, 0x
9
1, 0x
d7
, 0x
50
, 0x
b
1, 0x
6f
, 0x
f8
, 0x3
3
, 0x2
c
, 0x
4f
,
0x
f3
, 0x
c5
, 0x
c6
, 0x
66
, 0x
86
, 0x
c7
, 0x
d
6, 0x
4a
, 0x
1e
, 0xa
9
, 0x
8
4, 0x
04
, 0x
f
d, 0x
bb
, 0x
e5
, 0x
b0
,
0x
f0
, 0x
2
0, 0x
3f, 0x41
, 0xff, 0x
62
, 0x
39
, 0x
2c
, 0x
a4
, 0x
39
, 0x
c4
, 0x
69
, 0xf
9
, 0x
9e
, 0x
9
7, 0x
3e
,
0x8
3
, 0x
16
, 0x
03
, 0x
27
, 0x
69
, 0x
f9
, 0x
b4
, 0x
bf
, 0x
8e
, 0x
9
e, 0x
f6
, 0x
f
2, 0x
67
, 0x
d0
, 0x
62
, 0x
ee
,
0x
24, 0x2d
, 0x5f, 0xf
9
, 0x
63
, 0x5
0
, 0x
d7
, 0x9
b
, 0x
c
a, 0x
f7
, 0x
0
2, 0x
d9
, 0x0
3
, 0x
88
, 0x
ef
, 0x
24
,
0x
10
, 0x
8d
, 0x3
6
, 0x
31, 0xb5
, 0x
d2
, 0x
3
e, 0x4
8
, 0x
32
, 0x
45
, 0x
0
d, 0x
ae
, 0x
3
1, 0x
ca
, 0x3
d
, 0x
a6
,
0x
1b, 0x33
, 0x
7
1, 0x5
b
, 0x
05
, 0x4
e
, 0x
7c
, 0x
1b
, 0x
2b
, 0x
e
3, 0x1
6
, 0x
0a
, 0xe
a
, 0x
e4
, 0x
6f
, 0x2
3
,
0x
a5
, 0x
7e
, 0x
54
, 0xa
2
, 0x
0c
, 0x
f
6, 0x
ff
, 0x5
6
, 0x
a0
, 0x
cc
, 0x
ff
, 0x
3
c, 0x
92
, 0x
6
f, 0x
60
, 0x
d7
,
0x
bc, 0x3
c, 0x
1c
, 0x0
d
, 0x2
f
, 0x
8
e, 0x
af
, 0x
4
f, 0x
8d
, 0x
8b
, 0x
8b
, 0xf
e
, 0x
91
, 0xa
1
, 0x7
e
, 0x
45
,
0x0
8
, 0x
b4
, 0xd
0
, 0x3
8
, 0x
31
, 0x
0
6, 0x
e3
, 0x
7
8, 0x
4d
, 0x
2
1, 0x
8f
, 0x
e1
, 0x6
b
, 0x
fd
, 0x
d2
, 0x
1c
,
0x
0d
, 0x
07
, 0x
fd
, 0xb
1
, 0x
11
, 0x
2f
, 0x
6f
, 0x7
1
, 0x
5e
, 0x3
7
, 0x
46
, 0x
c3
, 0x
2b
, 0x
03
, 0xe
3
, 0x
c5
,
0x
12
, 0x
69
, 0x
42
, 0x
a
d, 0x
af
, 0x
e
b, 0x
d7
, 0x
a6
, 0x
61
, 0xa
0
, 0x
5a
, 0x
26
, 0x
bb
, 0x
d0
, 0x4
0
, 0x
e3
,
0x
f
4, 0x
fc
, 0x
ca
, 0x
90
, 0x
0b
, 0x
15
, 0x
fe
, 0x
33
, 0x
1a
, 0x
83
, 0x
ab
, 0x
6b
, 0x
3
4, 0x
07
, 0x
ea
, 0x
3
6,
0x
8
f, 0x
2e
, 0x
8c
, 0x
33
, 0x
5d
, 0x
44
, 0x
55
, 0x
1e
, 0x
e9
, 0x7
8
, 0x
6e
, 0x8
a
, 0xa8, 0x
46
, 0x
6a
, 0x
50
,
0x
3e
, 0x
39
, 0x1
f
, 0x
9e
, 0x
a9
, 0x
7
5, 0x
52
, 0x
8
7, 0x
ca
, 0x
c8
, 0x
e8
, 0x5
f
, 0x
19
, 0x
2
a, 0x
f
0, 0x
cf
,
0x
23
, 0x
ec, 0xbf
, 0x
1
b, 0x
ab
, 0x0
d
, 0xfe, 0x
6
9, 0x
e
2, 0x
e5
, 0x
99
, 0x
a1
, 0x
3
6, 0xf
7
, 0xd
f
, 0xc
2
,
0x
6e
, 0x
72
, 0x
bf
, 0x
87
, 0x1
6
, 0x
9
b, 0xd
e
, 0x
90
, 0x
1f
, 0x
a0
, 0x
32
, 0x
e1
, 0x
1f
, 0x
e1
, 0x
10
, 0x
3f
,
0x
ce
, 0x
1
d, 0x
05
, 0x
9
4, 0x
9a
, 0xc
3
, 0x
e6
, 0x
c7
, 0x
bb
, 0x
3d
, 0x
e
5, 0x
9f
, 0xb
b
, 0x
3d
, 0x
e5
, 0x
d
f,
0x
bb
, 0x
3d
, 0x
e5
, 0x
b
f, 0x
0
0, 0x
00
, 0x
00
, 0x
f
f, 0x
ff
, 0x
92
, 0x
e3
, 0x
7
0, 0x
55
, 0x
a5
, 0x
0b
, 0x
00
,
0x00,
// 99
9
bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x96, 0x
51
, 0x6
f
, 0xd
a
, 0x
5
6,
0x1
4
, 0xc
7
, 0x
e7
, 0x
00
, 0x
01
, 0x
0e
, 0x
84
, 0x
78
, 0x
77
, 0x
6
d, 0x
65
, 0x
b1
, 0x
36
, 0x
62
, 0x5
9
, 0x
55
,
0x2
1
, 0x4
d
, 0x4
2
, 0x
6a
, 0x
a
4, 0x
a
9, 0x
0f
, 0x
6b
, 0xa
b
, 0x
11
, 0x
e
c, 0x2
6, 0x44
, 0x
2
4, 0xb
1, 0x0e
,
0x
24
, 0x
7
b, 0x
c
c, 0x
0c
, 0xd
c
, 0x
35
, 0x
8e
, 0xc
0
, 0x
b6
, 0x
ec
, 0x
0b
, 0x
53
, 0x
9f
, 0x
f6
, 0x
b4
, 0xe
f
,
0x
d6
, 0x
b7
, 0x
e
d, 0x
23
, 0x
54
, 0x
f9
, 0x
24
, 0x
d3
, 0x
bd
, 0x
d7
, 0x
36
, 0x
36
, 0x
d8
, 0x
b4
, 0x
8b
, 0x
f
a,
0x
e6
, 0x
73
, 0x
f3
, 0x
ff
, 0x
9d
, 0x
7b
, 0x
ce
, 0x
bd
, 0x
e7
, 0x7
f
, 0x
03
, 0x
d4
, 0x
98
, 0x
6f
, 0x
4d
, 0x6
8
,
0x
c7
, 0x
f3
, 0x
5d
, 0xe
6
, 0x
9
2, 0x
aa
, 0x
b7
, 0x
18
, 0x
07
, 0x
8b
, 0x
71
, 0x
c7
, 0x
1b
, 0x
1f
, 0x
7e
, 0x
7a
,
0x
02
, 0x
3
0, 0x
e2
, 0x
7
f, 0x3
2
, 0x
96
, 0x
d4
, 0x
61
, 0x
a4
, 0x
0
3, 0x
45
, 0x
f6
, 0x
c1, 0xa3
, 0x
9a
, 0xd
2
,
0x
52
, 0xd
a
, 0x
8
d, 0x
a3
, 0x
66
, 0x
2
7, 0x1
6
, 0x
76
, 0x
56
, 0x
a2
, 0x
ce
, 0xe
8, 0x8
3, 0x
47
, 0x
5
1, 0x
e8
,
0x
c8
, 0x
1
3, 0x
d8
, 0x
f5
, 0x
28
, 0x
f5
, 0x
fb
, 0x
ba
, 0x
b6
, 0xd
3
, 0x5
2
, 0x
da
, 0x
75
, 0x
0c
, 0x
2
3, 0x
f2
,
0x
14
, 0x
aa
, 0x
cc
, 0x
9e
, 0x
d3
, 0x
80
, 0x
59
, 0x
73
, 0x
4f
, 0x
2b
, 0x
b4
, 0x
9
4, 0x
76
, 0x
01
, 0x5
7
, 0x
0b
,
0x6
4
, 0x
00
, 0x0
d
, 0x
6f
, 0x
31
, 0x
9e
, 0x
d9
, 0x
c1
, 0x
ed
, 0x
3
9, 0x
0d
, 0x
02
, 0x
eb
, 0x
3
d, 0x
d5
, 0x
8
a,
0x
2d
, 0x
a5
, 0x
5d
, 0x
3
b, 0x7
a
, 0x
9e
, 0x
bd
, 0x
9
f, 0x
99
, 0x
d2
, 0x
e2
, 0x
1a
, 0x
4b
, 0x
fa
, 0x
b
0, 0x
e7
,
0x
d3
, 0x
3b
, 0x
3a
, 0x
61
, 0x
51
, 0x
b
2, 0x
92
, 0x
48
, 0x
f6
, 0x
63
, 0x
76
, 0x
32
, 0x4
c
, 0x
4a
, 0x
31
, 0x
4d
,
0x
12
, 0x
0
4, 0x
75
, 0x
b
a, 0x
f0
, 0x
66
, 0x
f6
, 0x
c4
, 0x
62
, 0x
34
, 0x
ca
, 0x
b6
, 0x
2b
, 0xb
2
, 0x
bd
, 0x
c8
,
0x
ce
, 0x
a6
, 0x
a
f, 0x
a9
, 0x
71
, 0x
8
3, 0xe
7
, 0x
cd
, 0x
4e
, 0x
e9
, 0x
cc
, 0x
5e
, 0x5
2
, 0x
3f, 0xca
, 0x
5
8,
0x
de
, 0x
d6
, 0x
ac
, 0x
9e
, 0x
d2
, 0x
e2
, 0x
1a
, 0x
4
b, 0x
5e
, 0x
41
, 0x
d9
, 0x
9a
, 0x
4e
, 0x
4d
, 0x
4a
, 0x
7d
,
0x
ad
, 0x
22
, 0x
d2
, 0x
3c
, 0x
cb
, 0x
4e
, 0x
d
3, 0x
95
, 0x
22
, 0x8
c
, 0x
d4, 0xe4
, 0x5
7
, 0x
00
, 0x9f, 0xc
e
,
0x
dd
, 0x
25
, 0x
15, 0x6c
, 0x5
5
, 0xb0, 0x
ad
, 0x
b
c, 0x
23
, 0x8a, 0x
74
, 0x
9
8, 0x
60
, 0x
f
8, 0x
d6
, 0x
3e
,
0x
9d
, 0x
2c
, 0x
d1
, 0x
ec
, 0x
69
, 0x
b
0, 0x
6d
, 0x6
b
, 0x
94
, 0x
22
, 0x8
c
, 0x
d4
, 0x
1c
, 0x
0c
, 0x
a8
, 0x
33
,
0xe
5
, 0x
60
, 0x
6d, 0x1b
, 0x
3
8, 0x
9
4, 0x
22
, 0x8
c
, 0x
d
4, 0x1
c
, 0x
9c
, 0x
fa
, 0x
a
e, 0xc7, 0x
c1
, 0x
fa
,
0x36, 0x
50
, 0x
97
, 0x
22
, 0x
8c
, 0x
d4
, 0x
7c
, 0x
8c
, 0x
ef
, 0x
5
c, 0x
d
b, 0xd
1
, 0x
f6
, 0x
04
, 0x
95
, 0x
33
,
0x
c6
, 0x
67
, 0x
a
e, 0x
ed
, 0x
a0
, 0x
d
0, 0x
91
, 0x
97
, 0x
50
, 0x
9a
, 0x
51
, 0x
6b
, 0x
49
, 0xb
5
, 0x
86
, 0x
00
,
0x
be
, 0x
c
f, 0x
0
6, 0x
06
, 0x
5c
, 0x
8
2, 0x
5
2, 0x
c
9, 0x
91
, 0x
f7
, 0xb
e
, 0xf
5
, 0x
07
, 0xd
3
, 0x
f6
, 0xb
7
,
0x
21
, 0x
27
, 0x
5c
, 0x
8
2, 0x
5
2, 0x
c
9, 0x
11
, 0x
cf
, 0x
5f
, 0x
38
, 0x
54
, 0x
53
, 0x
b7
, 0x
21
, 0x
26
, 0x
97
,
0x
a0
, 0x
5
4, 0x
36
, 0x
75
, 0x
68
, 0x
a
4, 0x
a7
, 0x
9f
, 0x
3b
, 0x
6b
, 0x
2e
, 0x
3f
, 0xf
b
, 0x
ba
, 0x
b0
, 0x
69
,
0x
1
d, 0x
57
, 0x
0b
, 0x
e4
, 0x
11
, 0x
9
4, 0x
98
, 0x
eb
, 0x
d9
, 0x
13
, 0x
61
, 0x
c7
, 0x
2a
, 0x
ca
, 0x
a0
, 0x
f9
,
0x
17
, 0x
ec
, 0x
a5
, 0x
c6
, 0x
fe
, 0x
33
, 0x4
9
, 0x
0e
, 0x
a1
, 0x
ee
, 0x
d3
, 0x
09
, 0x
b5
, 0x
97
, 0x
74
, 0x
fa
,
0x
ce
, 0x
77
, 0x
e7
, 0x
a1
, 0x
b5
, 0x
53
, 0x
6b
, 0x
d
c, 0x
f8
, 0x3
e
, 0xb
5
, 0x
02
, 0x
d7
, 0x
11
, 0x
ee
, 0x
ae
,
0x
62
, 0x
1
8, 0x
ad
, 0x
0a
, 0x
28
, 0x
26
, 0x
0b
, 0x
b8
, 0x0
3
, 0x
75
, 0x
dd
, 0x
29
, 0x5
f
, 0x
a1
, 0x
86
, 0x
78
,
0x
a
f, 0x
42
, 0x
72
, 0x
a
f, 0x5
b
, 0x
68
, 0x
a
4, 0x
3d
, 0x
f4
, 0x
90
, 0x
23
, 0x
db
, 0xd
8
, 0x
bf
, 0x
b0
, 0x
b9
,
0x
7f
, 0x
f3
, 0x1
5
, 0x
94
, 0x4
3
, 0x
9b
, 0x
25
, 0x
de
, 0x
41
, 0x
25
, 0x
f
5, 0x
0
e, 0x
3e
, 0x
e2
, 0x
57
, 0x
ee
,
0x
32
, 0x
37, 0x4a
, 0x2
e
, 0x
82
, 0x
e6
, 0x
73
, 0x
80
, 0x
9
5, 0x
c7
, 0x
f2
, 0xd
8
, 0xe
6
, 0xe
f
, 0x
50
, 0x
0
e,
0xa
d
, 0x
b4
, 0x
5
1, 0x
8d
, 0x
92
, 0x
71
, 0x1
a
, 0x
2f
, 0x
a
1, 0x
38
, 0x
a7
, 0x
c
c, 0x
12
, 0x
3b
, 0x
e5
, 0x
7b
,
0x
d3
, 0x
ec
, 0x
9d
, 0x5
3
, 0x
66
, 0x
a1
, 0x
90
, 0x
36
, 0x
47
, 0x
50
, 0x
0e
, 0x
3d
, 0x
c7
, 0x
8b
, 0x
e0
, 0xa
e
,
0x
1b
, 0x
b9
, 0x
51
, 0x
11
, 0x
32
, 0x
7a
, 0x
60
, 0x
d6
, 0x
d0
, 0x
90
, 0x
5f
, 0x
33
, 0x
eb
, 0x
53
, 0x
28
, 0x
72
,
0x
c3
, 0x
ae
, 0x
ae
, 0x
4b
, 0x
49
, 0x
5
e, 0x
f
a, 0x
33
, 0x
2
8, 0x0
9
, 0x
7
7, 0x
e
6, 0x
18
, 0x
e0
, 0x
67, 0x28
,
0x
09
, 0x
27
, 0x
6
e, 0x
bb
, 0x
a7
, 0x
6c
, 0x
4c
, 0x
b
8, 0x
f1
, 0x
7f
, 0x
62
, 0x
1f
, 0x
1
5, 0x
28
, 0x
8
7, 0x
c5
,
0x
93
, 0x
37
, 0x
50
, 0x
0
9, 0x
47
, 0x
2d
, 0x
d0
, 0x
94
, 0x
56
, 0x
a1
, 0x
5d
, 0x
3b
, 0x
fa
, 0x
21
, 0x
bb
, 0x
db
,
0x
70
, 0x
58
, 0x
45
, 0x
c7
, 0x3
1
, 0x
42
, 0x
b
a, 0x
50, 0x0f
, 0x1
6
, 0x
e
3, 0x
60
, 0x
e2
, 0xdb, 0x1
e
, 0x
b3
,
0x
5
d, 0x
47
, 0x
db
, 0x
11
, 0x
29
, 0x
f2
, 0x
de
, 0xc
f
, 0x
c5
, 0x5
8
, 0x
e0
, 0x
29
, 0x
84
, 0xf
c
, 0x
02
, 0x
e5
,
0x
89
, 0x
eb
, 0x
30
, 0x
df
, 0x9
d
, 0x
89
, 0x
2
1, 0x
ce
, 0x2
d
, 0xa
0
, 0x
2
7, 0x
45
, 0x
22
, 0x
43
, 0x
44
, 0x
34
,
0x
b
b, 0x
50
, 0x4
b, 0x14
, 0x
f6
, 0x
a0
, 0xc
7
, 0xe
7
, 0x
0d
, 0x9
4
, 0x
c
3, 0x
c2
, 0x
38
, 0x1
e
, 0x
9
6, 0x
36
,
0x
96
, 0x
3
f, 0x
31
, 0x
2a
, 0x
b8
, 0x5
a
, 0x
c8
, 0x
c
1, 0x
ff
, 0x
de
, 0x
8
1, 0x
5a
, 0x
a2
, 0x3
4
, 0x
f
2, 0x
1a
,
0x
4a
, 0x
f6
, 0x
2d
, 0x
7f
, 0x
aa
, 0x
e5
, 0x6
9
, 0x
be
, 0x
d8
, 0x
d
a, 0x4
c
, 0x
ff
, 0xd
4
, 0x
5a
, 0x
ca
, 0x
23
,
0x
95
, 0x
9
0, 0x
a0
, 0xff, 0x
b4
, 0x
1c
, 0x
16
, 0x
1e
, 0x
e4
, 0x
67
, 0x
e8
, 0x
d
f, 0x
2c
, 0x
8
7, 0x
85, 0x34
,
0x8
7
, 0x
38
, 0x
2d
, 0x
df
, 0x
fc
, 0x
c2
, 0x
17
, 0x
d0
, 0x
62
, 0xe
0
, 0x
24
, 0x2
d
, 0x
9f
, 0x
ff
, 0x
d7
, 0x
d1
,
0x
f3
, 0x5f, 0xf
c
, 0x
02
, 0x5
a
, 0x
cc
, 0x9
d
, 0xa
4
, 0x
e5
, 0x
7f, 0x8
2, 0x
53
, 0x
5
0, 0x
d7
, 0x
9b
, 0x
ca
,
0x
f6
, 0x
02
, 0x3
9
, 0x
00
, 0x
88
, 0xe
f
, 0x
2
4, 0x
10
, 0x
8d
, 0xd
6
, 0x
31
, 0x
b
1, 0x
d2
, 0x3
c
, 0x
5a, 0x65
,
0x
8a
, 0x1
a
, 0x5
c
, 0x
63
, 0x
9
4, 0x
0d
, 0x
a6
, 0x
1d
, 0x
3
3, 0x
7
1, 0x
5b, 0x39
, 0x
4
e, 0x
7c
, 0x
1b
, 0x2
b
,
0x
e3
, 0x
16
, 0x
72
, 0x
e
a, 0x
e4
, 0x6
f
, 0x
23
, 0x
a
5, 0x
7e
, 0x
54
, 0x
a2
, 0x
0
c, 0x
0e
, 0x
f
f, 0x
51
, 0x
a0
,
0xc
8
, 0x
7f
, 0x
6
0, 0x
9
2, 0xe
f
, 0x
60
, 0x
d
f, 0x
bc
, 0x
3a
, 0x
1e
, 0xf
4
, 0x
87
, 0xa
7
, 0x
37, 0xe
7, 0x
c6
,
0x
7
0, 0x
d8
, 0x
3
d, 0x3
1
, 0x
d4
, 0x6
f
, 0x
08
, 0x8
1
, 0x
06
, 0x1
a
, 0x
67
, 0x
46
, 0x6
f
, 0x
14
, 0x
af
, 0x
29
,
0x
e4
, 0x
31
, 0x
7c
, 0x
a
b, 0x
5f
, 0x
99
, 0x
83
, 0x7
e
, 0x
af
, 0x3
b
, 0x
32
, 0x
e2
, 0x
e5
, 0x
1d
, 0x
c
e, 0x
eb
,
0x
c6
, 0x
a0
, 0x
7f
, 0x
6
d, 0x
60
, 0xb
c
, 0x
58
, 0x
20
, 0x
75
, 0xa
8
, 0x
74
, 0x
75
, 0x
fd
, 0x
c6
, 0x
3
4, 0x
0c
,
0x
5
4, 0x
8b
, 0x
64
, 0x
1f
, 0x
6a
, 0x
68
, 0x
9c
, 0x
5f
, 0x
5e
, 0x
1b
, 0x
72
, 0x
a1
, 0x
c
4, 0x
ff
, 0x
8c
, 0x
4
6,
0x
e
f, 0x
fa
, 0x
06
, 0x
cd
, 0x
9e
, 0x
ba
, 0x
cb
, 0x
a3
, 0x
a1
, 0x7
1
, 0x
a1
, 0x8
b
, 0xa8, 0x
cc
, 0x
23
, 0x
1d
,
0x
2f
, 0x
4d
, 0x1
1
, 0x
55
, 0x
48
, 0x
0
5, 0x
8a
, 0x
6
7, 0x
97
, 0x
fd
, 0x
0b
, 0x
b
5, 0x
4a
, 0x
a
a, 0x
5
0, 0x
1a
,
0x
18
, 0x
dd
, 0x
6
b, 0x
43
, 0x0
5
, 0xfe, 0x
7
9, 0x
8
2, 0x
dd
, 0x
77
, 0x
23
, 0x
b5, 0xc
6, 0x
3
f, 0x
4
d, 0x
b
c,
0x
ba
, 0x
30
, 0x
d4
, 0x
fa
, 0x
e
1, 0x
5
b, 0xd
8
, 0x
5f
, 0x
dd
, 0x
ef
, 0x
b1
, 0x
c5
, 0x
26
, 0x
b7
, 0x
e4
, 0x
27
,
0x
28
, 0x
8
d, 0x
f9
, 0x4
7
, 0x
38
, 0xc
4
, 0x
8f
, 0x
33
, 0x
47
, 0x
01
, 0x
a
5, 0x
e6
, 0xb
8
, 0x
fe
, 0x
f1
, 0xf
e
,
0x
40
, 0x
f9
, 0x
f7
, 0xf
e
, 0x
4
0, 0x
f9
, 0x
74
, 0x
7
f, 0x
a0
, 0x
fc
, 0x
17
, 0x
0
0, 0x
00
, 0x
ff
, 0x
ff
, 0x
db
,
0x3a, 0x1c, 0xe4, 0xc9, 0x0b, 0x00,
0x00,
}
func (m *TraceEvent) Marshal() (dAtA []byte, err error) {
...
...
@@ -1938,6 +1946,13 @@ func (m *TraceEvent_DeliverMessage) MarshalToSizedBuffer(dAtA []byte) (int, erro
i -= len(m.XXX_unrecognized)
copy(dAtA[i:], m.XXX_unrecognized)
}
if m.ReceivedFrom != nil {
i -= len(m.ReceivedFrom)
copy(dAtA[i:], m.ReceivedFrom)
i = encodeVarintTrace(dAtA, i, uint64(len(m.ReceivedFrom)))
i--
dAtA[i] = 0x1a
}
if m.Topic != nil {
i -= len(*m.Topic)
copy(dAtA[i:], *m.Topic)
...
...
@@ -2921,6 +2936,10 @@ func (m *TraceEvent_DeliverMessage) Size() (n int) {
l = len(*m.Topic)
n += 1 + l + sovTrace(uint64(l))
}
if m.ReceivedFrom != nil {
l = len(m.ReceivedFrom)
n += 1 + l + sovTrace(uint64(l))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
...
...
@@ -4456,6 +4475,40 @@ func (m *TraceEvent_DeliverMessage) Unmarshal(dAtA []byte) error {
s := string(dAtA[iNdEx:postIndex])
m.Topic = &s
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ReceivedFrom", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowTrace
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthTrace
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthTrace
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ReceivedFrom = append(m.ReceivedFrom[:0], dAtA[iNdEx:postIndex]...)
if m.ReceivedFrom == nil {
m.ReceivedFrom = []byte{}
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipTrace(dAtA[iNdEx:])
...
...
pb/trace.proto
View file @
4f972a14
...
...
@@ -58,6 +58,7 @@ message TraceEvent {
message
DeliverMessage
{
optional
bytes
messageID
=
1
;
optional
string
topic
=
2
;
optional
bytes
receivedFrom
=
3
;
}
message
AddPeer
{
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment