( ctx context.Context, roomID livekit.RoomID, roomName livekit.RoomName, participantID livekit.ParticipantID, trackID livekit.TrackID, mimeType mime.MimeType, stats *livekit.RTPStats, )
| 465 | } |
| 466 | |
| 467 | func (t *telemetryService) TrackSubscribeRTPStats( |
| 468 | ctx context.Context, |
| 469 | roomID livekit.RoomID, |
| 470 | roomName livekit.RoomName, |
| 471 | participantID livekit.ParticipantID, |
| 472 | trackID livekit.TrackID, |
| 473 | mimeType mime.MimeType, |
| 474 | stats *livekit.RTPStats, |
| 475 | ) { |
| 476 | t.enqueue(func() { |
| 477 | room := toMinimalRoomProto(roomID, roomName) |
| 478 | ev := newRoomEvent(livekit.AnalyticsEventType_TRACK_SUBSCRIBE_STATS, room) |
| 479 | ev.ParticipantId = string(participantID) |
| 480 | ev.TrackId = string(trackID) |
| 481 | ev.Mime = mimeType.String() |
| 482 | ev.RtpStats = stats |
| 483 | t.SendEvent(ctx, ev) |
| 484 | }) |
| 485 | } |
| 486 | |
| 487 | func (t *telemetryService) NotifyEgressEvent(ctx context.Context, event string, info *livekit.EgressInfo) { |
| 488 | opts := egress.GetEgressNotifyOptions(info) |
nothing calls this directly
no test coverage detected