MCPcopy Index your code

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

⨍ Functions 7,437◇ Types & classes 718
↓ 368 callersMethodLoad
()
pkg/agent/testutils/server.go:149
↓ 262 callersMethodRun
(jobType livekit.JobType, namespace string)
test/agent.go:69
↓ 250 callersMethodID
()
pkg/rtc/types/interfaces.go:742
↓ 223 callersMethodAdd
(f func())
pkg/sfu/utils/debounce.go:20
↓ 182 callersMethodStore
(sender T)
pkg/sfu/utils/downtrackspreader.go:69
↓ 169 callersMethodrecordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_local_participant.go:10002
↓ 143 callersMethodString
()
pkg/rtc/transport.go:154
↓ 117 callersMethodGetLogger
()
pkg/rtc/types/interfaces.go:313
↓ 82 callersMethodDuration
()
pkg/sfu/ccutils/prober.go:367
↓ 75 callersMethodGet
(key T)
pkg/utils/iceconfigcache.go:37
↓ 75 callersFunctionWithTimeout
(t *testing.T, f func() string, timeouts ...time.Duration)
pkg/testutils/timeout.go:27
↓ 73 callersFunctioncreateRTCClient
creates a client and runs against server
test/integration_helpers.go:276
↓ 72 callersMethodTrackID
()
pkg/sfu/receiver_base.go:102
↓ 71 callersMethodIdentity
()
pkg/rtc/types/interfaces.go:303
↓ 68 callersMethodStop
()
test/client/trackwriter.go:35
↓ 67 callersMethodString
()
test/integration_helpers.go:237
↓ 64 callersMethodClose
()
pkg/rtc/types/interfaces.go:851
↓ 62 callersMethodLen
()
pkg/sfu/streamallocator/track.go:209
↓ 60 callersMethodGetValue
(key RT)
pkg/sfu/utils/rangemap.go:159
↓ 57 callersMethodToProto
()
pkg/rtc/types/interfaces.go:836
↓ 54 callersMethodClose
()
pkg/sfu/downtrack.go:62
↓ 53 callersMethodAdd
Add adds a message to the cache if there is a gap between the last sequence number and cached messages then return the cache State: - MigrationDataCac
pkg/rtc/migrationdatacache.go:36
↓ 53 callersMethodIsValid
()
pkg/sfu/buffer/videolayer.go:56
↓ 48 callersFunctionwaitUntilConnected
(t *testing.T, clients ...*testclient.RTCClient)
test/integration_helpers.go:134
↓ 46 callersMethodMarshal
()
pkg/sfu/rtpextension/playoutdelay/playoutdelay.go:55
↓ 46 callersMethodParticipantID
()
pkg/telemetry/statsworker.go:114
↓ 46 callersMethodSubscribedTracks
()
test/client/client.go:749
↓ 44 callersFunctionAppendLogFields
(ctx context.Context, fields ...any)
pkg/service/twirp.go:84
↓ 44 callersMethodDone
()
pkg/utils/incrementaldispatcher.go:50
↓ 44 callersFunctiontwirpAuthError
wraps authentication errors around Twirp
pkg/service/auth.go:258
↓ 42 callersMethodUnmarshal
* ┆* +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ ┆* 0 1 2 3 ┆* 0 1 2
pkg/rtc/datatrack/packet.go:112
↓ 42 callersMethodrecordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_local_media_track.go:2367
↓ 41 callersMethodNodeID
()
pkg/routing/node.go:32
↓ 40 callersMethodStop
()
pkg/rtc/dynacast/interfaces.go:146
↓ 39 callersFunctionGetTestExtPacket
-----------------------------------------------------------
pkg/sfu/testutils/data.go:47
↓ 39 callersMethodMarshal
()
pkg/rtc/datatrack/packet.go:279
↓ 38 callersMethodString
()
pkg/rtc/types/ice.go:44
↓ 38 callersMethodrecordInvocation
(key string, args []interface{})
pkg/telemetry/telemetryfakes/fake_telemetry_service.go:1686
↓ 37 callersMethodStop
()
pkg/sfu/pacer/pacer.go:61
↓ 37 callersMethodUnmarshal
(rawData []byte)
pkg/sfu/rtpextension/playoutdelay/playoutdelay.go:64
↓ 36 callersMethodTargetLayer
()
pkg/sfu/forwarder.go:683
↓ 36 callersMethodhasPermissionLocked
(trackID livekit.TrackID, subscriberIdentity livekit.ParticipantIdentity)
pkg/rtc/uptrackmanager.go:359
↓ 36 callersMethodrecordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_participant.go:2284
↓ 35 callersMethodGetParticipants
()
pkg/rtc/room.go:363
↓ 34 callersMethodParticipantID
()
pkg/rtc/datatrack/extension_participant_sid.go:35
↓ 33 callersMethodCodec
()
pkg/sfu/track_remote.go:27
↓ 33 callersMethodObserve
(hasMarker bool, ts uint32)
pkg/sfu/streamtracker/interfaces.go:56
↓ 32 callersMethodenqueue
(op func())
pkg/telemetry/telemetryservice.go:261
↓ 32 callersMethodrecordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_media_track.go:1872
↓ 30 callersMethodGetScoreAndQuality
()
pkg/sfu/connectionquality/connectionstats.go:200
↓ 30 callersMethodSendEvent
(ctx context.Context, events *livekit.AnalyticsEvent)
pkg/telemetry/analyticsservice.go:36
↓ 30 callersMethodhandleError
(method string, w http.ResponseWriter, r *http.Request, status int, err error)
pkg/service/whipservice.go:533
↓ 29 callersMethodGetTranslationParams
(extPkt *buffer.ExtPacket, layer int32)
pkg/sfu/forwarder.go:1761
↓ 29 callersMethodKind
()
pkg/rtc/types/interfaces.go:761
↓ 29 callersMethodName
()
pkg/rtc/types/interfaces.go:741
↓ 29 callersMethodString
()
pkg/clientconfiguration/match.go:81
↓ 29 callersMethodString
()
pkg/sfu/buffer/videolayer.go:44
↓ 29 callersMethodSwap
(i, j int)
pkg/sfu/streamallocator/track.go:213
↓ 29 callersMethodWriteMessage
(messageType int, data []byte)
pkg/rtc/types/interfaces.go:46
↓ 28 callersMethodlistener
()
pkg/rtc/participant.go:471
↓ 28 callersMethodupdateScoreAt
(at time.Time)
pkg/sfu/connectionquality/connectionstats.go:279
↓ 27 callersMethodClone
()
pkg/routing/node.go:30
↓ 27 callersMethodDownTrack
()
pkg/rtc/types/interfaces.go:890
↓ 27 callersMethodEmpty
()
pkg/sfu/streamallocator/streamstateupdate.go:81
↓ 27 callersMethodGetCurrent
()
pkg/sfu/videolayerselector/videolayerselector.go:61
↓ 27 callersMethodGetMax
()
pkg/sfu/videolayerselector/videolayerselector.go:45
↓ 26 callersMethodBroadcast
(writer func(T))
pkg/sfu/utils/downtrackspreader.go:93
↓ 26 callersMethodGetRoom
()
pkg/service/roommanager.go:794
↓ 25 callersFunctionGetTestExtPacketVP8
--------------------------------------
pkg/sfu/testutils/data.go:83
↓ 25 callersMethodWrite
(seq uint64, close bool, msgs []proto.Message)
pkg/routing/signal.go:184
↓ 25 callersFunctionnewRoomWithParticipants
(t *testing.T, opts testRoomOpts)
pkg/rtc/room_test.go:816
↓ 25 callersMethodsetStreams
(streams map[uint32]*buffer.StreamStatsWithLayers)
pkg/sfu/connectionquality/connectionstats_test.go:42
↓ 24 callersMethodAddStaticTrack
(mime string, id string, label string, opts ...AddTrackOption)
test/client/client.go:962
↓ 24 callersMethodGetQualityForDimension
returns quality information that's appropriate for width & height
pkg/rtc/types/interfaces.go:797
↓ 24 callersMethodSSRC
()
pkg/sfu/track_remote.go:23
↓ 24 callersMethodUpdateAndGetSnTs
(extPkt *buffer.ExtPacket, marker bool)
pkg/sfu/rtpmunger.go:171
↓ 23 callersMethodAddTrack
(req *livekit.AddTrackRequest)
pkg/rtc/types/interfaces.go:461
↓ 23 callersMethodMime
()
pkg/rtc/dynacast/interfaces.go:160
↓ 23 callersFunctionStatsKeyForData
( country string, streamType livekit.StreamType, participantID livekit.ParticipantID, trackID livekit.Trac
pkg/telemetry/stats.go:51
↓ 23 callersMethodTrackStats
TrackStats is called periodically for each track in both directions (published/subscribed)
pkg/telemetry/telemetryservice.go:34
↓ 23 callersMethodgetReceiver
()
pkg/rtc/wrappedreceiver.go:487
↓ 22 callersMethodGetTarget
()
pkg/sfu/videolayerselector/videolayerselector.go:48
↓ 22 callersFunctioncontextWithToken
(token string)
test/integration_helpers.go:104
↓ 22 callersFunctionperSec
(prev, curr uint64, secs int64)
pkg/telemetry/prometheus/node.go:276
↓ 22 callersMethodrecordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_local_participant_listener.go:1014
↓ 22 callersFunctionsubscribedCodecsAsString
(c1 []*livekit.SubscribedCodec)
pkg/rtc/dynacast/dynacastmanager_test.go:501
↓ 21 callersMethodClose
()
pkg/agent/worker.go:63
↓ 21 callersMethodGet
()
pkg/rtc/migrationdatacache.go:57
↓ 21 callersMethodSetCurrent
(currentLayer buffer.VideoLayer)
pkg/sfu/videolayerselector/videolayerselector.go:60
↓ 21 callersMethodWriteMessageCallCount
()
pkg/rtc/types/typesfakes/fake_websocket_client.go:342
↓ 21 callersMethodneedsSubscribe
()
pkg/rtc/subscriptionmanager.go:1586
↓ 21 callersMethodsendRequestResponse
(requestResponse *livekit.RequestResponse)
pkg/rtc/participant_signal.go:160
↓ 21 callersFunctionsetupSingleNodeTest
(name string)
test/integration_helpers.go:65
↓ 21 callersMethodwriteBits
(val uint64, bitCount int)
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorwriter.go:192
↓ 20 callersMethodDuration
()
pkg/sfu/bwe/sendsidebwe/traffic_stats.go:88
↓ 20 callersMethodID
()
pkg/rtc/participant.go:528
↓ 20 callersMethodReset
()
pkg/sfu/bwe/bwe.go:85
↓ 20 callersMethodSetTarget
(targetLayer buffer.VideoLayer)
pkg/sfu/videolayerselector/videolayerselector.go:47
↓ 20 callersMethodgetSubscribedTrack
()
pkg/rtc/subscriptionmanager.go:1454
↓ 19 callersMethodNotifySubscriberMaxQuality
( subscriberID livekit.ParticipantID, mime mime.MimeType, quality livekit.VideoQuality, )
pkg/rtc/dynacast/interfaces.go:59
next →1–100 of 7,437, ranked by callers