features

Documentation

Index

• func HeapDump() ([]byte, error)
• func InitTracing(config *structures.Config, transporter *services.Transporter) error
• func NewWsReporter(transporter *services.Transporter) reporter.Reporter
• func StartCPUProfile() error
• func StopCPUProfile() ([]byte, error)
• type Error
• type Notifier
  • func (notifier *Notifier) Error(err error)
  • func (notifier *Notifier) Log(log string)
• type Timers
• type WsReporter
  • func (r *WsReporter) Close() error
  • func (r *WsReporter) Send(s model.SpanModel)

Functions

func HeapDump

func HeapDump() ([]byte, error)

HeapDump return a binary string of a pprof

func InitTracing

func InitTracing(config *structures.Config, transporter *services.Transporter) error

InitTracing with config and transporter provided

func NewWsReporter

func NewWsReporter(transporter *services.Transporter) reporter.Reporter

NewWsReporter create a reporter using specified transporter

func StartCPUProfile

func StartCPUProfile() error

StartCPUProfile start a CPU profiling and write it to file

func StopCPUProfile

func StopCPUProfile() ([]byte, error)

StopCPUProfile stop the profiling and read the file

Types

type Error

type Error struct {
	Message string `json:"message"`
	Stack   string `json:"stack"`
}

Error packet to KM

type Notifier

type Notifier struct {
	Transporter *services.Transporter
}

Notifier with transporter

func (*Notifier) Error

func (notifier *Notifier) Error(err error)

Error to KM

func (*Notifier) Log

func (notifier *Notifier) Log(log string)

Log to KM

type Timers

type Timers struct {
	T int64 `json:"timestamp,omitempty"`
	D int64 `json:"duration,omitempty"`
}

Timers store timestamp and duration in JSON format from model.SpanModel

type WsReporter

type WsReporter struct {
	Transporter *services.Transporter
}

WsReporter is a Zipkin compatible reporter through PM2 WebSocket

func (*WsReporter) Close

func (r *WsReporter) Close() error

Close the reporter (not used, ws handled in transporter)

func (*WsReporter) Send

func (r *WsReporter) Send(s model.SpanModel)

Send a message using PM2 transporter