prometheus

Documentation

Index

• Variables
• func AddParticipant()
• func AddPublishedTrack(kind string)
• func AddSubscribedTrack(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 IncrementRTCP(direction Direction, nack, pli, fir uint32)
• func Init(nodeID string)
• func RoomEnded(startedAt time.Time)
• func RoomStarted()
• func SubParticipant()
• func SubPublishedTrack(kind string)
• func SubSubscribedTrack(kind string)
• type Direction

Variables

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

Functions

func AddParticipant

func AddParticipant()

func AddPublishedTrack

func AddPublishedTrack(kind string)

func AddSubscribedTrack

func AddSubscribedTrack(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 IncrementRTCP

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

func Init

func Init(nodeID string)

func RoomEnded

func RoomEnded(startedAt time.Time)

func RoomStarted

func RoomStarted()

func SubParticipant

func SubParticipant()

func SubPublishedTrack

func SubPublishedTrack(kind string)

func SubSubscribedTrack

func SubSubscribedTrack(kind string)

Types

type Direction

type Direction string

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