MCPcopy Index your code

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

⨍ Functions 7,437◇ Types & classes 718
↓ 5 callersMethodPostEvent
(ome OperationMonitorEvent, omd OperationMonitorData)
pkg/rtc/types/interfaces.go:965
↓ 5 callersMethodPriority
()
pkg/rtc/mediatrackreceiver.go:83
↓ 5 callersMethodProbeSignal
(ppg *probePacketGroup)
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:101
↓ 5 callersMethodPropagatedQueuingDelay
()
pkg/sfu/bwe/sendsidebwe/packet_group.go:233
↓ 5 callersMethodProtocolVersion
()
pkg/rtc/types/interfaces.go:410
↓ 5 callersMethodProvisionalAllocateCommit
()
pkg/sfu/streamallocator/track.go:165
↓ 5 callersMethodPublisherIdentity
()
pkg/rtc/types/interfaces.go:839
↓ 5 callersMethodReceiver
(mime mime.MimeType)
pkg/rtc/mediatrackreceiver.go:1186
↓ 5 callersFunctionRecordPeerConnectionState
(transport livekit.SignalTarget, state string)
pkg/telemetry/prometheus/rooms.go:295
↓ 5 callersFunctionRecordServiceOperationSuccess
(op string)
pkg/telemetry/prometheus/node.go:296
↓ 5 callersFunctionRecordTrackSubscribeCancels
(numCancels int32)
pkg/telemetry/prometheus/rooms.go:278
↓ 5 callersMethodReplace
( maxSubscriberQuality map[livekit.ParticipantID]livekit.VideoQuality, maxSubscriberNodeQuality map[liveki
pkg/rtc/dynacast/interfaces.go:155
↓ 5 callersMethodSeed
(value T)
pkg/sfu/ccutils/trenddetector.go:111
↓ 5 callersMethodSelect
(extPkt *buffer.ExtPacket, layer int32)
pkg/sfu/videolayerselector/simulcast.go:63
↓ 5 callersMethodSendDataMessageCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:7235
↓ 5 callersMethodSendParticipantUpdate
(participants []*livekit.ParticipantInfo)
pkg/rtc/types/interfaces.go:498
↓ 5 callersMethodSetRTT
(rtt uint32)
pkg/sfu/buffer/buffer_base.go:88
↓ 5 callersMethodSimulateAgentWorker
(opts ...SimulatedWorkerOption)
pkg/agent/testutils/server.go:107
↓ 5 callersMethodStart
()
pkg/rtc/dynacast/interfaces.go:144
↓ 5 callersMethodStartEgress
(context.Context, *rpc.StartEgressRequest)
pkg/rtc/egress.go:31
↓ 5 callersMethodStoreRoom
(ctx context.Context, room *livekit.Room, internal *livekit.RoomInternal)
pkg/service/interfaces.go:38
↓ 5 callersMethodStoreSIPTrunk
(ctx context.Context, info *livekit.SIPTrunkInfo)
pkg/service/interfaces.go:90
↓ 5 callersMethodStreamTrackerManager
()
pkg/sfu/receiver_base.go:547
↓ 5 callersMethodString
()
pkg/sfu/downtrack.go:280
↓ 5 callersMethodSubscribeToDataTrack
(trackID livekit.TrackID)
pkg/rtc/types/interfaces.go:479
↓ 5 callersMethodUpdate
(packet *datatrack.Packet, arrivalTime int64, payloadLength int)
pkg/rtc/datatrack_stats.go:50
↓ 5 callersMethodUpdateAndGetPaddingSnTs
( num int, clockRate uint32, frameRate uint32, forceMarker bool, extRtpTimestamp uint64, )
pkg/sfu/rtpmunger.go:276
↓ 5 callersMethodUpdateIngressState
(ctx context.Context, req *rpc.UpdateIngressStateRequest)
pkg/service/clients.go:32
↓ 5 callersMethodUpdateMaxPictureId
(extPictureId int32, mBit bool)
pkg/sfu/codecmunger/vp8.go:488
↓ 5 callersMethodUpgrade
( w http.ResponseWriter, r *http.Request, responseHeader http.Header, )
pkg/service/agentservice.go:49
↓ 5 callersFunctionVideoQualityToRid
(mimeType mime.MimeType, quality livekit.VideoQuality, trackInfo *livekit.TrackInfo, ridSpace VideoLayersRid)
pkg/sfu/buffer/videolayerutils.go:210
↓ 5 callersMethodWriteMessageArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_websocket_client.go:354
↓ 5 callersMethodWriteMessageCalls
(stub func(proto.Message) error)
pkg/routing/routingfakes/fake_message_sink.go:207
↓ 5 callersMethodWriteRTCP
(pkts []rtcp.Packet)
pkg/rtc/transport.go:1457
↓ 5 callersMethodWriteServerMessage
(msg *livekit.ServerMessage)
pkg/agent/worker.go:60
↓ 5 callersMethodadd
(size int)
pkg/sfu/bwe/sendsidebwe/packet_group.go:54
↓ 5 callersFunctionappendEnvelope
appendEnvelope appends the 5-byte envelope (XORed trailer_len + magic).
pkg/sfu/packettrailer/packet_trailer_test.go:37
↓ 5 callersFunctionappendTLV
appendTLV appends a single XORed TLV element to dst.
pkg/sfu/packettrailer/packet_trailer_test.go:28
↓ 5 callersFunctioncreateRTCClientWithToken
creates a client and runs against server
test/integration_helpers.go:287
↓ 5 callersFunctionencodeQueryParam
(key, value string)
test/client/client.go:1388
↓ 5 callersMethodfilterCandidates
(sd webrtc.SessionDescription, preferTCP, isLocal bool)
pkg/rtc/transport.go:2472
↓ 5 callersMethodgetNumAttempts
()
pkg/rtc/subscriptionmanager.go:1346
↓ 5 callersMethodgetPacketsSeenMinusPadding
(extStartSN, extHighestSN uint64)
pkg/sfu/rtpstats/rtpstats_base.go:462
↓ 5 callersMethodgetPublishedTrackBySdpCid
(clientId string)
pkg/rtc/participant.go:3599
↓ 5 callersFunctionhandleICEExchange
(t *testing.T, a, b *PCTransport, ah, bh *transportfakes.FakeHandler)
pkg/rtc/transport_test.go:519
↓ 5 callersMethodinterceptor
()
test/singlenode_test.go:1540
↓ 5 callersMethodisCanceled
()
pkg/rtc/subscriptionmanager.go:1535
↓ 5 callersFunctionkeyFrameOnLayer
(spatial, temporal int32)
pkg/sfu/videolayerselector/simulcast_test.go:27
↓ 5 callersMethodmaybeAddTransition
(bitrate int64, distance float64, pauseReason VideoPauseReason)
pkg/sfu/downtrack.go:1615
↓ 5 callersMethodmaybeRecordError
(tl types.ParticipantTelemetryListener, err error, isUserError bool)
pkg/rtc/subscriptionmanager.go:1495
↓ 5 callersMethodneedsBind
()
pkg/rtc/subscriptionmanager.go:1551
↓ 5 callersFunctionnewIngressEvent
(event livekit.AnalyticsEventType, ingress *livekit.IngressInfo)
pkg/telemetry/events.go:636
↓ 5 callersFunctionnewPacketGroup
(params packetGroupParams, inheritedQueuingDelay int64)
pkg/sfu/bwe/sendsidebwe/packet_group.go:152
↓ 5 callersFunctionnewParticipantEvent
(event livekit.AnalyticsEventType, room *livekit.Room, participant *livekit.ParticipantInfo)
pkg/telemetry/events.go:606
↓ 5 callersFunctionnewStreamTrackerPacket
(samplesRequired uint32, cyclesRequired uint32, cycleDuration time.Duration)
pkg/sfu/streamtracker/streamtracker_packet_test.go:30
↓ 5 callersFunctionnewTestRoomService
(limitConf config.LimitConfig)
pkg/service/roomservice_test.go:178
↓ 5 callersMethodnotifyDataTrackSubscriberHandles
()
pkg/rtc/subscriptionmanager.go:1151
↓ 5 callersFunctionplayoutDelayEqual
(t *testing.T, data []byte, min, max uint16)
pkg/sfu/playoutdelay_test.go:76
↓ 5 callersMethodpostKeyFrameRequestEvent
()
pkg/sfu/downtrack.go:985
↓ 5 callersMethodqueueReconcileDataTrack
(trackID livekit.TrackID)
pkg/rtc/subscriptionmanager.go:681
↓ 5 callersMethodrecordInvocation
(key string, args []interface{})
pkg/service/servicefakes/fake_agent_store.go:402
↓ 5 callersMethodrecordInvocation
(key string, args []interface{})
pkg/service/servicefakes/fake_ioclient.go:424
↓ 5 callersMethodrecordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_websocket_client.go:394
↓ 5 callersMethodrecordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_data_down_track.go:254
↓ 5 callersMethodresyncLocked
()
pkg/sfu/forwarder.go:1700
↓ 5 callersMethodsendDataMessage
(dc *datachannel.DataChannelWriter[*webrtc.DataChannel], data []byte)
pkg/rtc/transport.go:1541
↓ 5 callersMethodsetDesired
(desired bool)
pkg/rtc/subscriptionmanager.go:1299
↓ 5 callersMethodsetEntity
(entity uint64, sd selectorDecision)
pkg/sfu/videolayerselector/selectordecisioncache.go:173
↓ 5 callersMethodtakeRequestResponse
()
test/singlenode_test.go:1560
↓ 5 callersMethodupdateAllocation
(alloc VideoAllocation, reason string)
pkg/sfu/forwarder.go:1658
↓ 5 callersMethodupdateSnOffset
()
pkg/sfu/rtpmunger.go:347
↓ 5 callersMethodupdateState
(state livekit.ParticipantInfo_State)
pkg/rtc/participant.go:2188
↓ 5 callersFunctionwriteRTP
()
pkg/sfu/receiver_test.go:206
↓ 4 callersMethodAPIKey
()
pkg/agent/worker.go:291
↓ 4 callersMethodAddPacket
(extSeq uint64, ddVal *dd.DependencyDescriptor)
pkg/sfu/buffer/frameintegrity.go:29
↓ 4 callersMethodAddStaticTrackWithCodec
(codec webrtc.RTPCodecCapability, id string, label string, opts ...AddTrackOption)
test/client/client.go:966
↓ 4 callersMethodAddSubscriber
(sub LocalParticipant)
pkg/rtc/types/interfaces.go:841
↓ 4 callersMethodAddSubscriberCallCount
()
pkg/rtc/types/typesfakes/fake_data_track.go:224
↓ 4 callersMethodCheckSync
()
pkg/sfu/videolayerselector/dependencydescriptor.go:442
↓ 4 callersMethodClearEvents
()
test/webhook_test.go:209
↓ 4 callersMethodClose
(sendLeave bool, reason types.ParticipantCloseReason, isExpectedToResume bool)
pkg/rtc/participant.go:1445
↓ 4 callersMethodCloseIfEmpty
CloseIfEmpty closes the room if all participants had left, or it's still empty past timeout
pkg/rtc/room.go:772
↓ 4 callersMethodCloseSignalConnection
(reason types.SignallingCloseReason)
pkg/rtc/participant_signal.go:38
↓ 4 callersMethodClosed
(guard *ReferenceGuard)
pkg/telemetry/statsworker.go:170
↓ 4 callersMethodCurrentLayer
()
pkg/sfu/forwarder.go:676
↓ 4 callersMethodDecValue
(end RT, dec VT)
pkg/sfu/utils/rangemap.go:95
↓ 4 callersMethodDetermineCodec
(codec webrtc.RTPCodecCapability, extensions []webrtc.RTPHeaderExtensionParameter, videoLayerMode livekit.Vide
pkg/sfu/forwarder.go:352
↓ 4 callersMethodDistanceToDesired
()
pkg/sfu/streamallocator/track.go:189
↓ 4 callersFunctionEnsureIngressAdminPermission
(ctx context.Context)
pkg/service/auth.go:220
↓ 4 callersFunctionEnsureJoinPermission
(ctx context.Context)
pkg/service/auth.go:168
↓ 4 callersMethodFirstJoinedAt
()
pkg/rtc/room.go:412
↓ 4 callersMethodFree
(subscriberID livekit.ParticipantID)
pkg/sfu/utils/downtrackspreader.go:77
↓ 4 callersMethodGetActiveSpeakers
()
pkg/rtc/room.go:381
↓ 4 callersMethodGetAllBuffers
()
pkg/sfu/receiver_base.go:832
↓ 4 callersFunctionGetAvailableNodes
(nodes []*livekit.Node)
pkg/routing/selector/utils.go:43
↓ 4 callersMethodGetEgress
(ctx context.Context, req *rpc.GetEgressRequest)
pkg/service/clients.go:29
↓ 4 callersMethodGetICEConnectionType
()
pkg/rtc/transport.go:1453
↓ 4 callersMethodGetNodeForRoom
(ctx context.Context, roomName livekit.RoomName)
pkg/routing/interfaces.go:135
↓ 4 callersMethodGetNotifier
(key string)
pkg/utils/changenotifier.go:83
↓ 4 callersMethodGetPublishedTrack
(trackID livekit.TrackID)
pkg/rtc/types/interfaces.go:321
← previousnext →501–600 of 7,437, ranked by callers