cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Append source auth flag to lotus tracer event

Browse Source
This commit is contained in:
Matija Petrunic 2021-09-21 12:54:07 +02:00
commit 0c390d12f7
3 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
node/config/types.go
View File

@ -311,6 +311,7 @@ type Pubsub struct {
RemoteTracer string RemoteTracer string
JsonTracerFile string JsonTracerFile string
ElasticSearchTracer string ElasticSearchTracer string
TracerSourceAuth string
} }
type Chainstore struct { type Chainstore struct {

2
node/modules/lp2p/pubsub.go
View File

@ -383,7 +383,7 @@ func GossipSub(in GossipIn) (service *pubsub.PubSub, err error) {
} }
transports = append(transports, elasticSearchTransport) transports = append(transports, elasticSearchTransport)
} }
lt := tracer.NewLotusTracer(transports, in.Host.ID()) lt := tracer.NewLotusTracer(transports, in.Host.ID(), in.Cfg.TracerSourceAuth)
// tracer // tracer
if in.Cfg.RemoteTracer != "" { if in.Cfg.RemoteTracer != "" {

22
node/modules/tracer/tracer.go
View File

@ -11,16 +11,18 @@ import (
var log = logging.Logger("lotus-tracer") var log = logging.Logger("lotus-tracer")
func NewLotusTracer(tt []TracerTransport, pid peer.ID) LotusTracer { func NewLotusTracer(tt []TracerTransport, pid peer.ID, sourceAuth string) LotusTracer {
return &lotusTracer{ return &lotusTracer{
tt: tt, tt: tt,
pid: pid, pid: pid,
sa: sourceAuth,
} }
} }
type lotusTracer struct { type lotusTracer struct {
tt []TracerTransport tt []TracerTransport
pid peer.ID pid peer.ID
sa string
} }
const ( const (
@ -28,10 +30,11 @@ const (
) )
type LotusTraceEvent struct { type LotusTraceEvent struct {
Type pubsub_pb.TraceEvent_Type `json:"type,omitempty"` Type pubsub_pb.TraceEvent_Type `json:"type,omitempty"`
PeerID string `json:"peerID,omitempty"` PeerID string `json:"peerID,omitempty"`
Timestamp *int64 `json:"timestamp,omitempty"` Timestamp *int64 `json:"timestamp,omitempty"`
PeerScore TraceEvent_PeerScore `json:"peerScore,omitempty"` PeerScore TraceEvent_PeerScore `json:"peerScore,omitempty"`
SourceAuth string `json:"sourceAuth,omitempty"`
} }
type TraceEvent_PeerScore struct { type TraceEvent_PeerScore struct {
@ -50,10 +53,11 @@ func (lt *lotusTracer) PeerScores(scores map[peer.ID]*pubsub.PeerScoreSnapshot)
now := time.Now().UnixNano() now := time.Now().UnixNano()
for pid, score := range scores { for pid, score := range scores {
evt := &LotusTraceEvent{ evt := &LotusTraceEvent{
Type: *TraceEvent_PEER_SCORES.Enum(), Type: *TraceEvent_PEER_SCORES.Enum(),
PeerID: lt.pid.Pretty(), PeerID: lt.pid.Pretty(),
Timestamp: &now, Timestamp: &now,
PeerScore: TraceEvent_PeerScore{PeerID: pid.Pretty(), Score: float32(score.Score)}, SourceAuth: lt.sa,
PeerScore: TraceEvent_PeerScore{PeerID: pid.Pretty(), Score: float32(score.Score)},
} }
lt.TraceLotusEvent(evt) lt.TraceLotusEvent(evt)