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
↓ 2 callers
Method
setState
(state streamAllocatorState)
pkg/sfu/streamallocator/streamallocator.go:899
↓ 2 callers
Method
setSubscribedTrack
(track types.SubscribedTrack)
pkg/rtc/subscriptionmanager.go:1437
↓ 2 callers
Method
setTargetLayer
(targetLayer buffer.VideoLayer, requestLayerSpatial int32)
pkg/sfu/forwarder.go:1684
↓ 2 callers
Method
setupBuffer
(buff buffer.BufferProvider, layer int32, rtt uint32, paused bool)
pkg/sfu/receiver_base.go:761
↓ 2 callers
Function
setupDataBlobServer
(t *testing.T, name string, enable bool)
test/singlenode_test.go:1599
↓ 2 callers
Method
setupMigrationTimerLocked
()
pkg/rtc/participant.go:1560
↓ 2 callers
Function
setupMultiNodeTestWithConfig
(name string, configUpdater func(*config.Config))
test/integration_helpers.go:86
↓ 2 callers
Method
setupRTPStats
(clockRate uint32)
pkg/sfu/buffer/buffer_base.go:449
↓ 2 callers
Method
setupRTPStatsLite
(clockRate uint32)
pkg/sfu/buffer/buffer_base.go:463
↓ 2 callers
Method
shadowDownTracks
()
pkg/sfu/utils/downtrackspreader.go:116
↓ 2 callers
Method
shadowVideoTracksLocked
()
pkg/sfu/streamallocator/streamallocator.go:1436
↓ 2 callers
Method
shouldWriteActiveDecodeTargetsBitmask
()
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorwriter.go:463
↓ 2 callers
Method
startAtLocked
(packetLossWeight float64, at time.Time)
pkg/sfu/connectionquality/scorer.go:242
↓ 2 callers
Method
startForwarderForBufferLocked
(layer int32, buff buffer.BufferProvider)
pkg/sfu/receiver_base.go:930
↓ 2 callers
Method
startForwardersGeneration
()
pkg/sfu/receiver_base.go:912
↓ 2 callers
Method
stopMaxQualityTimer
()
pkg/rtc/dynacast/dynacastqualityvideo.go:241
↓ 2 callers
Method
stopRTPStats
(reason string)
pkg/sfu/buffer/buffer_base.go:473
↓ 2 callers
Method
stopRTPStatsLite
(reason string)
pkg/sfu/buffer/buffer_base.go:490
↓ 2 callers
Method
storeIngress
(_ context.Context, info *livekit.IngressInfo)
pkg/service/redisstore.go:542
↓ 2 callers
Method
storeIngressState
(_ context.Context, ingressId string, state *livekit.IngressState)
pkg/service/redisstore.go:619
↓ 2 callers
Method
subscriberRTCPWorker
subscriberRTCPWorker sends SenderReports periodically when the participant is subscribed to other publishedTracks in the room.
pkg/rtc/participant.go:2691
↓ 2 callers
Method
takeBlobResponse
()
test/singlenode_test.go:1582
↓ 2 callers
Method
takeStoreResponse
()
test/singlenode_test.go:1571
↓ 2 callers
Function
testBatchJobRequest
(t require.TestingT, batchSize int, totalJobs int, client rpc.AgentInternalClient, workers []*testutils.AgentW
pkg/agent/agent_test.go:60
↓ 2 callers
Function
testIter
( t *testing.T, create func(ctx context.Context, id string) error, list func(ctx context.Context, page *liv
pkg/service/redisstore_sip_test.go:316
↓ 2 callers
Function
testRTCServicePathToTestClientOptions
(testRTCServicePath testRTCServicePath, opts *testclient.Options)
test/integration_helpers.go:256
↓ 2 callers
Function
toAggregateDeltaInfo
(streams map[uint32]*buffer.StreamStatsWithLayers, useRemoteView bool)
pkg/sfu/connectionquality/connectionstats.go:429
↓ 2 callers
Method
toDD
()
pkg/sfu/buffer/fps_test.go:46
↓ 2 callers
Method
toH26x
()
pkg/sfu/buffer/fps_test.go:61
↓ 2 callers
Function
toParticipants
(lps []types.LocalParticipant)
pkg/rtc/room.go:2398
↓ 2 callers
Method
toVP8
()
pkg/sfu/buffer/fps_test.go:36
↓ 2 callers
Method
trendCoefficient
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:298
↓ 2 callers
Method
unmarkSubscribedTo
(publisherID livekit.ParticipantID, trackID livekit.TrackID)
pkg/rtc/subscriptionmanager.go:1202
↓ 2 callers
Function
unmarshalCandidate
(i ice.Candidate)
pkg/rtc/types/ice.go:353
↓ 2 callers
Function
unmarshalICECandidate
(c webrtc.ICECandidateInit)
pkg/rtc/types/ice.go:339
↓ 2 callers
Method
unmarshalKeys
(keys string)
pkg/config/config.go:918
↓ 2 callers
Method
unsubscribeSynchronous
(trackID livekit.TrackID)
pkg/rtc/subscriptionmanager.go:919
↓ 2 callers
Method
updateAtLocked
(stat *windowStat, at time.Time)
pkg/sfu/connectionquality/scorer.go:388
↓ 2 callers
Method
updateCongestedSignal
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:942
↓ 2 callers
Method
updateCongestionSignal
( qdJQRConfig CongestionSignalConfig, qdDQRConfig CongestionSignalConfig, lossJQRConfig CongestionSignalCon
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:881
↓ 2 callers
Method
updateConnectionTypeLocked
()
pkg/rtc/types/ice.go:267
↓ 2 callers
Method
updateEarlyWarningSignal
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:933
↓ 2 callers
Function
updateEnableTranscoding
(info *livekit.IngressInfo)
pkg/service/ingress.go:219
↓ 2 callers
Method
updateEvalInterval
()
pkg/sfu/streamtracker/streamtracker_frame.go:221
↓ 2 callers
Function
updateInfoUsingRequest
(req *livekit.UpdateIngressRequest, info *livekit.IngressInfo)
pkg/service/ingress.go:237
↓ 2 callers
Method
updateJitter
(ets uint64, packetTime int64)
pkg/sfu/rtpstats/rtpstats_base.go:663
↓ 2 callers
Method
updateLastNegotiateLocked
()
pkg/rtc/transport.go:2015
↓ 2 callers
Method
updateLayerMuteAtLocked
(isMuted bool, at time.Time)
pkg/sfu/connectionquality/scorer.go:312
↓ 2 callers
Method
updateMuteAtLocked
(isMuted bool, at time.Time)
pkg/sfu/connectionquality/scorer.go:268
↓ 2 callers
Method
updatePauseAtLocked
(isPaused bool, at time.Time)
pkg/sfu/connectionquality/scorer.go:341
↓ 2 callers
Method
updateSNOffset
()
pkg/sfu/sequencer.go:431
↓ 2 callers
Function
verifyEncodingEqual
(t *testing.T, p1, p2 *rtp.Packet)
pkg/sfu/redreceiver_test.go:259
↓ 2 callers
Method
withinAcquireGraceLocked
withinAcquireGraceLocked reports whether the initial-acquisition grace window is still open.
pkg/sfu/forwarder.go:317
↓ 2 callers
Method
worker
()
pkg/rtc/signalanddatastats.go:166
↓ 2 callers
Method
worker
(generation uint32)
pkg/sfu/streamtracker/streamtracker_dd.go:230
↓ 2 callers
Method
write
()
pkg/routing/signal.go:310
↓ 2 callers
Method
writeBlankFrameRTP
(duration float32, generation uint32)
pkg/sfu/downtrack.go:1796
↓ 2 callers
Method
writeNonSymmetric
(value, numValues uint32)
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorwriter.go:366
↓ 2 callers
Method
writePartialByte
(source uint8, sourceBitCount int, target uint8, targetBitOffset int)
pkg/sfu/rtpextension/dependencydescriptor/bitstreamwriter.go:93
↓ 2 callers
Method
writeRTX
(rtxPkt *rtp.Packet, arrivalTime int64)
pkg/sfu/buffer/buffer.go:242
↓ 1 callers
Method
APICall
(ctx context.Context, apiCallInfo *livekit.APICallInfo)
pkg/telemetry/telemetryservice.go:87
↓ 1 callers
Method
ActiveAt
()
pkg/rtc/participant.go:608
↓ 1 callers
Method
ActiveAt
()
pkg/rtc/types/interfaces.go:415
↓ 1 callers
Method
AddAgentDispatch
(dispatch *livekit.AgentDispatch)
pkg/rtc/room.go:881
↓ 1 callers
Method
AddBuffer
(buff buffer.BufferProvider, layer int32)
pkg/sfu/receiver_base.go:816
↓ 1 callers
Method
AddCluster
(mode ProbeClusterMode, pcg ProbeClusterGoal)
pkg/sfu/ccutils/prober.go:184
↓ 1 callers
Method
AddCodec
(mime mime.MimeType)
pkg/rtc/dynacast/interfaces.go:51
↓ 1 callers
Method
AddDataBlob
(dataBlob *livekit.DataBlob)
pkg/rtc/participant_data_blob_handler.go:80
↓ 1 callers
Method
AddDataDownTrack
(sender DataTrackSender)
pkg/rtc/types/interfaces.go:846
↓ 1 callers
Method
AddDataTrack
(dataTrack types.DataTrack, publisherIdentity livekit.ParticipantIdentity, publisherID livekit.ParticipantID)
pkg/rtc/roomtrackmanager.go:178
↓ 1 callers
Method
AddDependencyDescriptorTrackers
()
pkg/sfu/streamtrackermanager.go:215
↓ 1 callers
Method
AddEstimate
(estimate int64)
pkg/sfu/bwe/remotebwe/channel_observer.go:146
↓ 1 callers
Method
AddLayerTransitionAt
(distance float64, at time.Time)
pkg/sfu/connectionquality/connectionstats.go:184
↓ 1 callers
Method
AddNack
(packets uint32, repeatedNacks uint32)
pkg/sfu/bwe/remotebwe/channel_observer.go:150
↓ 1 callers
Method
AddOnBindArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_subscribed_track.go:203
↓ 1 callers
Method
AddOnBindCallCount
()
pkg/rtc/types/typesfakes/fake_subscribed_track.go:191
↓ 1 callers
Function
AddPublishedTrack
(kind string)
pkg/telemetry/prometheus/rooms.go:175
↓ 1 callers
Method
AddPublisherRTT
(participantIdentity livekit.ParticipantIdentity, rtt float32)
pkg/metric/metrics_collector.go:85
↓ 1 callers
Method
AddReceiver
AddReceiver adds a new RTP receiver to the track, returns true when receiver represents a new codec and if a receiver was added successfully
pkg/rtc/mediatrack.go:295
↓ 1 callers
Method
AddRemoteCandidate
(c webrtc.ICECandidateInit, filtered, trickle, canUpdate bool)
pkg/rtc/types/ice.go:186
↓ 1 callers
Method
AddSubscribedTrack
(subTrack types.SubscribedTrack)
pkg/rtc/transportmanager.go:332
↓ 1 callers
Method
AddSubscriber
(sub types.LocalParticipant)
pkg/rtc/datatrack.go:116
↓ 1 callers
Method
AddSubscriberCalls
(stub func(types.LocalParticipant) (types.DataDownTrack, error))
pkg/rtc/types/typesfakes/fake_data_track.go:230
↓ 1 callers
Method
AddSubscriberCalls
(stub func(types.LocalParticipant) (types.SubscribedTrack, error))
pkg/rtc/types/typesfakes/fake_media_track.go:364
↓ 1 callers
Method
AddSubscriberRTT
(rtt float32)
pkg/metric/metrics_collector.go:104
↓ 1 callers
Method
AddTrack
AddTrack is called when client intends to publish track. records track details and lets client know it's ok to proceed
pkg/rtc/participant.go:1326
↓ 1 callers
Method
AddTrackCalls
(stub func(*livekit.AddTrackRequest))
pkg/rtc/types/typesfakes/fake_local_participant.go:1723
↓ 1 callers
Method
AddUpTrack
(track TrackRemote, buff *buffer.Buffer)
pkg/sfu/receiver.go:171
↓ 1 callers
Function
AggregateRTPDeltaInfo
(deltaInfoList []*RTPDeltaInfo)
pkg/sfu/rtpstats/rtpstats_base.go:839
↓ 1 callers
Method
AutoCreateEnabled
(ctx context.Context)
pkg/service/interfaces.go:82
↓ 1 callers
Method
AutoCreateEnabledReturns
(result1 bool)
pkg/service/servicefakes/fake_room_allocator.go:110
↓ 1 callers
Method
BWEType
get the BWE type in use
pkg/sfu/downtrack.go:250
↓ 1 callers
Method
BaseSendTimeThreshold
(threshold int64)
pkg/sfu/bwe/sendsidebwe/packet_tracker.go:94
↓ 1 callers
Method
Bitrate
()
pkg/sfu/ccutils/prober.go:371
↓ 1 callers
Function
BroadcastDataMessageForRoom
(r types.Room, source types.LocalParticipant, data []byte, logger logger.Logger)
pkg/rtc/room.go:2157
↓ 1 callers
Function
BroadcastDataPacketForRoom
------------------------------------------------------------
pkg/rtc/room.go:2094
↓ 1 callers
Function
BroadcastMetricsForRoom
(r types.Room, source types.Participant, dp *livekit.DataPacket, logger logger.Logger)
pkg/rtc/room.go:2167
↓ 1 callers
Method
BufferedAmount
()
pkg/sfu/datachannel/datachannel_writer_test.go:131
↓ 1 callers
Method
BytesRead
()
pkg/sfu/rtpextension/dependencydescriptor/bitstreamreader.go:124
↓ 1 callers
Method
CacheDownTrack
(trackID livekit.TrackID, rtpTransceiver *webrtc.RTPTransceiver, downTrackState sfu.DownTrackState)
pkg/rtc/types/interfaces.go:534
← previous
next →
1,601–1,700 of 7,437, ranked by callers