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 RecordSessionStartTime(protocolVersion int, d time.Duration)
- 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, ...)
Constants ¶
This section is empty.
Variables ¶
View Source
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 IncrementBytes ¶
func IncrementPackets ¶
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 RecordJitter ¶
func RecordPacketLoss ¶
func RecordQuality ¶
func RecordQuality(rating livekit.ConnectionQuality, score float32, numUpDrops int, numDownDrops int)
func RecordSessionStartTime ¶
func RecordTrackSubscribeAttempt ¶
func RecordTrackSubscribeAttempt()
func RecordTrackSubscribeSuccess ¶
func RecordTrackSubscribeSuccess(kind string)
func RecordTrackUnsubscribed ¶
func RecordTrackUnsubscribed(kind string)
func RoomStarted ¶
func RoomStarted()
func SubConnection ¶
func SubConnection(direction Direction)
func SubParticipant ¶
func SubParticipant()
func SubPublishedTrack ¶
func SubPublishedTrack(kind string)
Types ¶
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)
Click to show internal directories.
Click to hide internal directories.