prometheus

package

v1.7.0 Latest Latest Go to latest Published: Jun 25, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/livekit/livekit-server

Links

Open Source Insights

Documentation ¶

Rendered for

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

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

func AddConnection ¶ added in v1.2.1

func AddConnection(direction Direction)

func AddParticipant ¶

func AddParticipant()

func AddPublishAttempt ¶ added in v1.3.4

func AddPublishAttempt(kind string)

func AddPublishSuccess ¶ added in v1.3.4

func AddPublishSuccess(kind string)

func AddPublishedTrack ¶

func AddPublishedTrack(kind string)

func GetUpdatedNodeStats ¶ added in v0.15.4

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 ¶ added in v1.1.0

func IncrementParticipantJoin(join uint32)

func IncrementParticipantJoinFail ¶ added in v1.3.4

func IncrementParticipantJoinFail(join uint32)

func IncrementParticipantRtcConnected ¶ added in v1.3.4

func IncrementParticipantRtcConnected(join uint32)

func IncrementParticipantRtcInit ¶ added in v1.3.4

func IncrementParticipantRtcInit(join uint32)

func IncrementRTCP ¶ added in v0.14.2

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

func Init ¶ added in v1.2.0

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

func RecordForwardJitter ¶ added in v1.6.2

func RecordForwardJitter(_, jitterAvg uint32)

func RecordForwardLatency ¶ added in v1.6.2

func RecordForwardLatency(_, latencyAvg uint32)

func RecordJitter ¶ added in v1.3.4

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

func RecordPacketLoss ¶ added in v1.3.4

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

func RecordQuality ¶ added in v1.4.3

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

func RecordRTT ¶ added in v1.3.4

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

func RecordSessionDuration ¶ added in v1.6.3

func RecordSessionDuration(protocolVersion int, d time.Duration)

func RecordSessionStartTime ¶ added in v1.5.3

func RecordSessionStartTime(protocolVersion int, d time.Duration)

func RecordTrackSubscribeAttempt ¶ added in v1.3.4

func RecordTrackSubscribeAttempt()

func RecordTrackSubscribeFailure ¶ added in v1.3.4

func RecordTrackSubscribeFailure(err error, isUserError bool)

func RecordTrackSubscribeSuccess ¶ added in v1.3.4

func RecordTrackSubscribeSuccess(kind string)

func RecordTrackUnsubscribed ¶ added in v1.3.4

func RecordTrackUnsubscribed(kind string)

func RoomEnded ¶

func RoomEnded(startedAt time.Time)

func RoomStarted ¶

func RoomStarted()

func SubConnection ¶ added in v1.2.1

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL