telemetry

package

v0.14.2 Latest Latest Go to latest Published: Nov 19, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/livekit/livekit-server

Links

Open Source Insights

Documentation ¶

Index ¶

type Stats
type StatsInterceptor
- func (s *StatsInterceptor) BindRTCPWriter(writer interceptor.RTCPWriter) interceptor.RTCPWriter
type StatsInterceptorFactory
- func (f *StatsInterceptorFactory) NewInterceptor(id string) (interceptor.Interceptor, error)
type StatsWorker
- func NewStatsWorker(t *TelemetryService, roomID, participantID string) *StatsWorker
type TelemetryService
- func NewTelemetryService(notifier webhook.Notifier) *TelemetryService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Stats ¶ added in v0.14.2

type Stats struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type StatsInterceptor ¶

type StatsInterceptor struct {
	interceptor.NoOp
	// contains filtered or unexported fields
}

func (*StatsInterceptor) BindRTCPWriter ¶

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

BindRTCPWriter lets you modify any outgoing RTCP packets. It is called once per PeerConnection. The returned method will be called once per packet batch.

type StatsInterceptorFactory ¶

type StatsInterceptorFactory struct {
	// contains filtered or unexported fields
}

func (*StatsInterceptorFactory) NewInterceptor ¶

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

type StatsWorker ¶

type StatsWorker struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

StatsWorker handles participant stats

func NewStatsWorker ¶

func NewStatsWorker(t *TelemetryService, roomID, participantID string) *StatsWorker

func (*StatsWorker) AddBuffer ¶

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

func (*StatsWorker) Close ¶

func (s *StatsWorker) Close()

func (*StatsWorker) OnDownstreamPacket ¶ added in v0.14.2

func (s *StatsWorker) OnDownstreamPacket(bytes int)

func (*StatsWorker) OnRTCP ¶ added in v0.14.2

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

func (*StatsWorker) RemoveBuffer ¶

func (s *StatsWorker) RemoveBuffer(ssrc uint32)

func (*StatsWorker) Update ¶ added in v0.14.2

func (s *StatsWorker) Update()

type TelemetryService ¶

type TelemetryService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewTelemetryService ¶

func NewTelemetryService(notifier webhook.Notifier) *TelemetryService

func (*TelemetryService) AddUpTrack ¶ added in v0.14.2

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

func (*TelemetryService) HandleRTCP ¶ added in v0.14.2

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

func (*TelemetryService) NewStatsInterceptorFactory ¶

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

func (*TelemetryService) OnDownstreamPacket ¶ added in v0.14.2

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

func (*TelemetryService) ParticipantJoined ¶

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

func (*TelemetryService) ParticipantLeft ¶

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

func (*TelemetryService) RecordingEnded ¶

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

func (*TelemetryService) RecordingStarted ¶

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

func (*TelemetryService) Report ¶ added in v0.14.2

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

func (*TelemetryService) RoomEnded ¶

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

func (*TelemetryService) RoomStarted ¶

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

func (*TelemetryService) TrackPublished ¶

func (t *TelemetryService) TrackPublished(participantID string, track *livekit.TrackInfo)

func (*TelemetryService) TrackSubscribed ¶

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

func (*TelemetryService) TrackUnpublished ¶

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

func (*TelemetryService) TrackUnsubscribed ¶

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
prometheus

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