lib

Documentation

Index

• type Telemetry
• type TelemetryManager
  • func (m *TelemetryManager) AverageLatencyWindow() time.Duration
  • func (m *TelemetryManager) MaxLatency() time.Duration
  • func (m *TelemetryManager) MinLatency() time.Duration
  • func (m *TelemetryManager) Num400s() int
  • func (m *TelemetryManager) Num500s() int
  • func (m *TelemetryManager) NumRequests() int
  • func (m *TelemetryManager) Request(delta time.Duration, code int)

Types

type Telemetry

type Telemetry struct {
	Status       int
	RequestDelta time.Duration
}

type TelemetryManager

type TelemetryManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

TODO: Break metrics down into "since reset" and "since restart" and provide a persistence mechanism.

func (*TelemetryManager) AverageLatencyWindow

func (m *TelemetryManager) AverageLatencyWindow() time.Duration

func (*TelemetryManager) MaxLatency

func (m *TelemetryManager) MaxLatency() time.Duration

func (*TelemetryManager) MinLatency

func (m *TelemetryManager) MinLatency() time.Duration

func (*TelemetryManager) Num400s

func (m *TelemetryManager) Num400s() int

func (*TelemetryManager) Num500s

func (m *TelemetryManager) Num500s() int

func (*TelemetryManager) NumRequests

func (m *TelemetryManager) NumRequests() int

func (*TelemetryManager) Request

func (m *TelemetryManager) Request(delta time.Duration, code int)