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
autoSubscribeDataTrack
checks if participant should be auto subscribed to new data tracks, assumes lock is already acquired
pkg/rtc/room.go:1032
↓ 2 callers
Function
benchmarkPool
(b *testing.B, wp *workerpool.WorkerPool, buckets []int)
pkg/sfu/receiver_test.go:112
↓ 2 callers
Method
bitrate
(ts time.Time, force bool)
pkg/sfu/datachannel/bitrate.go:91
↓ 2 callers
Method
calculateMatch
(idx int, template *FrameDependencyTemplate)
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorwriter.go:129
↓ 2 callers
Method
canReconcile
()
pkg/rtc/subscriptionmanager.go:459
↓ 2 callers
Method
clearCTRTrend
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:1020
↓ 2 callers
Method
clearLocalDescriptionSent
()
pkg/rtc/transport.go:2393
↓ 2 callers
Function
closeNonRTCRoom
close a room that has been created, but no participant has joined
test/scenarios.go:317
↓ 2 callers
Method
collectStats
( ts *timestamppb.Timestamp, streamType livekit.StreamType, perTrack map[livekit.TrackID][]*livekit.Analyti
pkg/telemetry/statsworker.go:180
↓ 2 callers
Function
compare
(expected *VP8, actual *VP8)
pkg/sfu/codecmunger/vp8_test.go:29
↓ 2 callers
Method
compare
(rhsSdkVersion string)
pkg/clientconfiguration/match.go:164
↓ 2 callers
Function
compareIngressInfo
(t *testing.T, expected, v *livekit.IngressInfo)
pkg/service/redisstore_test.go:387
↓ 2 callers
Method
configureICE
(iceConfig *livekit.ICEConfig, reset bool)
pkg/rtc/transportmanager.go:665
↓ 2 callers
Method
configurePublisherAnswer
configure publisher answer for audio track's dtx and stereo settings
pkg/rtc/participant_sdp.go:321
↓ 2 callers
Function
configureReceiverCodecs
( tr *webrtc.RTPTransceiver, preferredMimeType string, compliesWithCodecOrderInSDPAnswer bool, )
pkg/rtc/transport.go:3257
↓ 2 callers
Function
configureSender
(params configureSenderParams, offerAudioPT map[mime.MimeType]webrtc.PayloadType)
pkg/rtc/transport.go:3099
↓ 2 callers
Method
consumeBits
(bitCount int)
pkg/sfu/rtpextension/dependencydescriptor/bitstreamwriter.go:82
↓ 2 callers
Method
createAgentDispatch
(dispatch *livekit.AgentDispatch)
pkg/rtc/room.go:1849
↓ 2 callers
Method
createAndSendAnswer
()
pkg/rtc/transport.go:2774
↓ 2 callers
Function
createDDFrames
(maxLayer buffer.VideoLayer, startFrameNumber uint16)
pkg/sfu/videolayerselector/dependencydescriptor_test.go:275
↓ 2 callers
Method
createDDParserAndFrameRateCalculator
()
pkg/sfu/buffer/buffer_base.go:583
↓ 2 callers
Method
createDataChannelsForSubscriber
(pendingDataChannels []*livekit.DataChannelInfo)
pkg/rtc/transportmanager.go:409
↓ 2 callers
Method
createExtData
()
pkg/sfu/playoutdelay.go:189
↓ 2 callers
Function
createMultiNodeServer
(nodeID string, port uint32, configUpdater func(*config.Config))
test/integration_helpers.go:197
↓ 2 callers
Function
createRedisClient
(conf *config.Config)
pkg/service/wire_gen.go:243
↓ 2 callers
Method
deltaInfo
( snapshotID uint32, extStartSN uint64, extHighestSN uint64, )
pkg/sfu/rtpstats/rtpstats_base.go:475
↓ 2 callers
Method
deregisterJob
(jobID livekit.JobID)
pkg/service/agentservice.go:375
↓ 2 callers
Method
doICERestart
()
pkg/rtc/transport.go:2965
↓ 2 callers
Function
encodeRedForPrimary
(redPkts []*rtp.Packet, primary *rtp.Packet, redPayload []byte)
pkg/sfu/redreceiver.go:206
↓ 2 callers
Method
enqueueSubscribedChange
()
pkg/rtc/dynacast/dynacastmanageraudio.go:178
↓ 2 callers
Method
enqueueSubscribedQualityChange
()
pkg/rtc/dynacast/dynacastmanagervideo.go:226
↓ 2 callers
Method
estimateAvailableChannelCapacity
(reason channelCongestionReason)
pkg/sfu/bwe/remotebwe/remote_bwe.go:197
↓ 2 callers
Function
extractPktsFromRed
(redPkt *rtp.Packet, recoverBits byte)
pkg/sfu/redprimaryreceiver.go:271
↓ 2 callers
Function
extractPrimaryEncodingForRED
(payload []byte)
pkg/sfu/redprimaryreceiver.go:342
↓ 2 callers
Function
filterCodecs
( codecs []webrtc.RTPCodecParameters, enabledCodecs []*livekit.Codec, rtcpFeedbackConfig RTCPFeedbackConfig
pkg/rtc/mediaengine.go:169
↓ 2 callers
Method
filterNodes
(nodes []*livekit.Node)
pkg/routing/selector/cpuload.go:29
↓ 2 callers
Method
findBestTemplate
()
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorwriter.go:91
↓ 2 callers
Method
firstPacketTimeAdjustLogFields
(now, firstTime int64, adjustment int64, extNowTS, extStartTS uint64, srData *livekit.RTCPSenderReportState, t
pkg/sfu/rtpstats/rtpstats_base.go:443
↓ 2 callers
Method
flushExtPacketsLocked
()
pkg/sfu/buffer/buffer_base.go:1219
↓ 2 callers
Function
generateRedPkts
(t *testing.T, pkts []*rtp.Packet, redCount int)
pkg/sfu/redreceiver_test.go:279
↓ 2 callers
Method
getAllowedSubscribersLocked
returns a list of participants that are allowed to subscribe to the track. if nil is returned, it means everyone is allowed to subscribe to this track
pkg/rtc/uptrackmanager.go:384
↓ 2 callers
Method
getAndResetSnapshot
(snapshotID uint32, extStartSN uint64, extHighestSN uint64)
pkg/sfu/rtpstats/rtpstats_base.go:697
↓ 2 callers
Method
getBase
()
pkg/sfu/videolayerselector/videolayerselector.go:33
↓ 2 callers
Method
getBufferLocked
(layer int32)
pkg/sfu/receiver_base.go:689
↓ 2 callers
Method
getDrift
(extStartTS, extHighestTS uint64)
pkg/sfu/rtpstats/rtpstats_base.go:715
↓ 2 callers
Method
getEntity
(entity uint64)
pkg/sfu/videolayerselector/selectordecisioncache.go:188
↓ 2 callers
Method
getIceConfig
(roomName livekit.RoomName, participant types.LocalParticipant)
pkg/service/roommanager.go:1183
↓ 2 callers
Method
getIntervalStats
( extStartInclusive uint64, extEndExclusive uint64, ehsn uint64, )
pkg/sfu/rtpstats/rtpstats_sender.go:1377
↓ 2 callers
Method
getLayeredBitrateLocked
()
pkg/sfu/streamtrackermanager.go:479
↓ 2 callers
Function
getMediaStateForParticipant
(participant types.Participant)
pkg/service/roommanager_service.go:206
↓ 2 callers
Function
getMessageBus
(rc redis.UniversalClient)
pkg/service/wire_gen.go:257
↓ 2 callers
Function
getNodeID
wire.go:
pkg/service/wire_gen.go:191
↓ 2 callers
Function
getNodeStatsConfig
(config2 *config.Config)
pkg/service/wire_gen.go:349
↓ 2 callers
Method
getOrCreateRoom
create the actual room object, to be used on RTC node
pkg/service/roommanager.go:641
↓ 2 callers
Function
getPSRPCClientParams
(config2 rpc.PSRPCConfig, bus psrpc.MessageBus)
pkg/service/wire_gen.go:334
↓ 2 callers
Function
getPSRPCConfig
(config2 *config.Config)
pkg/service/wire_gen.go:330
↓ 2 callers
Method
getPacketLocked
(buff []byte, esn uint64)
pkg/sfu/buffer/buffer_base.go:1334
↓ 2 callers
Function
getPacketLossWeight
----------------------------------------------------------------------- how much weight to give to packet loss rate when calculating score. It is code
pkg/sfu/connectionquality/connectionstats.go:402
↓ 2 callers
Method
getPacketsSeen
(extStartSN, extHighestSN uint64)
pkg/sfu/rtpstats/rtpstats_base_lite.go:308
↓ 2 callers
Method
getPos
(entity uint64)
pkg/sfu/videolayerselector/selectordecisioncache.go:193
↓ 2 callers
Function
getPublisherConfig
(consolidated bool)
pkg/rtc/config.go:107
↓ 2 callers
Method
getRefLayer
()
pkg/sfu/forwarder.go:713
↓ 2 callers
Method
getRefTime
(at int64)
pkg/sfu/sequencer.go:427
↓ 2 callers
Function
getRoomConfig
(config2 *config.Config)
pkg/service/wire_gen.go:322
↓ 2 callers
Function
getSignalRelayConfig
(config2 *config.Config)
pkg/service/wire_gen.go:326
↓ 2 callers
Method
getSnInfoOutOfOrderSlot
(esn uint64, ehsn uint64)
pkg/sfu/rtpstats/rtpstats_sender.go:1317
↓ 2 callers
Method
getSnapshotLite
(startTime int64, extStartSN uint64)
pkg/sfu/rtpstats/rtpstats_base_lite.go:527
↓ 2 callers
Method
getStat
()
pkg/sfu/connectionquality/connectionstats.go:327
↓ 2 callers
Function
getSubscriberConfig
(enableTWCC bool)
pkg/rtc/config.go:175
↓ 2 callers
Function
getTCStats
()
pkg/telemetry/prometheus/node_linux.go:26
↓ 2 callers
Method
getTranslatedPayloadType
(srcPT uint8)
pkg/sfu/downtrack.go:2462
↓ 2 callers
Method
getTranslationParamsCommon
should be called with lock held
pkg/sfu/forwarder.go:2046
↓ 2 callers
Method
getWorker
(roomID livekit.RoomID, participantID livekit.ParticipantID)
pkg/telemetry/telemetryservice.go:265
↓ 2 callers
Method
handleConnectionFailed
(isShortLived bool)
pkg/rtc/transportmanager.go:756
↓ 2 callers
Function
handleError
(w http.ResponseWriter, r *http.Request, status int, err error, keysAndValues ...any)
pkg/service/utils.go:72
↓ 2 callers
Method
handleIncomingRpcResponse
(requestId string, payload string, err *utils.DataChannelRpcError)
pkg/rtc/participant.go:4221
↓ 2 callers
Method
handleMute
(muted bool, changed bool)
pkg/sfu/downtrack.go:1371
↓ 2 callers
Method
handleNewJobs
(ad *livekit.AgentDispatch, inc *sutils.IncrementalDispatcher[*livekit.Job])
pkg/rtc/room.go:1820
↓ 2 callers
Method
handleReceivedDataMessage
(kind livekit.DataPacket_Kind, dp *livekit.DataPacket)
pkg/rtc/participant.go:2427
↓ 2 callers
Method
handleSendDataResult
(err error, kind string, size int)
pkg/rtc/transportmanager.go:362
↓ 2 callers
Method
handleSourceTrackRemoved
()
pkg/rtc/subscriptionmanager.go:1398
↓ 2 callers
Method
hasCapacityForSubscription
(kind livekit.TrackType)
pkg/rtc/subscriptionmanager.go:727
↓ 2 callers
Method
hasExtendedFields
()
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorwriter.go:199
↓ 2 callers
Method
hasPendingMigratedTrack
()
pkg/rtc/participant.go:3476
↓ 2 callers
Method
hasPrimaryEverConnected
()
test/client/client.go:868
↓ 2 callers
Method
hasRecentSignalLocked
()
pkg/rtc/transportmanager.go:1050
↓ 2 callers
Function
hsin
haversine(θ) function
pkg/routing/selector/regionaware.go:103
↓ 2 callers
Function
iceServerForStunServers
------------------------------------
pkg/service/roommanager.go:1196
↓ 2 callers
Method
inGroup
(sequenceNumber uint64)
pkg/sfu/bwe/sendsidebwe/packet_group.go:300
↓ 2 callers
Function
inOrder
(a, b uint16)
pkg/sfu/videolayerselector/framenumberwrapper_test.go:93
↓ 2 callers
Method
initPCWithPreviousAnswer
(previousAnswer webrtc.SessionDescription)
pkg/rtc/transport.go:2154
↓ 2 callers
Method
initRanges
(start RT, val VT)
pkg/sfu/utils/rangemap.go:115
↓ 2 callers
Function
initSenderSnapshot
-------------------------------------------------------------------
pkg/sfu/rtpstats/rtpstats_sender.go:1474
↓ 2 callers
Function
initSenderSnapshotReceiverView
(startTime int64, extStartSN uint64)
pkg/sfu/rtpstats/rtpstats_sender.go:1489
↓ 2 callers
Function
initSenderSnapshotWindow
(startTime int64, extStartSN uint64)
pkg/sfu/rtpstats/rtpstats_sender.go:1481
↓ 2 callers
Function
installTools
(force bool)
magefile.go:231
↓ 2 callers
Method
invalidateKeyFrame
()
pkg/sfu/videolayerselector/dependencydescriptor.go:434
↓ 2 callers
Method
invalidateSlot
(slot int)
pkg/sfu/sequencer.go:444
↓ 2 callers
Function
ioStoreDocker
(t testing.TB)
pkg/service/ioservice_sip_test.go:29
↓ 2 callers
Method
isFullyEstablished
()
pkg/rtc/transport.go:982
← previous
next →
1,401–1,500 of 7,437, ranked by callers