telemetry

type AnalyticsService interface {
	SendStats(ctx context.Context, stats []*livekit.AnalyticsStat)
	SendEvent(ctx context.Context, events *livekit.AnalyticsEvent)
}

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

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

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

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

type TelemetryService interface {
	// stats
	NewStatsInterceptorFactory(participantID, identity string) *StatsInterceptorFactory
	AddUpTrack(participantID string, buff *buffer.Buffer)
	OnDownstreamPacket(participantID string, bytes int)
	HandleRTCP(streamType livekit.StreamType, participantID string, pkts []rtcp.Packet)
	Report(ctx context.Context, stats []*livekit.AnalyticsStat)

	// events
	RoomStarted(ctx context.Context, room *livekit.Room)
	RoomEnded(ctx context.Context, room *livekit.Room)
	ParticipantJoined(ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo, clientInfo *livekit.ClientInfo)
	ParticipantLeft(ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo)
	TrackPublished(ctx context.Context, participantID string, track *livekit.TrackInfo)
	TrackUnpublished(ctx context.Context, participantID string, track *livekit.TrackInfo, ssrc uint32)
	TrackSubscribed(ctx context.Context, participantID string, track *livekit.TrackInfo)
	TrackUnsubscribed(ctx context.Context, participantID string, track *livekit.TrackInfo)
	RecordingStarted(ctx context.Context, ri *livekit.RecordingInfo)
	RecordingEnded(ctx context.Context, ri *livekit.RecordingInfo)
}