performance

Documentation

Index

• type DBStore
• type Metrics
  • func NewMetrics() *Metrics
  • func (m *Metrics) DecWebSocketConn()
  • func (m *Metrics) Handler() http.Handler
  • func (m *Metrics) IncClusterEvent(evType string)
  • func (m *Metrics) IncClusterMutexLockRetries(group string)
  • func (m *Metrics) IncLiveCaptionsPktPayloadChBufFull()
  • func (m *Metrics) IncLiveCaptionsTranscriberBufFull()
  • func (m *Metrics) IncLiveCaptionsWindowDropped()
  • func (m *Metrics) IncStoreOp(op string)
  • func (m *Metrics) IncWebSocketConn()
  • func (m *Metrics) IncWebSocketEvent(direction, evType string)
  • func (m *Metrics) ObserveAppHandlersTime(handler string, elapsed float64)
  • func (m *Metrics) ObserveClusterMutexGrabTime(group string, elapsed float64)
  • func (m *Metrics) ObserveClusterMutexLockedTime(group string, elapsed float64)
  • func (m *Metrics) ObserveLiveCaptionsAudioLen(elapsed float64)
  • func (m *Metrics) ObserveStoreMethodsTime(method string, elapsed float64)
  • func (m *Metrics) RTCMetrics() rtc.Metrics
  • func (m *Metrics) RegisterDBMetrics(db *sql.DB, name string)

Types

type DBStore

type DBStore interface {
	WriterDB() *sql.DB
}

type Metrics

type Metrics struct {
	WebSocketConnections             prometheus.Gauge
	WebSocketEventCounters           *prometheus.CounterVec
	ClusterEventCounters             *prometheus.CounterVec
	ClusterMutexGrabTimeHistograms   *prometheus.HistogramVec
	ClusterMutexLockedTimeHistograms *prometheus.HistogramVec
	ClusterMutexLockRetriesCounters  *prometheus.CounterVec

	AppHandlersTimeHistograms *prometheus.HistogramVec

	StoreOpCounters            *prometheus.CounterVec
	StoreMethodsTimeHistograms *prometheus.HistogramVec

	LiveCaptionsNewAudioLenHistogram       prometheus.Histogram
	LiveCaptionsWindowDroppedCounter       prometheus.Counter
	LiveCaptionsTranscriberBufFullCounter  prometheus.Counter
	LiveCaptionsPktPayloadChBufFullCounter prometheus.Counter
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics() *Metrics

func (*Metrics) DecWebSocketConn

func (m *Metrics) DecWebSocketConn()

func (*Metrics) Handler

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

func (*Metrics) IncClusterEvent

func (m *Metrics) IncClusterEvent(evType string)

func (*Metrics) IncClusterMutexLockRetries

func (m *Metrics) IncClusterMutexLockRetries(group string)

func (*Metrics) IncLiveCaptionsPktPayloadChBufFull

func (m *Metrics) IncLiveCaptionsPktPayloadChBufFull()

func (*Metrics) IncLiveCaptionsTranscriberBufFull

func (m *Metrics) IncLiveCaptionsTranscriberBufFull()

func (*Metrics) IncLiveCaptionsWindowDropped

func (m *Metrics) IncLiveCaptionsWindowDropped()

func (*Metrics) IncStoreOp

func (m *Metrics) IncStoreOp(op string)

func (*Metrics) IncWebSocketConn

func (m *Metrics) IncWebSocketConn()

func (*Metrics) IncWebSocketEvent

func (m *Metrics) IncWebSocketEvent(direction, evType string)

func (*Metrics) ObserveAppHandlersTime

func (m *Metrics) ObserveAppHandlersTime(handler string, elapsed float64)

func (*Metrics) ObserveClusterMutexGrabTime

func (m *Metrics) ObserveClusterMutexGrabTime(group string, elapsed float64)

func (*Metrics) ObserveClusterMutexLockedTime

func (m *Metrics) ObserveClusterMutexLockedTime(group string, elapsed float64)

func (*Metrics) ObserveLiveCaptionsAudioLen

func (m *Metrics) ObserveLiveCaptionsAudioLen(elapsed float64)

func (*Metrics) ObserveStoreMethodsTime

func (m *Metrics) ObserveStoreMethodsTime(method string, elapsed float64)

func (*Metrics) RTCMetrics

func (m *Metrics) RTCMetrics() rtc.Metrics

func (*Metrics) RegisterDBMetrics

func (m *Metrics) RegisterDBMetrics(db *sql.DB, name string)