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

track topics in Reject/Duplicate/Deliver events

This commit is contained in:
vyzo 2020-07-31 10:01:32 +03:00
parent fa4d16e08a
commit 5a3055d33a
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
trace.go
View File

@ -95,6 +95,7 @@ func (t *pubsubTracer) RejectMessage(msg *Message, reason string) {
MessageID: []byte(t.msgID(msg.Message)),
ReceivedFrom: []byte(msg.ReceivedFrom),
Reason: &reason,
Topics: msg.TopicIDs,
},
}
@ -124,6 +125,7 @@ func (t *pubsubTracer) DuplicateMessage(msg *Message) {
DuplicateMessage: &pb.TraceEvent_DuplicateMessage{
MessageID: []byte(t.msgID(msg.Message)),
ReceivedFrom: []byte(msg.ReceivedFrom),
Topics: msg.TopicIDs,
},
}
@ -152,6 +154,7 @@ func (t *pubsubTracer) DeliverMessage(msg *Message) {
Timestamp: &now,
DeliverMessage: &pb.TraceEvent_DeliverMessage{
MessageID: []byte(t.msgID(msg.Message)),
Topics: msg.TopicIDs,
},
}