MCPcopy Create free account

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

MethodStartParticipantSignalCallCount
()
pkg/routing/routingfakes/fake_router.go:723
MethodStartParticipantSignalCalls
(stub func(context.Context, livekit.RoomName, routing.ParticipantInit, livekit.NodeID) (livekit.ConnectionID,
pkg/routing/routingfakes/fake_signal_client.go:128
MethodStartParticipantSignalCalls
(stub func(context.Context, livekit.RoomName, routing.ParticipantInit) (routing.StartParticipantSignalResults,
pkg/routing/routingfakes/fake_router.go:729
MethodStartParticipantSignalReturns
(result1 livekit.ConnectionID, result2 routing.MessageSink, result3 routing.MessageSource, result4 error)
pkg/routing/routingfakes/fake_signal_client.go:141
MethodStartParticipantSignalReturns
(result1 routing.StartParticipantSignalResults, result2 error)
pkg/routing/routingfakes/fake_router.go:742
MethodStartParticipantSignalReturnsOnCall
(i int, result1 livekit.ConnectionID, result2 routing.MessageSink, result3 routing.MessageSource, result4 erro
pkg/routing/routingfakes/fake_signal_client.go:153
MethodStartParticipantSignalReturnsOnCall
(i int, result1 routing.StartParticipantSignalResults, result2 error)
pkg/routing/routingfakes/fake_router.go:752
MethodStartProbeCluster
(pci ccutils.ProbeClusterInfo)
pkg/sfu/pacer/probe_observer.go:49
MethodStartReturns
(result1 error)
pkg/routing/routingfakes/fake_router.go:679
MethodStartReturnsOnCall
(i int, result1 error)
pkg/routing/routingfakes/fake_router.go:688
MethodStartRoomCompositeEgress
(ctx context.Context, req *livekit.RoomCompositeEgressRequest)
pkg/service/egress.go:102
MethodStartTrackCompositeEgress
(ctx context.Context, req *livekit.TrackCompositeEgressRequest)
pkg/service/egress.go:177
MethodStartTrackEgress
(ctx context.Context, req *livekit.TrackEgressRequest)
pkg/service/egress.go:203
MethodStartWebEgress
(ctx context.Context, req *livekit.WebEgressRequest)
pkg/service/egress.go:128
MethodState
()
pkg/rtc/types/typesfakes/fake_participant.go:1940
MethodState
()
pkg/rtc/types/typesfakes/fake_local_participant.go:8282
MethodStateCallCount
()
pkg/rtc/types/typesfakes/fake_participant.go:1958
MethodStateCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:8300
MethodStateCalls
(stub func() livekit.ParticipantInfo_State)
pkg/rtc/types/typesfakes/fake_participant.go:1964
MethodStateCalls
(stub func() livekit.ParticipantInfo_State)
pkg/rtc/types/typesfakes/fake_local_participant.go:8306
MethodStateReturnsOnCall
(i int, result1 livekit.ParticipantInfo_State)
pkg/rtc/types/typesfakes/fake_participant.go:1979
MethodStateReturnsOnCall
(i int, result1 livekit.ParticipantInfo_State)
pkg/rtc/types/typesfakes/fake_local_participant.go:8321
MethodStatus
()
pkg/sfu/streamtracker/streamtracker.go:93
MethodStatus
(layer int32)
pkg/sfu/streamtracker/streamtracker_dd.go:80
MethodStatus
()
pkg/sfu/streamtracker/streamtracker_dd.go:297
MethodStatus
()
pkg/agent/worker.go:295
MethodStop
()
pkg/utils/iceconfigcache.go:29
MethodStop
()
pkg/utils/opsqueue.go:105
MethodStop
()
pkg/service/signal.go:123
MethodStop
()
pkg/service/roommanager.go:242
MethodStop
()
pkg/service/ioservice.go:83
MethodStop
()
pkg/service/redisstore.go:119
MethodStop
()
pkg/metric/metrics_collector.go:79
MethodStop
()
pkg/metric/metrics_reporter.go:73
MethodStop
()
pkg/rtc/supervisor/participant_supervisor.go:64
MethodStop
()
pkg/rtc/dynacast/dynacastqualityaudio.go:64
MethodStop
()
pkg/rtc/dynacast/dynacastqualityvideo.go:70
MethodStop
()
pkg/rtc/dynacast/interfaces.go:171
MethodStop
()
pkg/sfu/forwardstats.go:92
MethodStop
()
pkg/sfu/pacer/pass_through.go:32
MethodStop
()
pkg/sfu/pacer/leaky_bucket.go:70
MethodStop
()
pkg/sfu/pacer/no_queue.go:49
MethodStop
()
pkg/sfu/streamallocator/streamallocator.go:292
MethodStop
()
pkg/sfu/streamtracker/streamtracker_packet.go:92
MethodStop
()
pkg/sfu/streamtracker/streamtracker_frame.go:98
MethodStop
()
pkg/sfu/streamtracker/interfaces.go:62
MethodStop
()
pkg/sfu/streamtracker/streamtracker.go:127
MethodStop
()
pkg/sfu/rtpstats/rtpstats_base_lite.go:193
MethodStop
()
pkg/routing/redisrouter.go:192
MethodStop
()
pkg/routing/localrouter.go:141
MethodStop
()
pkg/routing/interfaces.go:143
MethodStop
()
pkg/routing/routingfakes/fake_router.go:768
MethodStop
()
pkg/agent/client.go:327
MethodStop
()
test/webhook_test.go:239
MethodStop
()
test/client/datatrack_writer.go:49
MethodStop
()
test/client/trackwriter.go:103
MethodStopAndGetSubscribedTracksForwarderState
()
pkg/rtc/subscriptionmanager.go:324
MethodStopAndGetSubscribedTracksForwarderState
()
pkg/rtc/types/interfaces.go:487
MethodStopAndGetSubscribedTracksForwarderState
()
pkg/rtc/types/typesfakes/fake_local_participant.go:8335
MethodStopAndGetSubscribedTracksForwarderStateCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:8353
MethodStopAndGetSubscribedTracksForwarderStateCalls
(stub func() map[livekit.TrackID]*livekit.RTPForwarderState)
pkg/rtc/types/typesfakes/fake_local_participant.go:8359
MethodStopAndGetSubscribedTracksForwarderStateReturns
(result1 map[livekit.TrackID]*livekit.RTPForwarderState)
pkg/rtc/types/typesfakes/fake_local_participant.go:8365
MethodStopAndGetSubscribedTracksForwarderStateReturnsOnCall
(i int, result1 map[livekit.TrackID]*livekit.RTPForwarderState)
pkg/rtc/types/typesfakes/fake_local_participant.go:8374
MethodStopCallCount
()
pkg/routing/routingfakes/fake_router.go:780
MethodStopCalls
(stub func())
pkg/routing/routingfakes/fake_router.go:786
MethodStopEgress
(ctx context.Context, req *livekit.StopEgressRequest)
pkg/service/egress.go:363
MethodStopEgress
(ctx context.Context, req *livekit.StopEgressRequest)
pkg/service/egress.go:397
MethodStoreAgentDispatch
(ctx context.Context, dispatch *livekit.AgentDispatch)
pkg/service/localstore.go:202
MethodStoreAgentDispatch
(ctx context.Context, dispatch *livekit.AgentDispatch)
pkg/service/interfaces.go:109
MethodStoreAgentDispatch
(_ context.Context, dispatch *livekit.AgentDispatch)
pkg/service/redisstore.go:853
MethodStoreAgentDispatch
(arg1 context.Context, arg2 *livekit.AgentDispatch)
pkg/service/servicefakes/fake_agent_store.go:268
MethodStoreAgentDispatchArgsForCall
(i int)
pkg/service/servicefakes/fake_agent_store.go:300
MethodStoreAgentDispatchCallCount
()
pkg/service/servicefakes/fake_agent_store.go:288
MethodStoreAgentDispatchCalls
(stub func(context.Context, *livekit.AgentDispatch) error)
pkg/service/servicefakes/fake_agent_store.go:294
MethodStoreAgentDispatchReturns
(result1 error)
pkg/service/servicefakes/fake_agent_store.go:307
MethodStoreAgentDispatchReturnsOnCall
(i int, result1 error)
pkg/service/servicefakes/fake_agent_store.go:316
MethodStoreAgentJob
(ctx context.Context, job *livekit.Job)
pkg/service/localstore.go:266
MethodStoreAgentJob
(ctx context.Context, job *livekit.Job)
pkg/service/interfaces.go:113
MethodStoreAgentJob
(_ context.Context, job *livekit.Job)
pkg/service/redisstore.go:910
MethodStoreAgentJob
(arg1 context.Context, arg2 *livekit.Job)
pkg/service/servicefakes/fake_agent_store.go:330
MethodStoreAgentJobArgsForCall
(i int)
pkg/service/servicefakes/fake_agent_store.go:362
MethodStoreAgentJobCallCount
()
pkg/service/servicefakes/fake_agent_store.go:350
MethodStoreAgentJobCalls
(stub func(context.Context, *livekit.Job) error)
pkg/service/servicefakes/fake_agent_store.go:356
MethodStoreAgentJobReturns
(result1 error)
pkg/service/servicefakes/fake_agent_store.go:369
MethodStoreAgentJobReturnsOnCall
(i int, result1 error)
pkg/service/servicefakes/fake_agent_store.go:378
MethodStoreEgress
(_ context.Context, info *livekit.EgressInfo)
pkg/service/redisstore.go:360
MethodStoreEgress
(arg1 context.Context, arg2 *livekit.EgressInfo)
pkg/service/servicefakes/fake_egress_store.go:201
MethodStoreEgressArgsForCall
(i int)
pkg/service/servicefakes/fake_egress_store.go:233
MethodStoreEgressCallCount
()
pkg/service/servicefakes/fake_egress_store.go:221
MethodStoreEgressCalls
(stub func(context.Context, *livekit.EgressInfo) error)
pkg/service/servicefakes/fake_egress_store.go:227
MethodStoreEgressReturns
(result1 error)
pkg/service/servicefakes/fake_egress_store.go:240
MethodStoreEgressReturnsOnCall
(i int, result1 error)
pkg/service/servicefakes/fake_egress_store.go:249
MethodStoreIngress
(ctx context.Context, info *livekit.IngressInfo)
pkg/service/redisstore.go:533
MethodStoreIngress
(arg1 context.Context, arg2 *livekit.IngressInfo)
pkg/service/servicefakes/fake_ingress_store.go:365
MethodStoreIngressArgsForCall
(i int)
pkg/service/servicefakes/fake_ingress_store.go:397
MethodStoreIngressCallCount
()
pkg/service/servicefakes/fake_ingress_store.go:385
MethodStoreIngressCalls
(stub func(context.Context, *livekit.IngressInfo) error)
pkg/service/servicefakes/fake_ingress_store.go:391
MethodStoreIngressReturns
(result1 error)
pkg/service/servicefakes/fake_ingress_store.go:404
MethodStoreIngressReturnsOnCall
(i int, result1 error)
pkg/service/servicefakes/fake_ingress_store.go:413
MethodStoreParticipant
(_ context.Context, roomName livekit.RoomName, participant *livekit.ParticipantInfo)
pkg/service/localstore.go:141
← previousnext →6,301–6,400 of 7,437, ranked by callers