stat

Documentation

Index

• Variables
• func CpuUsage() int64
• func Report(msg string)
• func SetReportWriter(writer Writer)
• func SetReporter(fn func(string))
• type Metrics
  • func NewMetrics(name string) *Metrics
  • func (m *Metrics) Add(task Task)
  • func (m *Metrics) AddDrop()
  • func (m *Metrics) SetName(name string)
• type RemoteWriter
  • func (rw *RemoteWriter) Write(report *StatReport) error
• type StatReport
• type Task
• type Writer
  • func NewRemoteWriter(endpoint string) Writer

Variables

var ErrWriteFailed = errors.New("submit failed")

var (
	LogInterval = time.Minute
)

Functions

func CpuUsage

func CpuUsage() int64

func Report

func Report(msg string)

func SetReportWriter

func SetReportWriter(writer Writer)

func SetReporter

func SetReporter(fn func(string))

Types

type Metrics

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

func NewMetrics

func NewMetrics(name string) *Metrics

func (*Metrics) Add

func (m *Metrics) Add(task Task)

func (*Metrics) AddDrop

func (m *Metrics) AddDrop()

func (*Metrics) SetName

func (m *Metrics) SetName(name string)

type RemoteWriter

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

func (*RemoteWriter) Write

func (rw *RemoteWriter) Write(report *StatReport) error

type StatReport

type StatReport struct {
	Name          string  `json:"name"`
	Timestamp     int64   `json:"tm"`
	Pid           int     `json:"pid"`
	ReqsPerSecond float32 `json:"qps"`
	Drops         int     `json:"drops"`
	Average       float32 `json:"avg"`
	Median        float32 `json:"med"`
	Top90th       float32 `json:"t90"`
	Top99th       float32 `json:"t99"`
	Top99p9th     float32 `json:"t99p9"`
}

type Task

type Task struct {
	Drop        bool
	Duration    time.Duration
	Description string
}

type Writer

type Writer interface {
	Write(report *StatReport) error
}

func NewRemoteWriter

func NewRemoteWriter(endpoint string) Writer