latency

Documentation

Index

• type LatInfo
• type LatManager
  • func NewLatManager(windowLen time.Duration, windowSize int) *LatManager
  • func (lm *LatManager) AddLat(lat time.Duration)
  • func (lm *LatManager) GetAll95th() int
  • func (lm *LatManager) GetAllPth(p float64) int
  • func (lm *LatManager) GetWindowP(p float64) int64
• type LatPredictor
  • func NewLatPredictor(dstList []string, windowLen time.Duration, windowSize int) *LatPredictor
  • func (pm *LatPredictor) AddProbeRet(pr *ProbeRet)
  • func (pm *LatPredictor) PredictLat(addr string, p float64) int64
• type ProbeRet

Types

type LatInfo

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

type LatManager

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

Not thread safe.

func NewLatManager

func NewLatManager(windowLen time.Duration, windowSize int) *LatManager

func (*LatManager) AddLat

func (lm *LatManager) AddLat(lat time.Duration)

Accepts latency in ns

func (*LatManager) GetAll95th

func (lm *LatManager) GetAll95th() int

Returns the 95th latency (in ms) from the beginning

func (*LatManager) GetAllPth

func (lm *LatManager) GetAllPth(p float64) int

Returns the specific percentile latency in ms

func (*LatManager) GetWindowP

func (lm *LatManager) GetWindowP(p float64) int64

Returns the specific percentile latency (in ms) of the current window

type LatPredictor

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

func NewLatPredictor

func NewLatPredictor(dstList []string, windowLen time.Duration, windowSize int) *LatPredictor

func (*LatPredictor) AddProbeRet

func (pm *LatPredictor) AddProbeRet(pr *ProbeRet)

func (*LatPredictor) PredictLat

func (pm *LatPredictor) PredictLat(addr string, p float64) int64

Returns the predicted roundtrip latency in ms

type ProbeRet

type ProbeRet struct {
	Addr string
	Rt   time.Duration // rountrip time
}