chanstats

Documentation

Index

• type ChanStats
  • func New() *ChanStats
• type Details
  • func NewDetails(m *Messages) *Details
• type Messages
• type Report
  • func NewReport(s *ChanStats) *Report
• type WelfordStats
  • func NewWelford(w *welford.Stats) *WelfordStats

Types

type ChanStats

type ChanStats struct {
	ConnectedAt time.Time
	Rx          Messages
	Tx          Messages
}

Structs for recording stats

func New

func New() *ChanStats

type Details

type Details struct {
	Last  string       `json:"last"` //how many seconds ago...
	Bytes WelfordStats `json:"bytes"`
	Dt    WelfordStats `json:"dt"`
}

func NewDetails

func NewDetails(m *Messages) *Details

type Messages

type Messages struct {
	Last  time.Time
	Bytes *welford.Stats
	Dt    *welford.Stats
}

type Report

type Report struct {
	Connected string  `json:"connected"`
	Tx        Details `json:"tx"`
	Rx        Details `json:"rx"`
}

Structs for (un)marshalling stats into JSON

func NewReport

func NewReport(s *ChanStats) *Report

type WelfordStats

type WelfordStats struct {
	Count    uint64  `json:"count"`
	Min      float64 `json:"min"`
	Max      float64 `json:"max"`
	Mean     float64 `json:"mean"`
	Stddev   float64 `json:"stddev"`
	Variance float64 `json:"variance"`
}

func NewWelford

func NewWelford(w *welford.Stats) *WelfordStats