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) error
• func RecordForwardJitter(_, jitterAvg uint32)
• func RecordForwardLatency(_, latencyAvg uint32)
• func RecordJitter(direction Direction, trackSource livekit.TrackSource, ...)
• func RecordPacketLoss(direction Direction, trackSource livekit.TrackSource, ...)
• func RecordPacketOutOfOrder(direction Direction, trackSource livekit.TrackSource, ...)
• func RecordPublishTime(source livekit.TrackSource, trackType livekit.TrackType, d time.Duration, ...)
• func RecordQuality(rating livekit.ConnectionQuality, score float32, numUpDrops int, ...)
• func RecordRTT(direction Direction, trackSource livekit.TrackSource, ...)
• func RecordSessionDuration(protocolVersion int, d time.Duration)
• func RecordSessionStartTime(protocolVersion int, d time.Duration)
• func RecordSubscribeTime(source livekit.TrackSource, trackType livekit.TrackType, 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

Variables

var (
	MessageCounter            *prometheus.CounterVec
	MessageBytes              *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) error

func RecordForwardJitter

func RecordForwardJitter(_, jitterAvg uint32)

func RecordForwardLatency

func RecordForwardLatency(_, latencyAvg uint32)

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 RecordPacketOutOfOrder

func RecordPacketOutOfOrder(direction Direction, trackSource livekit.TrackSource, trackType livekit.TrackType, ooo, total uint32)

func RecordPublishTime

func RecordPublishTime(source livekit.TrackSource, trackType livekit.TrackType, d time.Duration, sdk livekit.ClientInfo_SDK, kind livekit.ParticipantInfo_Kind)

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 RecordSessionDuration

func RecordSessionDuration(protocolVersion int, d time.Duration)

func RecordSessionStartTime

func RecordSessionStartTime(protocolVersion int, d time.Duration)

func RecordSubscribeTime

func RecordSubscribeTime(source livekit.TrackSource, trackType livekit.TrackType, d time.Duration, sdk livekit.ClientInfo_SDK, kind livekit.ParticipantInfo_Kind, count int)

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"
)