perf

Documentation

Index

• type Metrics
  • func NewMetrics(namespace string, registry *prometheus.Registry) *Metrics
  • func (m *Metrics) DecRTCSessions(groupID string)
  • func (m *Metrics) DecRTPTracks(groupID, direction, trackType string)
  • func (m *Metrics) DecWSConnections(clientID string)
  • func (m *Metrics) Handler() http.Handler
  • func (m *Metrics) IncRTCConnState(state string)
  • func (m *Metrics) IncRTCErrors(groupID string, errType string)
  • func (m *Metrics) IncRTCSessions(groupID string)
  • func (m *Metrics) IncRTPTracks(groupID, direction, trackType string)
  • func (m *Metrics) IncWSConnections(clientID string)
  • func (m *Metrics) IncWSMessages(clientID, msgType, direction string)
  • func (m *Metrics) ObserveRTCClientJitter(groupID string, val float64)
  • func (m *Metrics) ObserveRTCClientLossRate(groupID string, val float64)
  • func (m *Metrics) ObserveRTCClientRTT(groupID string, val float64)
  • func (m *Metrics) ObserveRTPTracksWrite(groupID, trackType string, dur float64)

Types

type Metrics

type Metrics struct {
	RTPTracks            *prometheus.GaugeVec
	RTPTrackWrites       *prometheus.HistogramVec
	RTCSessions          *prometheus.GaugeVec
	RTCConnStateCounters *prometheus.CounterVec
	RTCErrors            *prometheus.CounterVec

	RTCClientLoss   *prometheus.HistogramVec
	RTCClientRTT    *prometheus.HistogramVec
	RTCClientJitter *prometheus.HistogramVec

	WSConnections     *prometheus.GaugeVec
	WSMessageCounters *prometheus.CounterVec
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics(namespace string, registry *prometheus.Registry) *Metrics

func (*Metrics) DecRTCSessions

func (m *Metrics) DecRTCSessions(groupID string)

func (*Metrics) DecRTPTracks

func (m *Metrics) DecRTPTracks(groupID, direction, trackType string)

func (*Metrics) DecWSConnections

func (m *Metrics) DecWSConnections(clientID string)

func (*Metrics) Handler

func (m *Metrics) Handler() http.Handler

func (*Metrics) IncRTCConnState

func (m *Metrics) IncRTCConnState(state string)

func (*Metrics) IncRTCErrors

func (m *Metrics) IncRTCErrors(groupID string, errType string)

func (*Metrics) IncRTCSessions

func (m *Metrics) IncRTCSessions(groupID string)

func (*Metrics) IncRTPTracks

func (m *Metrics) IncRTPTracks(groupID, direction, trackType string)

func (*Metrics) IncWSConnections

func (m *Metrics) IncWSConnections(clientID string)

func (*Metrics) IncWSMessages

func (m *Metrics) IncWSMessages(clientID, msgType, direction string)

func (*Metrics) ObserveRTCClientJitter

func (m *Metrics) ObserveRTCClientJitter(groupID string, val float64)

func (*Metrics) ObserveRTCClientLossRate

func (m *Metrics) ObserveRTCClientLossRate(groupID string, val float64)

func (*Metrics) ObserveRTCClientRTT

func (m *Metrics) ObserveRTCClientRTT(groupID string, val float64)

func (*Metrics) ObserveRTPTracksWrite

func (m *Metrics) ObserveRTPTracksWrite(groupID, trackType string, dur float64)