Documentation ¶
Index ¶
- func CleanTrackStats(labels Labels)
- func ExtendRouter(router *mux.Router, config *MetricConfig) error
- func FirDel(labels Labels)
- func FirInc(labels Labels, fir uint32)
- func GetPrometheusMiddleware(m *HttpMetric) func(http.Handler) http.Handler
- func GraphAddEdge(sessionId string, liveStreamId string, nodeType string)
- func GraphDeleteEdge(sessionId string, liveStreamId string, nodeType string)
- func GraphNodeDelete(node GraphNode)
- func JitterDel(labels Labels)
- func JitterInc(labels Labels, jitter float64)
- func NackDel(labels Labels)
- func NackInc(labels Labels, nack uint32)
- func PacketBytesDel(labels Labels)
- func PacketBytesInc(labels Labels, pkg uint64)
- func PacketDel(labels Labels)
- func PacketInc(labels Labels, pkg uint64)
- func PacketLossDel(labels Labels)
- func PacketLossInc(labels Labels, pkg int64)
- func PacketLossTotalDel(labels Labels)
- func PacketLossTotalInc(labels Labels, pkg int64)
- func PliDel(labels Labels)
- func PliInc(labels Labels, pli uint32)
- func RecordTrackStats(labels Labels, statsRec *stats.Stats)
- func RttDel(labels Labels)
- func RttInc(labels Labels, rtt uint64)
- func RunningLobbyDec(stream string, lobby string)
- func RunningLobbyInc(stream string, lobby string)
- func RunningSessionsDec(lobby string)
- func RunningSessionsDelete(lobby string)
- func RunningSessionsInc(lobby string)
- func ServeMetrics(ctx context.Context, config *MetricConfig) error
- func ValidateMetricConfig(config *MetricConfig) error
- type GraphEdge
- type GraphNode
- type HttpMetric
- type LabelType
- type Labels
- type LobbyMetric
- type LobbySessionMetric
- type LobbySessionTrackMetric
- type MetricConfig
- type NodeGraphMetric
- type PrometheusConfig
- type TrackMetric
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CleanTrackStats ¶
func CleanTrackStats(labels Labels)
func ExtendRouter ¶
func ExtendRouter(router *mux.Router, config *MetricConfig) error
func GetPrometheusMiddleware ¶
func GetPrometheusMiddleware(m *HttpMetric) func(http.Handler) http.Handler
func GraphAddEdge ¶
func GraphDeleteEdge ¶
func GraphNodeDelete ¶
func GraphNodeDelete(node GraphNode)
func PacketBytesDel ¶
func PacketBytesDel(labels Labels)
func PacketBytesInc ¶
func PacketLossDel ¶
func PacketLossDel(labels Labels)
func PacketLossInc ¶
func PacketLossTotalDel ¶
func PacketLossTotalDel(labels Labels)
func PacketLossTotalInc ¶
func RecordTrackStats ¶
func RunningLobbyDec ¶
func RunningLobbyInc ¶
func RunningSessionsDec ¶
func RunningSessionsDec(lobby string)
func RunningSessionsDelete ¶
func RunningSessionsDelete(lobby string)
func RunningSessionsInc ¶
func RunningSessionsInc(lobby string)
func ServeMetrics ¶
func ServeMetrics(ctx context.Context, config *MetricConfig) error
func ValidateMetricConfig ¶
func ValidateMetricConfig(config *MetricConfig) error
Types ¶
type GraphNode ¶
type GraphNode struct { Id string Title string Subtitle string Stream string // live stream Tracks int MainTracks int }
func GraphNodeUpdate ¶
func GraphNodeUpdateDec ¶
func GraphNodeUpdateInc ¶
type HttpMetric ¶
type HttpMetric struct {
// contains filtered or unexported fields
}
func NewHttpMetric ¶
func NewHttpMetric() (*HttpMetric, error)
type LabelType ¶
type LabelType string
const ( Session LabelType = "session" Stream LabelType = "stream" MediaStream LabelType = "mediastream" TrackId LabelType = "track" SSRC LabelType = "ssrc" TrackKind LabelType = "kind" // values: video | audio TrackPurpose LabelType = "purpose" // values: guest | main Direction LabelType = "direction" // values: ingress | egress )
type LobbyMetric ¶
type LobbyMetric struct {
// contains filtered or unexported fields
}
func NewLobbyMetrics ¶
func NewLobbyMetrics() (*LobbyMetric, error)
type LobbySessionMetric ¶
type LobbySessionMetric struct {
// contains filtered or unexported fields
}
func NewLobbySessionMetrics ¶
func NewLobbySessionMetrics() (*LobbySessionMetric, error)
type LobbySessionTrackMetric ¶
type LobbySessionTrackMetric struct {
// contains filtered or unexported fields
}
func NewLobbySessionTrackMetrics ¶
func NewLobbySessionTrackMetrics() (*LobbySessionTrackMetric, error)
type MetricConfig ¶
type MetricConfig struct {
Prometheus *PrometheusConfig `mapstructure:"prometheus"`
}
type NodeGraphMetric ¶
type NodeGraphMetric struct {
// contains filtered or unexported fields
}
func NewServiceGraphMetrics ¶
func NewServiceGraphMetrics() (*NodeGraphMetric, error)
type PrometheusConfig ¶
type TrackMetric ¶
type TrackMetric struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.