tracer

Documentation

Index

• Constants
• type LotusTraceEvent
• type LotusTracer
  • func NewLotusTracer(tt []TracerTransport, pid peer.ID, sourceAuth string) LotusTracer
• type TopicScore
• type TraceEventPeerScore
• type TracerTransport
  • func NewElasticSearchTransport(connectionString string, elasticsearchIndex string) (TracerTransport, error)
  • func NewJsonTracerTransport(file string) (TracerTransport, error)
• type TracerTransportEvent

Constants

const (
	ElasticSearchDefaultIndex = "lotus-pubsub"
)

const (
	TraceEventPeerScores pubsub_pb.TraceEvent_Type = 100
)

Types

type LotusTraceEvent

type LotusTraceEvent struct {
	Type       pubsub_pb.TraceEvent_Type `json:"type,omitempty"`
	PeerID     string                    `json:"peerID,omitempty"`
	Timestamp  *int64                    `json:"timestamp,omitempty"`
	PeerScore  TraceEventPeerScore       `json:"peerScore,omitempty"`
	SourceAuth string                    `json:"sourceAuth,omitempty"`
}

type LotusTracer

type LotusTracer interface {
	Trace(evt *pubsub_pb.TraceEvent)
	TraceLotusEvent(evt *LotusTraceEvent)

	PeerScores(scores map[peer.ID]*pubsub.PeerScoreSnapshot)
}

func NewLotusTracer

func NewLotusTracer(tt []TracerTransport, pid peer.ID, sourceAuth string) LotusTracer

type TopicScore

type TopicScore struct {
	Topic                    string        `json:"topic"`
	TimeInMesh               time.Duration `json:"timeInMesh"`
	FirstMessageDeliveries   float64       `json:"firstMessageDeliveries"`
	MeshMessageDeliveries    float64       `json:"meshMessageDeliveries"`
	InvalidMessageDeliveries float64       `json:"invalidMessageDeliveries"`
}

type TraceEventPeerScore

type TraceEventPeerScore struct {
	PeerID             string       `json:"peerID"`
	Score              float64      `json:"score"`
	AppSpecificScore   float64      `json:"appSpecificScore"`
	IPColocationFactor float64      `json:"ipColocationFactor"`
	BehaviourPenalty   float64      `json:"behaviourPenalty"`
	Topics             []TopicScore `json:"topics"`
}

type TracerTransport

type TracerTransport interface {
	Transport(evt TracerTransportEvent) error
}

func NewElasticSearchTransport

func NewElasticSearchTransport(connectionString string, elasticsearchIndex string) (TracerTransport, error)

func NewJsonTracerTransport

func NewJsonTracerTransport(file string) (TracerTransport, error)

type TracerTransportEvent

type TracerTransportEvent struct {
	// contains filtered or unexported fields
}