Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/livekit/livekit
/ functions
Functions
7,437 in github.com/livekit/livekit
⨍
Functions
7,437
◇
Types & classes
718
Method
ParticipantJoined
(ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo, clientInfo *livekit.ClientInfo
pkg/telemetry/telemetryservice.go:109
Method
ParticipantJoined
( ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo, clientInfo *livekit.Clien
pkg/telemetry/events.go:76
Method
ParticipantJoined
(arg1 context.Context, arg2 *livekit.Room, arg3 *livekit.ParticipantInfo, arg4 *livekit.ClientInfo, arg5 *live
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:749
Method
ParticipantJoinedArgsForCall
(i int)
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:780
Method
ParticipantJoinedCallCount
()
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:768
Method
ParticipantJoinedCalls
(stub func(context.Context, *livekit.Room, *livekit.ParticipantInfo, *livekit.ClientInfo, *livekit.AnalyticsCl
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:774
Method
ParticipantLeft
(ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo, shouldSendEvent bool, guard *R
pkg/telemetry/telemetryservice.go:115
Method
ParticipantLeft
(ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo, shouldSendEvent bool, guar
pkg/telemetry/events.go:184
Method
ParticipantLeft
(arg1 context.Context, arg2 *livekit.Room, arg3 *livekit.ParticipantInfo, arg4 bool, arg5 *telemetry.Reference
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:787
Method
ParticipantLeftArgsForCall
(i int)
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:816
Method
ParticipantLeftCallCount
()
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:804
Method
ParticipantLeftCalls
(stub func(context.Context, *livekit.Room, *livekit.ParticipantInfo, bool, *telemetry.ReferenceGuard))
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:810
Method
ParticipantResumed
(ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo, nodeID livekit.NodeID, reason
pkg/telemetry/telemetryservice.go:113
Method
ParticipantResumed
( ctx context.Context, room *livekit.Room, participant *livekit.ParticipantInfo, nodeID livekit.NodeID, r
pkg/telemetry/events.go:146
Method
ParticipantResumed
(arg1 context.Context, arg2 *livekit.Room, arg3 *livekit.ParticipantInfo, arg4 livekit.NodeID, arg5 livekit.Re
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:823
Method
ParticipantResumedArgsForCall
(i int)
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:852
Method
ParticipantResumedCallCount
()
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:840
Method
ParticipantResumedCalls
(stub func(context.Context, *livekit.Room, *livekit.ParticipantInfo, livekit.NodeID, livekit.ReconnectReason))
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:846
Method
Pause
(availableLayers []int32, brs Bitrates)
pkg/sfu/forwarder.go:1613
Method
PerformRpc
(ctx context.Context, req *livekit.PerformRpcRequest)
pkg/service/roommanager.go:907
Method
PerformRpc
(ctx context.Context, req *livekit.PerformRpcRequest)
pkg/service/roomservice.go:396
Method
PerformRpc
(req *livekit.PerformRpcRequest, resultCh chan string, errorCh chan error)
pkg/rtc/participant.go:4235
Method
PerformRpc
(arg1 *livekit.PerformRpcRequest, arg2 chan string, arg3 chan error)
pkg/rtc/types/typesfakes/fake_local_participant.go:6901
Method
PerformRpcArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_local_participant.go:6928
Method
PerformRpcCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:6916
Method
PerformRpcCalls
(stub func(*livekit.PerformRpcRequest, chan string, chan error))
pkg/rtc/types/typesfakes/fake_local_participant.go:6922
Method
PostEvent
(ome types.OperationMonitorEvent, omd types.OperationMonitorData)
pkg/rtc/supervisor/publication_monitor.go:69
Method
Priority
()
pkg/sfu/streamallocator/track.go:104
Method
ProbeClusterDone
(_pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/null_bwe.go:67
Method
ProbeClusterDone
(pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/remotebwe/probe_controller.go:138
Method
ProbeClusterDone
(pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/remotebwe/remote_bwe.go:281
Method
ProbeClusterDone
(pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/sendsidebwe/probe_packet_group.go:81
Method
ProbeClusterDone
(probeClusterId ccutils.ProbeClusterId)
pkg/sfu/bwe/sendsidebwe/packet_tracker.go:154
Method
ProbeClusterDone
(pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:795
Method
ProbeClusterDone
(pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/sendsidebwe/send_side_bwe.go:139
Method
ProbeClusterFinalize
()
pkg/sfu/bwe/null_bwe.go:73
Method
ProbeClusterFinalize
()
pkg/sfu/bwe/remotebwe/remote_bwe.go:301
Method
ProbeClusterFinalize
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:822
Method
ProbeClusterFinalize
()
pkg/sfu/bwe/sendsidebwe/send_side_bwe.go:147
Method
ProbeClusterIsGoalReached
()
pkg/sfu/bwe/null_bwe.go:69
Method
ProbeClusterIsGoalReached
(estimate int64)
pkg/sfu/bwe/remotebwe/probe_controller.go:147
Method
ProbeClusterIsGoalReached
()
pkg/sfu/bwe/remotebwe/remote_bwe.go:288
Method
ProbeClusterIsGoalReached
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:805
Method
ProbeClusterIsGoalReached
()
pkg/sfu/bwe/sendsidebwe/send_side_bwe.go:143
Method
ProbeClusterStarting
(_pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/null_bwe.go:65
Method
ProbeClusterStarting
(pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/remotebwe/probe_controller.go:129
Method
ProbeClusterStarting
(pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/remotebwe/remote_bwe.go:264
Method
ProbeClusterStarting
(probeClusterId ccutils.ProbeClusterId)
pkg/sfu/bwe/sendsidebwe/packet_tracker.go:147
Method
ProbeClusterStarting
(pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:779
Method
ProbeClusterStarting
(pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/sendsidebwe/send_side_bwe.go:135
Method
ProbeDuration
()
pkg/sfu/bwe/null_bwe.go:61
Method
ProbeDuration
()
pkg/sfu/bwe/remotebwe/remote_bwe.go:257
Method
ProbeDuration
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:772
Method
ProbeDuration
()
pkg/sfu/bwe/sendsidebwe/send_side_bwe.go:131
Method
ProbeDuration
()
pkg/sfu/ccutils/probe_regulator.go:76
Method
ProbeSignal
(probeSignal ProbeSignal, baseTime time.Time)
pkg/sfu/ccutils/probe_regulator.go:80
Method
ProbesSent
(bytesSent int)
pkg/sfu/ccutils/prober.go:531
Method
Process
(batch *livekit.MetricsBatch)
pkg/metric/metric_timestamper.go:65
Method
ProcessGetDataBlobRequest
(req *livekit.GetDataBlobRequest, publisher types.Participant)
pkg/rtc/participant_data_blob_handler.go:88
Method
ProcessGetDataBlobRequest
(arg1 *livekit.GetDataBlobRequest, arg2 types.Participant)
pkg/rtc/types/typesfakes/fake_local_participant.go:6935
Method
ProcessGetDataBlobRequestArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_local_participant.go:6961
Method
ProcessGetDataBlobRequestCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:6949
Method
ProcessGetDataBlobRequestCalls
(stub func(*livekit.GetDataBlobRequest, types.Participant))
pkg/rtc/types/typesfakes/fake_local_participant.go:6955
Method
ProcessPacketGroup
(pg *packetGroup, groupIdx int)
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:369
Method
ProtocolVersion
()
pkg/rtc/types/typesfakes/fake_local_participant.go:6968
Method
ProtocolVersionCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:6986
Method
ProtocolVersionCalls
(stub func() types.ProtocolVersion)
pkg/rtc/types/typesfakes/fake_local_participant.go:6992
Method
ProtocolVersionReturnsOnCall
(i int, result1 types.ProtocolVersion)
pkg/rtc/types/typesfakes/fake_local_participant.go:7007
Method
ProvisionalAllocate
(availableChannelCapacity int64, layer buffer.VideoLayer, allowPause bool, allowOvershoot bool)
pkg/sfu/forwarder.go:1062
Method
ProvisionalAllocateCommit
()
pkg/sfu/forwarder.go:1337
Method
ProvisionalAllocateGetBestWeightedTransition
()
pkg/sfu/forwarder.go:1241
Method
ProvisionalAllocateGetCooperativeTransition
(allowOvershoot bool)
pkg/sfu/forwarder.go:1106
Method
ProvisionalAllocatePrepare
(availableLayers []int32, bitrates Bitrates)
pkg/sfu/forwarder.go:1031
Method
ProvisionalAllocateReset
()
pkg/sfu/downtrack.go:1678
Method
ProvisionalAllocateReset
()
pkg/sfu/forwarder.go:1055
Method
PubHandle
()
pkg/rtc/types/typesfakes/fake_data_track.go:531
Method
PubHandleCallCount
()
pkg/rtc/types/typesfakes/fake_data_track.go:549
Method
PubHandleCalls
(stub func() uint16)
pkg/rtc/types/typesfakes/fake_data_track.go:555
Method
PubHandleReturns
(result1 uint16)
pkg/rtc/types/typesfakes/fake_data_track.go:561
Method
PubHandleReturnsOnCall
(i int, result1 uint16)
pkg/rtc/types/typesfakes/fake_data_track.go:570
Method
PubMute
(pubMuted bool)
pkg/sfu/forwarder.go:566
Method
PublishDataTrack
()
pkg/rtc/datadowntrack.go:101
Method
PublishDataTrack
()
pkg/rtc/types/typesfakes/fake_data_down_track.go:159
Method
PublishDataTrack
()
test/client/client.go:1040
Method
PublishDataTrackCallCount
()
pkg/rtc/types/typesfakes/fake_data_down_track.go:177
Method
PublishDataTrackCalls
(stub func() types.DataTrack)
pkg/rtc/types/typesfakes/fake_data_down_track.go:183
Method
PublishDataTrackReturnsOnCall
(i int, result1 types.DataTrack)
pkg/rtc/types/typesfakes/fake_data_down_track.go:198
Function
PublishDocker
builds and publish snapshot docker image
magefile.go:150
Method
PublisherID
()
pkg/rtc/datatrack.go:92
Method
PublisherID
()
pkg/rtc/types/interfaces.go:884
Method
PublisherID
()
pkg/rtc/types/typesfakes/fake_data_track.go:584
Method
PublisherID
()
pkg/rtc/types/typesfakes/fake_subscribed_track.go:592
Method
PublisherID
()
pkg/rtc/types/typesfakes/fake_local_media_track.go:1703
Method
PublisherID
()
pkg/rtc/types/typesfakes/fake_media_track.go:1264
Method
PublisherID
()
pkg/sfu/streamallocator/track.go:120
Method
PublisherIDCallCount
()
pkg/rtc/types/typesfakes/fake_data_track.go:602
Method
PublisherIDCallCount
()
pkg/rtc/types/typesfakes/fake_subscribed_track.go:610
Method
PublisherIDCallCount
()
pkg/rtc/types/typesfakes/fake_local_media_track.go:1721
Method
PublisherIDCallCount
()
pkg/rtc/types/typesfakes/fake_media_track.go:1282
Method
PublisherIDCalls
(stub func() livekit.ParticipantID)
pkg/rtc/types/typesfakes/fake_data_track.go:608
← previous
next →
5,501–5,600 of 7,437, ranked by callers