MCPcopy Create free account

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

⨍ Functions 7,437◇ Types & classes 718
MethodDistanceToDesired
()
pkg/sfu/streamtrackermanager.go:418
MethodDownTrack
()
pkg/rtc/types/typesfakes/fake_subscribed_track.go:242
MethodDownTrack
()
pkg/sfu/streamallocator/track.go:108
MethodDownTrackCallCount
()
pkg/rtc/types/typesfakes/fake_subscribed_track.go:260
MethodDownTrackCalls
(stub func() *sfu.DownTrack)
pkg/rtc/types/typesfakes/fake_subscribed_track.go:266
MethodDownTrackReturns
(result1 *sfu.DownTrack)
pkg/rtc/types/typesfakes/fake_subscribed_track.go:272
MethodDownTrackReturnsOnCall
(i int, result1 *sfu.DownTrack)
pkg/rtc/types/typesfakes/fake_subscribed_track.go:281
MethodDrain
()
pkg/routing/redisrouter.go:185
MethodDrain
()
pkg/routing/localrouter.go:137
MethodDrain
()
pkg/routing/routingfakes/fake_router.go:282
MethodDrainCallCount
()
pkg/routing/routingfakes/fake_router.go:294
MethodDrainCalls
(stub func())
pkg/routing/routingfakes/fake_router.go:300
MethodDrainConnections
(interval time.Duration, force bool)
pkg/service/agentservice.go:488
MethodDrainConnections
(interval time.Duration, force bool)
pkg/service/rtcservice.go:631
MethodEgressEnded
(ctx context.Context, info *livekit.EgressInfo)
pkg/telemetry/telemetryservice.go:145
MethodEgressEnded
(ctx context.Context, info *livekit.EgressInfo)
pkg/telemetry/events.go:513
MethodEgressEnded
(arg1 context.Context, arg2 *livekit.EgressInfo)
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:357
MethodEgressEndedArgsForCall
(i int)
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:383
MethodEgressEndedCallCount
()
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:371
MethodEgressEndedCalls
(stub func(context.Context, *livekit.EgressInfo))
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:377
MethodEgressStarted
(ctx context.Context, info *livekit.EgressInfo)
pkg/telemetry/telemetryservice.go:143
MethodEgressStarted
(ctx context.Context, info *livekit.EgressInfo)
pkg/telemetry/events.go:496
MethodEgressStarted
(arg1 context.Context, arg2 *livekit.EgressInfo)
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:390
MethodEgressStartedArgsForCall
(i int)
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:416
MethodEgressStartedCallCount
()
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:404
MethodEgressStartedCalls
(stub func(context.Context, *livekit.EgressInfo))
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:410
MethodEgressUpdated
(ctx context.Context, info *livekit.EgressInfo)
pkg/telemetry/telemetryservice.go:144
MethodEgressUpdated
(ctx context.Context, info *livekit.EgressInfo)
pkg/telemetry/events.go:505
MethodEgressUpdated
(arg1 context.Context, arg2 *livekit.EgressInfo)
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:423
MethodEgressUpdatedArgsForCall
(i int)
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:449
MethodEgressUpdatedCallCount
()
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:437
MethodEgressUpdatedCalls
(stub func(context.Context, *livekit.EgressInfo))
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:443
MethodEndProbeCluster
(probeClusterId ccutils.ProbeClusterId)
pkg/sfu/pacer/probe_observer.go:69
MethodEnqueue
(fn func(T), arg T)
pkg/utils/opsqueue.go:63
MethodEnqueue
(op T)
pkg/utils/opsqueue.go:118
MethodEnqueue
(pkt *Packet)
pkg/sfu/pacer/pass_through.go:35
MethodEnqueue
(p *Packet)
pkg/sfu/pacer/leaky_bucket.go:74
MethodEnqueue
(p *Packet)
pkg/sfu/pacer/no_queue.go:58
MethodEquals
(rhs tengo.Object)
pkg/clientconfiguration/match.go:156
MethodEvaluateSIPDispatchRules
(ctx context.Context, req *rpc.EvaluateSIPDispatchRulesRequest)
pkg/service/ioservice_sip.go:84
MethodExtHighestSequenceNumber
()
pkg/sfu/rtpstats/rtpstats_sender_lite.go:90
MethodFilterRTX
(nacks []uint16)
pkg/sfu/rtpmunger.go:261
MethodFlushStats
()
pkg/telemetry/telemetryservice.go:157
MethodFlushStats
()
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:456
MethodFlushStatsCallCount
()
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:468
MethodFlushStatsCalls
(stub func())
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:474
MethodForceEnable
It is possible for tracks to be in pending close state. When track is waiting to be closed, a node is not streaming a track. This can be used to force
pkg/rtc/dynacast/dynacastmanageraudio.go:83
MethodForceEnable
(enabled bool)
pkg/rtc/dynacast/interfaces.go:57
MethodForceEnable
(enabled bool)
pkg/rtc/dynacast/interfaces.go:92
MethodForceQuality
It is possible for tracks to be in pending close state. When track is waiting to be closed, a node is not streaming a track. This can be used to force
pkg/rtc/dynacast/dynacastmanagervideo.go:96
MethodForceQuality
(quality livekit.VideoQuality)
pkg/rtc/dynacast/interfaces.go:56
MethodForceQuality
(quality livekit.VideoQuality)
pkg/rtc/dynacast/interfaces.go:91
MethodForceUpdate
()
pkg/rtc/dynacast/interfaces.go:90
MethodForceUpdate
There are situations like track unmute or streaming from a different node where subscription changes needs to sent to the provider immediately. This b
pkg/rtc/dynacast/dynacastmanagerbase.go:131
MethodForwardParticipant
(ctx context.Context, req *livekit.ForwardParticipantRequest)
pkg/service/roommanager.go:899
MethodForwardParticipant
(ctx context.Context, req *livekit.ForwardParticipantRequest)
pkg/service/roomservice.go:360
MethodForwardRTCPSenderReport
( payloadType webrtc.PayloadType, layer int32, publisherSRData *livekit.RTCPSenderReportState, )
pkg/sfu/redprimaryreceiver.go:135
MethodForwardRTCPSenderReport
( payloadType webrtc.PayloadType, layer int32, publisherSRData *livekit.RTCPSenderReportState, )
pkg/sfu/redreceiver.go:100
MethodForwardRTP
(pkt *buffer.ExtPacket, spatialLayer int32)
pkg/sfu/redprimaryreceiver.go:64
MethodForwardRTP
(pkt *buffer.ExtPacket, spatialLayer int32)
pkg/sfu/redreceiver.go:64
FunctionGenerate
regenerate code
magefile.go:196
MethodGet
(dbKey *livekit.DataBlobKey)
pkg/rtc/participant_data_blob.go:63
MethodGetActiveClusterId
()
pkg/sfu/ccutils/prober.go:220
MethodGetAdaptiveStream
()
pkg/rtc/participant.go:512
MethodGetAdaptiveStream
()
pkg/rtc/types/typesfakes/fake_local_participant.go:2563
MethodGetAdaptiveStreamCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:2581
MethodGetAdaptiveStreamCalls
(stub func() bool)
pkg/rtc/types/typesfakes/fake_local_participant.go:2587
MethodGetAdaptiveStreamReturns
(result1 bool)
pkg/rtc/types/typesfakes/fake_local_participant.go:2593
MethodGetAdaptiveStreamReturnsOnCall
(i int, result1 bool)
pkg/rtc/types/typesfakes/fake_local_participant.go:2602
MethodGetAllDataBlob
()
pkg/rtc/participant_data_blob_handler.go:111
MethodGetAllDataBlob
()
pkg/rtc/types/interfaces.go:582
MethodGetAllDataBlob
()
pkg/rtc/types/typesfakes/fake_local_participant.go:2616
MethodGetAllDataBlobCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:2634
MethodGetAllDataBlobCalls
(stub func() []*livekit.DataBlob)
pkg/rtc/types/typesfakes/fake_local_participant.go:2640
MethodGetAllDataBlobReturns
(result1 []*livekit.DataBlob)
pkg/rtc/types/typesfakes/fake_local_participant.go:2646
MethodGetAllDataBlobReturnsOnCall
(i int, result1 []*livekit.DataBlob)
pkg/rtc/types/typesfakes/fake_local_participant.go:2655
MethodGetAllSubscribers
()
pkg/rtc/mediatracksubscriptions.go:296
MethodGetAllSubscribers
()
pkg/rtc/types/typesfakes/fake_local_media_track.go:566
MethodGetAllSubscribers
()
pkg/rtc/types/typesfakes/fake_media_track.go:467
MethodGetAllSubscribersCallCount
()
pkg/rtc/types/typesfakes/fake_local_media_track.go:584
MethodGetAllSubscribersCallCount
()
pkg/rtc/types/typesfakes/fake_media_track.go:485
MethodGetAllSubscribersCalls
(stub func() []livekit.ParticipantID)
pkg/rtc/types/typesfakes/fake_local_media_track.go:590
MethodGetAllSubscribersCalls
(stub func() []livekit.ParticipantID)
pkg/rtc/types/typesfakes/fake_media_track.go:491
MethodGetAllSubscribersReturns
(result1 []livekit.ParticipantID)
pkg/rtc/types/typesfakes/fake_local_media_track.go:596
MethodGetAllSubscribersReturns
(result1 []livekit.ParticipantID)
pkg/rtc/types/typesfakes/fake_media_track.go:497
MethodGetAllSubscribersReturnsOnCall
(i int, result1 []livekit.ParticipantID)
pkg/rtc/types/typesfakes/fake_local_media_track.go:605
MethodGetAllSubscribersReturnsOnCall
(i int, result1 []livekit.ParticipantID)
pkg/rtc/types/typesfakes/fake_media_track.go:506
MethodGetAnswer
()
pkg/rtc/transport.go:1691
MethodGetAnswer
()
pkg/rtc/transportmanager.go:526
MethodGetAnswer
()
pkg/rtc/participant.go:1243
MethodGetAnswer
()
pkg/rtc/types/typesfakes/fake_local_participant.go:2669
MethodGetAnswerCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:2687
MethodGetAnswerCalls
(stub func() (webrtc.SessionDescription, uint32, error))
pkg/rtc/types/typesfakes/fake_local_participant.go:2693
MethodGetAnswerReturns
(result1 webrtc.SessionDescription, result2 uint32, result3 error)
pkg/rtc/types/typesfakes/fake_local_participant.go:2699
MethodGetAnswerReturnsOnCall
(i int, result1 webrtc.SessionDescription, result2 uint32, result3 error)
pkg/rtc/types/typesfakes/fake_local_participant.go:2710
FunctionGetAttempt
(ctx context.Context)
pkg/utils/context.go:32
MethodGetAudioLevel
()
pkg/rtc/mediatrackreceiver.go:1130
MethodGetAudioLevel
()
pkg/rtc/wrappedreceiver.go:314
MethodGetAudioLevel
()
pkg/rtc/uptrackmanager.go:445
MethodGetAudioLevel
()
pkg/rtc/types/interfaces.go:329
← previousnext →3,501–3,600 of 7,437, ranked by callers