MCPcopy Create free account

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

⨍ Functions 7,437◇ Types & classes 718
↓ 1 callersFunctionmakeTrailer
makeTrailer builds a complete LKTS trailer with both timestamp and frame_id TLVs.
pkg/sfu/packettrailer/packet_trailer_test.go:44
↓ 1 callersMethodmatchSIPDispatchRule
matchSIPDispatchRule finds the best dispatch rule matching the request parameters. Returns an error if no rule matched. Trunk parameter can be nil, in
pkg/service/ioservice_sip.go:59
↓ 1 callersMethodmaxExpectedLayerFromTrackInfo
(force bool)
pkg/sfu/streamtrackermanager.go:582
↓ 1 callersMethodmaxLayerNotifierWorker
()
pkg/sfu/downtrack.go:1059
↓ 1 callersMethodmaybeGrowBucket
(now int64)
pkg/sfu/buffer/buffer_base.go:1227
↓ 1 callersMethodmaybeProbe
()
pkg/sfu/streamallocator/streamallocator.go:1320
↓ 1 callersMethodmaybeProbeWithMedia
()
pkg/sfu/streamallocator/streamallocator.go:1339
↓ 1 callersMethodmaybeProbeWithPadding
()
pkg/sfu/streamallocator/streamallocator.go:1356
↓ 1 callersMethodmaybeRecordRTCanceled
(closeReason types.ParticipantCloseReason)
pkg/rtc/participant.go:1429
↓ 1 callersMethodmaybeRecordSuccess
(tl types.ParticipantTelemetryListener)
pkg/rtc/subscriptionmanager.go:1503
↓ 1 callersMethodmaybeReinit
(oldESN uint64, newESN uint64)
pkg/sfu/rtpstats/rtpstats_sender.go:263
↓ 1 callersMethodmaybeRevokeDataTrackSubscriptions
()
pkg/rtc/participant_data_track.go:175
↓ 1 callersMethodmaybeRevokeSubscriptions
()
pkg/rtc/uptrackmanager.go:407
↓ 1 callersMethodmaybeRunOWDEstimator
(batch *livekit.MetricsBatch)
pkg/metric/metric_timestamper.go:98
↓ 1 callersMethodmaybeUpdateMaxJitter
(jitter float64)
pkg/sfu/rtpstats/rtpstats_sender.go:277
↓ 1 callersMethodmaybeUpdateMaxJitter
(jitter float64)
pkg/sfu/rtpstats/rtpstats_base.go:142
↓ 1 callersMethodmaybeUpdateMaxJitterFeed
(jitter float64)
pkg/sfu/rtpstats/rtpstats_sender.go:268
↓ 1 callersMethodmediaTrackReceived
( track sfu.TrackRemote, rtpReceiver *webrtc.RTPReceiver, )
pkg/rtc/participant.go:3175
↓ 1 callersFunctionmergeCodecsByMime
mergeCodecsByMime returns a union b, deduplicated by mime type.
pkg/rtc/mediaengine.go:151
↓ 1 callersFunctionmustAuthCreds
(t *testing.T, h *TURNAuthHandler, pID livekit.ParticipantID, ttlSeconds int)
pkg/service/turn_test.go:40
↓ 1 callersMethodneedsSubscribe
()
pkg/rtc/subscriptionmanager.go:1539
↓ 1 callersFunctionnewAgentDispatch
This provides utilities attached the agent dispatch to ensure that all pending jobs are created before terminating jobs attached to an agent dispatch.
pkg/rtc/room.go:176
↓ 1 callersFunctionnewAgentJob
This provides utilities to ensure that an agent left the room when killing a job
pkg/rtc/room.go:208
↓ 1 callersFunctionnewChannelObserver
(params channelObserverParams, logger logger.Logger)
pkg/sfu/bwe/remotebwe/channel_observer.go:125
↓ 1 callersFunctionnewCluster
(id ProbeClusterId, mode ProbeClusterMode, pcg ProbeClusterGoal, listener ProberListener)
pkg/sfu/ccutils/prober.go:447
↓ 1 callersFunctionnewCongestionDetector
(params congestionDetectorParams)
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:558
↓ 1 callersFunctionnewDataTrackStats
(params dataTrackStatsParams)
pkg/rtc/datatrack_stats.go:44
↓ 1 callersFunctionnewDynacastQualityAudio
(params dynacastQualityAudioParams)
pkg/rtc/dynacast/dynacastqualityaudio.go:48
↓ 1 callersFunctionnewDynacastQualityVideo
(params dynacastQualityVideoParams)
pkg/rtc/dynacast/dynacastqualityvideo.go:54
↓ 1 callersFunctionnewInProcessTurnServer
(conf *config.Config, authHandler turn.AuthHandler)
pkg/service/wire_gen.go:345
↓ 1 callersFunctionnewLossMeasurement
( jqrConfig CongestionSignalConfig, dqrConfig CongestionSignalConfig, weightedLossConfig WeightedLossConfig
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:348
↓ 1 callersFunctionnewMockLossyDataChannelWriter
(targetBitrate int)
pkg/sfu/datachannel/datachannel_writer_test.go:124
↓ 1 callersFunctionnewNackTracker
(params nackTrackerParams)
pkg/sfu/bwe/remotebwe/nack_tracker.go:63
↓ 1 callersFunctionnewPacketTracker
(params packetTrackerParams)
pkg/sfu/bwe/sendsidebwe/packet_tracker.go:49
↓ 1 callersFunctionnewPeerConnection
( params TransportParams, onBandwidthEstimator func(estimator cc.BandwidthEstimator), )
pkg/rtc/transport.go:333
↓ 1 callersFunctionnewProbeController
(params probeControllerParams)
pkg/sfu/bwe/remotebwe/probe_controller.go:89
↓ 1 callersFunctionnewProbePacketGroup
(params probePacketGroupParams, pci ccutils.ProbeClusterInfo)
pkg/sfu/bwe/sendsidebwe/probe_packet_group.go:66
↓ 1 callersFunctionnewQDMeasurement
(jqrConfig CongestionSignalConfig, dqrConfig CongestionSignalConfig, jqrMinDelay int64, jqrMinTrendCoefficient
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:202
↓ 1 callersFunctionnewQualityScorer
(params qualityScorerParams)
pkg/sfu/connectionquality/scorer.go:228
↓ 1 callersFunctionnewSIPClient
(p rpc.ClientParams)
pkg/service/wire_gen.go:297
↓ 1 callersFunctionnewSignallerAsyncBase
(params signallerAsyncBaseParams)
pkg/rtc/signalling/signallerasyncbase.go:39
↓ 1 callersMethodnewSnapshotLiteID
(extStartSN uint64)
pkg/sfu/rtpstats/rtpstats_base_lite.go:200
↓ 1 callersFunctionnewTWCCFeedback
(params twccFeedbackParams)
pkg/sfu/bwe/sendsidebwe/twcc_feedback.go:55
↓ 1 callersFunctionnewTestReceiverProvider
()
pkg/sfu/connectionquality/connectionstats_test.go:38
↓ 1 callersFunctionnewTestServer
(addr string)
test/webhook_test.go:173
↓ 1 callersFunctionnewWhipService
(rm *RoomManager)
pkg/service/roommanager_service.go:34
↓ 1 callersMethodnotifySession
(ctx context.Context, participant types.Participant)
pkg/service/roommanager_service.go:167
↓ 1 callersFunctionobserveSamplesWithRTPTimestamp
(a *AudioLevel, level uint8, count int, baseTime time.Time)
pkg/sfu/audio/audiolevel_test.go:146
↓ 1 callersMethodonAnyTransportFailed
()
pkg/rtc/participant.go:2668
↓ 1 callersMethodonAnyTransportNegotiationFailed
()
pkg/rtc/participant.go:3781
↓ 1 callersMethodonDataChannel
(dc *webrtc.DataChannel)
pkg/rtc/transport.go:872
↓ 1 callersMethodonDataMessageUnlabeled
(source types.LocalParticipant, data []byte)
pkg/rtc/room.go:1297
↓ 1 callersMethodonDataTrackPublished
(participant types.Participant, dt types.DataTrack)
pkg/rtc/room.go:1170
↓ 1 callersMethodonDataTrackUnpublished
(p types.Participant, dt types.DataTrack)
pkg/rtc/room.go:1207
↓ 1 callersMethodonGetDataBlob
(participant types.LocalParticipant, req *livekit.GetDataBlobRequest)
pkg/rtc/room.go:1387
↓ 1 callersMethodonICECandidate
(c *webrtc.ICECandidate, target livekit.SignalTarget)
pkg/rtc/participant.go:2593
↓ 1 callersMethodonLeave
(p types.LocalParticipant, reason types.ParticipantCloseReason)
pkg/rtc/room.go:1392
↓ 1 callersMethodonMetrics
(source types.Participant, dp *livekit.DataPacket)
pkg/rtc/room.go:1301
↓ 1 callersMethodonParticipantUpdate
(p types.Participant)
pkg/rtc/room.go:1217
↓ 1 callersMethodonPrimaryTransportFullyEstablished
()
pkg/rtc/participant.go:2640
↓ 1 callersMethodonPrimaryTransportInitialConnected
()
pkg/rtc/participant.go:2627
↓ 1 callersMethodonPublisherAnswer
(answer webrtc.SessionDescription, answerId uint32, midToTrackID map[string]string)
pkg/rtc/participant.go:1226
↓ 1 callersMethodonPublisherInitialConnected
()
pkg/rtc/participant.go:2605
↓ 1 callersMethodonPublisherSetRemoteDescription
()
pkg/rtc/participant.go:1208
↓ 1 callersMethodonReceivedDataMessage
(kind livekit.DataPacket_Kind, data []byte)
pkg/rtc/participant.go:2370
↓ 1 callersMethodonReceivedDataMessageUnlabeled
(data []byte)
pkg/rtc/participant.go:2583
↓ 1 callersMethodonReceivedDataTrackMessage
(data []byte, arrivalTime int64)
pkg/rtc/participant_data_track.go:148
↓ 1 callersMethodonSimulateScenario
(participant types.LocalParticipant, simulateScenario *livekit.SimulateScenario)
pkg/rtc/room.go:958
↓ 1 callersMethodonStateChange
(p types.LocalParticipant)
pkg/rtc/room.go:1226
↓ 1 callersMethodonSubscribeStatusChanged
(participant types.LocalParticipant, publisherID livekit.ParticipantID, subscribed bool)
pkg/rtc/room.go:1305
↓ 1 callersMethodonSubscribedAudioCodecChange
( trackID livekit.TrackID, codecs []*livekit.SubscribedAudioCodec, )
pkg/rtc/participant.go:2831
↓ 1 callersMethodonSubscribedMaxQualityChange
( trackID livekit.TrackID, trackInfo *livekit.TrackInfo, subscribedQualities []*livekit.SubscribedCodec, m
pkg/rtc/participant.go:2776
↓ 1 callersMethodonSubscriberInitialConnected
()
pkg/rtc/participant.go:2621
↓ 1 callersMethodonSubscriberOffer
when the server has an offer for participant
pkg/rtc/participant.go:2233
↓ 1 callersMethodonTrackPublished
a ParticipantImpl in the room added a new track, subscribe other participants to it
pkg/rtc/room.go:1073
↓ 1 callersMethodonTrackUnpublished
(p types.Participant, track types.MediaTrack)
pkg/rtc/room.go:1160
↓ 1 callersMethodonUpdateDataSubscriptions
(participant types.LocalParticipant, req *livekit.UpdateDataSubscription)
pkg/rtc/room.go:1374
↓ 1 callersMethodonUpdateSubscriptionPermission
(participant types.LocalParticipant, subscriptionPermission *livekit.SubscriptionPermission)
pkg/rtc/room.go:701
↓ 1 callersMethodonUpdateSubscriptions
( participant types.LocalParticipant, trackIDs []livekit.TrackID, participantTracks []*livekit.ParticipantT
pkg/rtc/room.go:1340
↓ 1 callersFunctionparseEgressEnded
(value string)
pkg/service/redisstore.go:521
↓ 1 callersMethodparseSubscriptionPermissionsLocked
( subscriptionPermission *livekit.SubscriptionPermission, resolver func(participantID livekit.ParticipantID)
pkg/rtc/uptrackmanager.go:297
↓ 1 callersMethodparseTrackMid
(sd webrtc.SessionDescription, senders map[string]*webrtc.RTPSender)
pkg/rtc/transport.go:2274
↓ 1 callersMethodparticipantLeft
()
pkg/rtc/room.go:215
↓ 1 callersMethodpatchExtPacket
(ep *ExtPacket, buf []byte)
pkg/sfu/buffer/buffer_base.go:1180
↓ 1 callersMethodpatchRTPHeaderExtensions
patch just abs-send-time and transport-cc extensions if applicable
pkg/sfu/pacer/base.go:92
↓ 1 callersMethodpingWorker
()
pkg/service/wsprotocol.go:178
↓ 1 callersMethodpopulateSdpCid
(parsedOffer *sdp.SessionDescription)
pkg/rtc/participant_sdp.go:34
↓ 1 callersMethodpostRtcp
(pkts []rtcp.Packet)
pkg/rtc/participant.go:3637
↓ 1 callersMethodpreparePC
(previousAnswer webrtc.SessionDescription)
pkg/rtc/transport.go:2077
↓ 1 callersMethodprocess
()
pkg/utils/opsqueue.go:135
↓ 1 callersMethodprocessAudioSsrcLevelHeaderExtension
(p *rtp.Packet, arrivalTime int64)
pkg/sfu/buffer/buffer_base.go:954
↓ 1 callersMethodprocessSourceSwitch
(extPkt *buffer.ExtPacket, layer int32)
pkg/sfu/forwarder.go:1814
↓ 1 callersMethodprocessVideoPacket
(ep *ExtPacket)
pkg/sfu/buffer/buffer_base.go:1054
↓ 1 callersMethodprune
()
pkg/sfu/ccutils/trenddetector.go:194
↓ 1 callersMethodprunePacketGroups
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:863
↓ 1 callersMethodpushBackClusterAndMaybeStart
(cluster *Cluster)
pkg/sfu/ccutils/prober.go:268
↓ 1 callersMethodread
()
test/agent.go:110
↓ 1 callersMethodreadExtendedFields
()
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorreader.go:119
↓ 1 callersMethodreadFrameChains
()
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorreader.go:434
↓ 1 callersMethodreadFrameDependencyDefinition
()
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorreader.go:351
← previousnext →2,701–2,800 of 7,437, ranked by callers