features

package
v0.0.0-...-0a5d1ac Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 10, 2022 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL