prometheus

Documentation

Index

• Variables
• func AddConnection(direction Direction)
• func AddParticipant()
• func AddPublishAttempt(kind string)
• func AddPublishSuccess(kind string)
• func AddPublishedTrack(kind string)
• func GetUpdatedNodeStats(prev *livekit.NodeStats, prevAverage *livekit.NodeStats) (*livekit.NodeStats, bool, error)
• func IncrementBytes(direction Direction, count uint64, retransmit bool)
• func IncrementPackets(direction Direction, count uint64, retransmit bool)
• func IncrementParticipantJoin(join uint32)
• func IncrementParticipantJoinFail(join uint32)
• func IncrementParticipantRtcConnected(join uint32)
• func IncrementParticipantRtcInit(join uint32)
• func IncrementRTCP(direction Direction, nack, pli, fir uint32)
• func Init(nodeID string, nodeType livekit.NodeType, env string)
• func RecordJitter(direction Direction, trackSource livekit.TrackSource, ...)
• func RecordPacketLoss(direction Direction, trackSource livekit.TrackSource, ...)
• func RecordQuality(rating livekit.ConnectionQuality, score float32, numUpDrops int, ...)
• func RecordRTT(direction Direction, trackSource livekit.TrackSource, ...)
• func RecordTrackSubscribeAttempt()
• func RecordTrackSubscribeFailure(err error, isUserError bool)
• func RecordTrackSubscribeSuccess(kind string)
• func RecordTrackUnsubscribed(kind string)
• func RoomEnded(startedAt time.Time)
• func RoomStarted()
• func SubConnection(direction Direction)
• func SubParticipant()
• func SubPublishedTrack(kind string)
• type Direction
• type PSRPCMetricsObserver
  • func (o PSRPCMetricsObserver) OnMultiRequest(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, ...)
  • func (o PSRPCMetricsObserver) OnStreamClose(role middleware.MetricRole, info psrpc.RPCInfo)
  • func (o PSRPCMetricsObserver) OnStreamOpen(role middleware.MetricRole, info psrpc.RPCInfo)
  • func (o PSRPCMetricsObserver) OnStreamRecv(role middleware.MetricRole, info psrpc.RPCInfo, err error)
  • func (o PSRPCMetricsObserver) OnStreamSend(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, ...)
  • func (o PSRPCMetricsObserver) OnUnaryRequest(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, ...)

Variables

var (
	MessageCounter            *prometheus.CounterVec
	ServiceOperationCounter   *prometheus.CounterVec
	TwirpRequestStatusCounter *prometheus.CounterVec
)

Functions

func AddConnection

func AddConnection(direction Direction)

func AddParticipant

func AddParticipant()

func AddPublishAttempt

func AddPublishAttempt(kind string)

func AddPublishSuccess

func AddPublishSuccess(kind string)

func AddPublishedTrack

func AddPublishedTrack(kind string)

func GetUpdatedNodeStats

func GetUpdatedNodeStats(prev *livekit.NodeStats, prevAverage *livekit.NodeStats) (*livekit.NodeStats, bool, error)

func IncrementBytes

func IncrementBytes(direction Direction, count uint64, retransmit bool)

func IncrementPackets

func IncrementPackets(direction Direction, count uint64, retransmit bool)

func IncrementParticipantJoin

func IncrementParticipantJoin(join uint32)

func IncrementParticipantJoinFail

func IncrementParticipantJoinFail(join uint32)

func IncrementParticipantRtcConnected

func IncrementParticipantRtcConnected(join uint32)

func IncrementParticipantRtcInit

func IncrementParticipantRtcInit(join uint32)

func IncrementRTCP

func IncrementRTCP(direction Direction, nack, pli, fir uint32)

func Init

func Init(nodeID string, nodeType livekit.NodeType, env string)

func RecordJitter

func RecordJitter(direction Direction, trackSource livekit.TrackSource, trackType livekit.TrackType, jitter uint32)

func RecordPacketLoss

func RecordPacketLoss(direction Direction, trackSource livekit.TrackSource, trackType livekit.TrackType, lost, total uint32)

func RecordQuality

func RecordQuality(rating livekit.ConnectionQuality, score float32, numUpDrops int, numDownDrops int)

func RecordRTT

func RecordRTT(direction Direction, trackSource livekit.TrackSource, trackType livekit.TrackType, rtt uint32)

func RecordTrackSubscribeAttempt

func RecordTrackSubscribeAttempt()

func RecordTrackSubscribeFailure

func RecordTrackSubscribeFailure(err error, isUserError bool)

func RecordTrackSubscribeSuccess

func RecordTrackSubscribeSuccess(kind string)

func RecordTrackUnsubscribed

func RecordTrackUnsubscribed(kind string)

func RoomEnded

func RoomEnded(startedAt time.Time)

func RoomStarted

func RoomStarted()

func SubConnection

func SubConnection(direction Direction)

func SubParticipant

func SubParticipant()

func SubPublishedTrack

func SubPublishedTrack(kind string)

Types

type Direction

type Direction string

const (
	Incoming Direction = "incoming"
	Outgoing Direction = "outgoing"
)

type PSRPCMetricsObserver

type PSRPCMetricsObserver struct{}

func (PSRPCMetricsObserver) OnMultiRequest

func (o PSRPCMetricsObserver) OnMultiRequest(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, responseCount int, errorCount int)

func (PSRPCMetricsObserver) OnStreamClose

func (o PSRPCMetricsObserver) OnStreamClose(role middleware.MetricRole, info psrpc.RPCInfo)

func (PSRPCMetricsObserver) OnStreamOpen

func (o PSRPCMetricsObserver) OnStreamOpen(role middleware.MetricRole, info psrpc.RPCInfo)

func (PSRPCMetricsObserver) OnStreamRecv

func (o PSRPCMetricsObserver) OnStreamRecv(role middleware.MetricRole, info psrpc.RPCInfo, err error)

func (PSRPCMetricsObserver) OnStreamSend

func (o PSRPCMetricsObserver) OnStreamSend(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, err error)

func (PSRPCMetricsObserver) OnUnaryRequest

func (o PSRPCMetricsObserver) OnUnaryRequest(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, err error)