telemetry

package

Go to main page

Versions in this module

v1

v1.8.3

Jan 7, 2025

v1.8.2

Jan 6, 2025

v1.8.1

Jan 3, 2025

v1.8.0

Oct 19, 2024

v1.7.2

Aug 12, 2024

v1.7.1

Aug 11, 2024

Changes in this version

type StatsWorker

+ func (s *StatsWorker) Closed() bool

v1.7.0

Jun 25, 2024

v1.6.3

Jun 23, 2024

v1.6.2

Jun 16, 2024

v1.6.1

Apr 26, 2024

v1.6.0

Apr 11, 2024

Changes in this version

+ type BytesSignalStats struct

+ func NewBytesSignalStats(ctx context.Context, telemetry TelemetryService) *BytesSignalStats

+ func (s *BytesSignalStats) ResolveParticipant(pi *livekit.ParticipantInfo)

+ func (s *BytesSignalStats) ResolveRoom(ri *livekit.Room)

v1.5.3

Feb 17, 2024

Changes in this version

type AnalyticsService

+ SendNodeRoomStates func(ctx context.Context, nodeRooms *livekit.AnalyticsNodeRooms)

type TelemetryService

+ LocalRoomState func(ctx context.Context, info *livekit.AnalyticsNodeRooms)

v1.5.2

Dec 22, 2023

Changes in this version

type BytesTrackStats

+ func (s *BytesTrackStats) GetTrafficTotals() *TrafficTotals

+ func (s *BytesTrackStats) Stop()

+ type TrafficTotals struct

+ At time.Time

+ RecvBytes uint64

+ RecvMessages uint32

+ SendBytes uint64

+ SendMessages uint32

v1.5.1

Nov 9, 2023

v1.5.0

Oct 16, 2023

v1.4.5

Aug 23, 2023

v1.4.4

Jul 9, 2023

Changes in this version

type TelemetryService

+ IngressUpdated func(ctx context.Context, info *livekit.IngressInfo)

v1.4.3

Jun 4, 2023

Changes in this version

type TelemetryService

+ IngressCreated func(ctx context.Context, info *livekit.IngressInfo)

+ IngressDeleted func(ctx context.Context, info *livekit.IngressInfo)

+ IngressEnded func(ctx context.Context, info *livekit.IngressInfo)

+ IngressStarted func(ctx context.Context, info *livekit.IngressInfo)

v1.4.2

May 10, 2023

v1.4.1

Apr 6, 2023

v1.4.0

Mar 31, 2023

Changes in this version

type TelemetryService

+ EgressUpdated func(ctx context.Context, info *livekit.EgressInfo)

+ TrackPublishRTPStats func(ctx context.Context, participantID livekit.ParticipantID, ...)

+ TrackSubscribeRTPStats func(ctx context.Context, participantID livekit.ParticipantID, ...)

v1.3.5

Feb 26, 2023

v1.3.4

Feb 10, 2023

Changes in this version

+ type StatsKey struct

+ func StatsKeyForData(streamType livekit.StreamType, participantID livekit.ParticipantID, ...) StatsKey

+ func StatsKeyForTrack(streamType livekit.StreamType, participantID livekit.ParticipantID, ...) StatsKey

type TelemetryService

+ ParticipantResumed func(ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo, ...)

+ TrackMuted func(ctx context.Context, participantID livekit.ParticipantID, ...)

+ TrackPublishRequested func(ctx context.Context, participantID livekit.ParticipantID, ...)

+ TrackSubscribeFailed func(ctx context.Context, participantID livekit.ParticipantID, ...)

+ TrackSubscribeRequested func(ctx context.Context, participantID livekit.ParticipantID, ...)

+ TrackUnmuted func(ctx context.Context, participantID livekit.ParticipantID, ...)

v1.3.3

Jan 8, 2023

Changes in this version

type StatsWorker

+ func (s *StatsWorker) IsConnected() bool

+ func (s *StatsWorker) SetConnected()

v1.3.2

Dec 16, 2022

Changes in this version

+ func BytesTrackIDForParticipantID(typ BytesTrackType, participantID livekit.ParticipantID) livekit.TrackID

+ type BytesTrackStats struct

+ func NewBytesTrackStats(trackID livekit.TrackID, pID livekit.ParticipantID, telemetry TelemetryService) *BytesTrackStats

+ func (s *BytesTrackStats) AddBytes(bytes uint64, isSend bool)

+ func (s *BytesTrackStats) Report()

+ type BytesTrackType string

+ const BytesTrackTypeData

+ const BytesTrackTypeSignal

v1.3.1

Nov 9, 2022

v1.3.0

Nov 8, 2022

v1.2.5

Oct 20, 2022

v1.2.4

Oct 13, 2022

v1.2.3

Sep 27, 2022

v1.2.2

Sep 26, 2022

Changes in this version

type StatsWorker

+ func (s *StatsWorker) Flush()

type TelemetryService

+ FlushStats func()

+ NotifyEvent func(ctx context.Context, event *livekit.WebhookEvent)

v1.2.1

Sep 13, 2022

Changes in this version

+ type Conn struct

+ func NewConn(c net.Conn, direction prometheus.Direction) *Conn

+ func (c *Conn) Close() error

+ func (c *Conn) Read(b []byte) (n int, err error)

+ func (c *Conn) Write(b []byte) (n int, err error)

+ type Listener struct

+ func NewListener(l net.Listener) *Listener

+ func (l *Listener) Accept() (net.Conn, error)

+ type PacketConn struct

+ func NewPacketConn(c net.PacketConn, direction prometheus.Direction) *PacketConn

+ func (c *PacketConn) Close() error

+ func (c *PacketConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)

+ func (c *PacketConn) WriteTo(p []byte, addr net.Addr) (n int, err error)

+ type RelayAddressGenerator struct

+ func NewRelayAddressGenerator(g turn.RelayAddressGenerator) *RelayAddressGenerator

+ func (g *RelayAddressGenerator) AllocateConn(network string, requestedPort int) (net.Conn, net.Addr, error)

+ func (g *RelayAddressGenerator) AllocatePacketConn(network string, requestedPort int) (net.PacketConn, net.Addr, error)

v1.2.0

Aug 26, 2022

Changes in this version

type StatsWorker

+ func (s *StatsWorker) ClosedAt() time.Time

+ func (s *StatsWorker) ParticipantID() livekit.ParticipantID

type TelemetryServiceInternal

+ CleanupWorkers func()

v1.1.2

Jul 11, 2022

v1.1.1

Jul 8, 2022

v1.1.0

Jun 22, 2022

v1.0.2

May 28, 2022

v1.0.1

May 19, 2022

v1.0.0

May 18, 2022

v0

v0.15.7

May 1, 2022

v0.15.6

Mar 28, 2022

v0.15.5

Feb 28, 2022

Changes in this version

+ type Stat struct

+ Jitter uint32

+ MaxLayer int32

+ Rtt uint32

+ Score float32

+ TotalBytes uint64

+ TotalFirs uint32

+ TotalFrames uint32

+ TotalNacks uint32

+ TotalPackets uint32

+ TotalPacketsLost uint32

+ TotalPaddingBytes uint64

+ TotalPaddingPackets uint32

+ TotalPlis uint32

+ TotalPrimaryBytes uint64

+ TotalPrimaryPackets uint32

+ TotalRetransmitBytes uint64

+ TotalRetransmitPackets uint32

+ VideoLayers map[int32]*livekit.AnalyticsVideoLayer

+ func (stat *Stat) ToAnalyticsStats(layers *livekit.AnalyticsVideoLayer) *livekit.AnalyticsStat

type StatsWorker

+ func (s *StatsWorker) CleanUpTrackStats()

type TelemetryService

+ EgressEnded func(ctx context.Context, info *livekit.EgressInfo)

+ EgressStarted func(ctx context.Context, info *livekit.EgressInfo)

+ TrackMaxSubscribedVideoQuality func(ctx context.Context, participantID livekit.ParticipantID, ...)

v0.15.4

Feb 9, 2022

Changes in this version

type TelemetryService

+ ParticipantActive func(ctx context.Context, participantID livekit.ParticipantID, ...)

v0.15.3

Jan 29, 2022

Changes in this version

type StatsWorker

+ func (s *StatsWorker) OnTrackStat(trackID livekit.TrackID, direction livekit.StreamType, ...)

+ func (s *StatsWorker) RemoveStats(trackID livekit.TrackID)

type TelemetryService

+ TrackPublishedUpdate func(ctx context.Context, participantID livekit.ParticipantID, ...)

+ TrackStats func(streamType livekit.StreamType, participantID livekit.ParticipantID, ...)

v0.15.2

Jan 6, 2022

Changes in this version

+ const CompactNtpInSecond

+ const MaxCompactNtp

+ const MicroSecondsInSecond

+ const NanoSecondsInMicroSecond

+ const NtpInSecond

+ const NtpJan1970Sec

+ func GetRttMs(packet *rtcp.ReceiverReport) int64

+ func NtpToTimeMicros(val NtpTime) int64

+ func SaturatedUsToCompactNtp(us int64) uint32

+ type NtpTime struct

+ func NtpCompactToTime(val uint32) NtpTime

+ func TimeMicrosToNtp(time_us int64) *NtpTime

+ func (n *NtpTime) Compact() uint32

+ func (n *NtpTime) FromCompact(val uint32)

+ func (n *NtpTime) Ntp() uint64

+ func (n *NtpTime) Set(val uint64)

+ type TelemetryReporter interface

+ Report func(ctx context.Context, stats []*livekit.AnalyticsStat)

+ type TelemetryServiceInternal interface

+ SendAnalytics func()

+ func NewTelemetryServiceInternal(notifier webhook.Notifier, analytics AnalyticsService) TelemetryServiceInternal

v0.15.1

Dec 22, 2021

v0.15.0

Dec 22, 2021

Changes in this version

+ type AnalyticsService interface

+ SendEvent func(ctx context.Context, events *livekit.AnalyticsEvent)

+ SendStats func(ctx context.Context, stats []*livekit.AnalyticsStat)

+ func NewAnalyticsService(_ *config.Config, currentNode routing.LocalNode) AnalyticsService

v0.14.2

Nov 19, 2021

Changes in this version

+ type Stats struct

type StatsWorker

+ func (s *StatsWorker) OnDownstreamPacket(bytes int)

+ func (s *StatsWorker) OnRTCP(direction livekit.StreamType, stats *livekit.AnalyticsStat)

+ func (s *StatsWorker) Update()

type TelemetryService

+ func (t *TelemetryService) AddUpTrack(participantID string, buff *buffer.Buffer)

+ func (t *TelemetryService) HandleRTCP(streamType livekit.StreamType, participantID string, pkts []rtcp.Packet)

+ func (t *TelemetryService) OnDownstreamPacket(participantID string, bytes int)

+ func (t *TelemetryService) Report(stats []*livekit.AnalyticsStat)

v0.14.1

Nov 11, 2021

Changes in this version

+ type StatsInterceptor struct

+ func (s *StatsInterceptor) BindLocalStream(_ *interceptor.StreamInfo, writer interceptor.RTPWriter) interceptor.RTPWriter

+ func (s *StatsInterceptor) BindRTCPReader(reader interceptor.RTCPReader) interceptor.RTCPReader

+ func (s *StatsInterceptor) BindRTCPWriter(writer interceptor.RTCPWriter) interceptor.RTCPWriter

+ type StatsInterceptorFactory struct

+ func (f *StatsInterceptorFactory) NewInterceptor(id string) (interceptor.Interceptor, error)

+ type StatsWorker struct

+ func NewStatsWorker(onUpdate func(*buffer.Stats)) *StatsWorker

+ func (s *StatsWorker) AddBuffer(buffer *buffer.Buffer)

+ func (s *StatsWorker) Calc() *buffer.Stats

+ func (s *StatsWorker) Close()

+ func (s *StatsWorker) RemoveBuffer(ssrc uint32)

+ type TelemetryService struct

+ func NewTelemetryService(notifier webhook.Notifier) *TelemetryService

+ func (t *TelemetryService) HandleIncomingRTCP(participantID, identity string, bytes []byte)

+ func (t *TelemetryService) HandleIncomingRTP(participantID, identity string, diff *buffer.Stats)

+ func (t *TelemetryService) HandleOutgoingRTCP(participantID, identity string, pkts []rtcp.Packet)

+ func (t *TelemetryService) HandleOutgoingRTP(participantID, identity string, pktLen uint64)

+ func (t *TelemetryService) NewStatsInterceptorFactory(participantID, identity string) *StatsInterceptorFactory

+ func (t *TelemetryService) ParticipantJoined(ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo)

+ func (t *TelemetryService) ParticipantLeft(ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo)

+ func (t *TelemetryService) RecordingEnded(res *livekit.RecordingResult)

+ func (t *TelemetryService) RecordingStarted(ctx context.Context, recordingID string, req *livekit.StartRecordingRequest)

+ func (t *TelemetryService) RoomEnded(ctx context.Context, room *livekit.Room)

+ func (t *TelemetryService) RoomStarted(ctx context.Context, room *livekit.Room)

+ func (t *TelemetryService) TrackPublished(participantID, identity string, track *livekit.TrackInfo, buff *buffer.Buffer)

+ func (t *TelemetryService) TrackSubscribed(participantID, identity string, track *livekit.TrackInfo)

+ func (t *TelemetryService) TrackUnpublished(participantID, identity string, track *livekit.TrackInfo, ssrc uint32)

+ func (t *TelemetryService) TrackUnsubscribed(participantID, identity string, track *livekit.TrackInfo)

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