prometheus

func AddConnection(direction Direction)

func AddParticipant()

func AddPublishAttempt(kind string)

func AddPublishSuccess(kind string)

func AddPublishedTrack(kind string)

func GetNodeStats(nodeStartedAt int64, prevStats []*livekit.NodeStats, rateIntervals []time.Duration) (*livekit.NodeStats, error)

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

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

func IncrementParticipantJoin(join uint32)

func IncrementParticipantJoinFail(join uint32)

func IncrementParticipantRtcConnected(join uint32)

func IncrementParticipantRtcInit(join uint32)

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

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

func RecordDataPacketStream(h *livekit.DataStream_Header, destCount int)

func RecordForwardJitter(longTermJitterAvg uint32)

func RecordForwardLatency(longTermLatencyAvg uint32)

func RecordForwardLatencySample(forwardLatency int64)

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

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

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

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

func RecordQuality(rating livekit.ConnectionQuality, score float32)

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

func RecordServiceOperationError(op string, error string)

func RecordServiceOperationSuccess(op string)

func RecordSessionDuration(protocolVersion int, d time.Duration)

func RecordSessionStartTime(protocolVersion int, d time.Duration)

func RecordSignalRequestFailure()

func RecordSignalRequestSuccess()

func RecordSignalResponseFailure()

func RecordSignalResponseSuccess()

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

func RecordTrackSubscribeAttempt()

func RecordTrackSubscribeFailure(err error, isUserError bool)

func RecordTrackSubscribeSuccess(kind string)

func RecordTrackUnsubscribed(kind string)

func RecordTwirpRequestStatus(service string, method string, statusFamily string, code twirp.ErrorCode)

func RoomEnded(startedAt time.Time)

func RoomStarted()

func SubConnection(direction Direction)

func SubParticipant()

func SubPublishedTrack(kind string)