MCPcopy Index your code

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

↓ 11 callersMethodStreamID
()
pkg/sfu/track_remote.go:25
↓ 11 callersMethodUpdateAndGet
(extPkt *buffer.ExtPacket, snOutOfOrder bool, snHasGap bool, maxTemporal int32)
pkg/sfu/codecmunger/codecmunger.go:36
↓ 11 callersMethodUpdateMuteAt
(isMuted bool, at time.Time)
pkg/sfu/connectionquality/connectionstats.go:120
↓ 11 callersMethodWrite
Write adds an RTP Packet, ordering is not guaranteed, newer packets may arrive later
pkg/sfu/buffer/buffer.go:141
↓ 11 callersMethodgetExtPacketMetas
(seqNo []uint16)
pkg/sfu/sequencer.go:309
↓ 11 callersFunctionnewTrackEvent
(event livekit.AnalyticsEventType, room *livekit.Room, participantID livekit.ParticipantID, track *livekit.Tra
pkg/telemetry/events.go:615
↓ 11 callersMethodpush
( packetTime int64, extIncomingSN, extModifiedSN uint64, extModifiedTS uint64, marker bool, layer int8,
pkg/sfu/sequencer.go:151
↓ 11 callersFunctionstopClients
(clients ...*testclient.RTCClient)
test/integration_helpers.go:380
↓ 11 callersFunctionstopWriters
(writers ...testclient.TrackWriter)
test/integration_helpers.go:374
↓ 10 callersMethodCompleted
()
pkg/sfu/buffer/fps.go:41
↓ 10 callersMethodGetFrameRate
()
pkg/sfu/buffer/fps.go:40
↓ 10 callersMethodGetLevel
returns current smoothed audio level
pkg/sfu/audio/audiolevel.go:164
↓ 10 callersMethodGetMaxSeen
()
pkg/sfu/videolayerselector/videolayerselector.go:58
↓ 10 callersMethodGetRedReceiver
Get red receiver for primary codec, used by forward red encodings for opus only codec
pkg/sfu/receiver_base.go:135
↓ 10 callersMethodGetRoom
(_ context.Context, roomName livekit.RoomName)
pkg/service/roommanager.go:185
↓ 10 callersMethodIdentity
()
pkg/rtc/participant.go:532
↓ 10 callersMethodOnClose
(fn func())
pkg/rtc/types/interfaces.go:857
↓ 10 callersFunctionRecordServiceOperationError
(op string, error string)
pkg/telemetry/prometheus/node.go:300
↓ 10 callersMethodString
()
pkg/rtc/participant.go:142
↓ 10 callersMethodSubscriberID
()
pkg/rtc/types/interfaces.go:867
↓ 10 callersMethodType
()
pkg/sfu/bwe/bwe.go:81
↓ 10 callersMethodUpdate
(arrival, left int64)
pkg/sfu/forwardstats.go:38
↓ 10 callersFunctionadminRoomToken
(name string)
test/integration_helpers.go:354
↓ 10 callersFunctionagentToken
()
test/agent_test.go:236
↓ 10 callersMethodclose
()
test/agent.go:192
↓ 10 callersFunctioncreateRoomToken
()
test/integration_helpers.go:344
↓ 10 callersFunctiongetPacket
(sn uint16, ts uint32, payloadSize int)
pkg/sfu/rtpstats/rtpstats_test.go:26
↓ 10 callersFunctionlastRequestResponse
(t *testing.T, sink *routingfakes.FakeMessageSink, idx int)
pkg/rtc/participant_data_blob_handler_test.go:41
↓ 10 callersFunctionnewAgentClient
(token string, port uint32)
test/agent.go:47
↓ 10 callersFunctionshouldLog
(count int)
pkg/sfu/rtpstats/rtpstats_base_lite.go:553
↓ 10 callersFunctionsubscribedAudioCodecsAsString
(c1 []*livekit.SubscribedAudioCodec)
pkg/rtc/dynacast/dynacastmanager_test.go:513
↓ 10 callersMethodupdateTrackInfoOfReceivers
()
pkg/rtc/mediatrackreceiver.go:644
↓ 10 callersFunctionwaitForServerToStart
(s *service.LivekitServer)
test/integration_helpers.go:114
↓ 9 callersMethodAddDropped
(entity uint64)
pkg/sfu/videolayerselector/selectordecisioncache.go:74
↓ 9 callersMethodAddTransceiverFromKind
( kind webrtc.RTPCodecType, init webrtc.RTPTransceiverInit, )
pkg/rtc/transport.go:1143
↓ 9 callersFunctionConvertAudioLevel
--------------------------------------------------- convert decibel back to linear
pkg/sfu/audio/audiolevel.go:195
↓ 9 callersMethodDeleteRoom
(ctx context.Context, roomName livekit.RoomName)
pkg/service/interfaces.go:55
↓ 9 callersMethodGetAnswer
()
pkg/rtc/types/interfaces.go:458
↓ 9 callersMethodGetDelayExtension
(seq uint16)
pkg/sfu/playoutdelay.go:172
↓ 9 callersMethodGetLayeredBitrate
()
pkg/sfu/receiver_base.go:114
↓ 9 callersMethodHandleStoreDataBlobRequest
(*livekit.StoreDataBlobRequest)
pkg/rtc/types/interfaces.go:568
↓ 9 callersMethodIDReturns
(result1 livekit.TrackID)
pkg/rtc/types/typesfakes/fake_media_track.go:838
↓ 9 callersFunctionIncrementParticipantRtcCanceled
(canceled uint64)
pkg/telemetry/prometheus/packets.go:349
↓ 9 callersMethodJoin
( participant types.LocalParticipant, requestSource routing.MessageSource, opts *ParticipantOptions, iceSe
pkg/rtc/room.go:440
↓ 9 callersFunctionNewLocalNode
(conf *config.Config)
pkg/routing/node.go:49
↓ 9 callersFunctionNewStreamStateUpdate
()
pkg/sfu/streamallocator/streamstateupdate.go:58
↓ 9 callersMethodNotifyEvent
(ctx context.Context, event *livekit.WebhookEvent, opts ...webhook.NotifyOption)
pkg/telemetry/events.go:32
↓ 9 callersMethodOnOfferCalls
(stub func(webrtc.SessionDescription, uint32, map[string]string) error)
pkg/rtc/transport/transportfakes/fake_handler.go:569
↓ 9 callersMethodReadBool
()
pkg/sfu/rtpextension/dependencydescriptor/bitstreamreader.go:80
↓ 9 callersMethodReceiver
()
pkg/rtc/wrappedreceiver.go:214
↓ 9 callersMethodRecvPacket
(ep *ExtPacket)
pkg/sfu/buffer/fps.go:39
↓ 9 callersMethodRemoveParticipant
(identity livekit.ParticipantIdentity, pID livekit.ParticipantID, reason ParticipantCloseReason)
pkg/rtc/types/interfaces.go:743
↓ 9 callersMethodSeedState
(state any)
pkg/sfu/codecmunger/codecmunger.go:31
↓ 9 callersMethodSetMaxPublishedLayer
(maxPublishedLayer int32)
pkg/sfu/forwarder.go:296
↓ 9 callersMethodSource
()
pkg/rtc/types/interfaces.go:763
↓ 9 callersMethodStop
()
pkg/agent/client.go:55
↓ 9 callersMethodSubscriberID
()
pkg/sfu/downtrack.go:66
↓ 9 callersMethodToProto
()
pkg/rtc/room.go:322
↓ 9 callersMethodUpdate
(bytes int, time int64)
pkg/sfu/buffer/datastats.go:48
↓ 9 callersMethodUpdateParticipant
(ctx context.Context, req *livekit.UpdateParticipantRequest)
pkg/service/roommanager.go:873
↓ 9 callersFunctiongetPacketsExpected
(extStartSN, extHighestSN uint64)
pkg/sfu/rtpstats/rtpstats_base_lite.go:549
↓ 9 callersMethodloadReceivers
()
pkg/rtc/mediatrackreceiver.go:1207
↓ 9 callersMethodmaybeSendUpdate
(update *StreamStateUpdate)
pkg/sfu/streamallocator/streamallocator.go:1237
↓ 9 callersFunctionnewRTPMunger
()
pkg/sfu/rtpmunger_test.go:27
↓ 9 callersFunctionnewTestTurnAuthHandler
()
pkg/service/turn_test.go:36
↓ 9 callersFunctionobserveSamples
(a *AudioLevel, level uint8, count int, baseTime time.Time)
pkg/sfu/audio/audiolevel_test.go:140
↓ 9 callersMethodqueueReconcile
trigger an immediate reconciliation, when trackID is empty, will reconcile all subscriptions
pkg/rtc/subscriptionmanager.go:673
↓ 8 callersMethodAddForwarded
(entity uint64)
pkg/sfu/videolayerselector/selectordecisioncache.go:70
↓ 8 callersMethodAddICECandidate
(candidate webrtc.ICECandidateInit)
pkg/rtc/transport.go:995
↓ 8 callersMethodGetMOSAndQuality
()
pkg/sfu/connectionquality/scorer.go:598
↓ 8 callersMethodGetParticipant
(identity livekit.ParticipantIdentity)
pkg/rtc/room.go:343
↓ 8 callersMethodGetPrimaryReceiverForRed
Get primary receiver if this receiver represents a RED codec; otherwise it will return itself
pkg/sfu/receiver_base.go:132
↓ 8 callersMethodGetPublishedDataTracks
()
pkg/rtc/types/interfaces.go:325
↓ 8 callersMethodGetState
()
pkg/sfu/codecmunger/codecmunger.go:30
↓ 8 callersMethodIsClosed
()
pkg/rtc/participant.go:1531
↓ 8 callersMethodLoadSIPInboundTrunk
(ctx context.Context, sipTrunkID string)
pkg/service/interfaces.go:94
↓ 8 callersMethodLoadSIPOutboundTrunk
(ctx context.Context, sipTrunkID string)
pkg/service/interfaces.go:95
↓ 8 callersMethodLogger
(ctx context.Context)
pkg/service/signal.go:37
↓ 8 callersMethodMarshalSize
()
pkg/rtc/datatrack/packet.go:172
↓ 8 callersMethodMaxLayer
()
pkg/sfu/downtrack.go:1534
↓ 8 callersFunctionNewConnectionStats
(params ConnectionStatsParams)
pkg/sfu/connectionquality/connectionstats.go:78
↓ 8 callersMethodPublisherID
()
pkg/rtc/types/interfaces.go:838
↓ 8 callersMethodRemoveSubscriber
(participantID livekit.ParticipantID)
pkg/rtc/types/interfaces.go:842
↓ 8 callersMethodResolve
(_subscriber types.LocalParticipant, trackID livekit.TrackID)
pkg/rtc/subscriptionmanager_test.go:581
↓ 8 callersMethodSendMessage
(m *livekit.WorkerMessage)
pkg/agent/testutils/server.go:335
↓ 8 callersMethodSetLast
(extPkt *buffer.ExtPacket)
pkg/sfu/codecmunger/codecmunger.go:33
↓ 8 callersMethodSetLogger
(lgr logger.Logger)
pkg/sfu/buffer/buffer_base.go:84
↓ 8 callersMethodSetRequestSpatial
(layer int32)
pkg/sfu/videolayerselector/videolayerselector.go:50
↓ 8 callersMethodbroadcastParticipantState
broadcast an update about participant p
pkg/rtc/room.go:1525
↓ 8 callersFunctiondisable
(f *Forwarder)
pkg/sfu/forwarder_test.go:31
↓ 8 callersFunctiongeneratePkts
(header rtp.Header, count int, tsStep uint32)
pkg/sfu/redreceiver_test.go:265
↓ 8 callersMethodgetDataDownTrack
()
pkg/rtc/subscriptionmanager.go:1620
↓ 8 callersMethodloadREDTransformer
()
pkg/sfu/receiver_base.go:1272
↓ 8 callersFunctionnewParticipantForTestWithOpts
(identity livekit.ParticipantIdentity, opts *participantOpts)
pkg/rtc/participant_internal_test.go:767
↓ 8 callersFunctionnewTestDataBlob
()
pkg/rtc/participant_data_blob_test.go:28
↓ 8 callersFunctionnewTestSubscriptionManager
()
pkg/rtc/subscriptionmanager_test.go:531
↓ 8 callersFunctionpublishTracksForClients
(t *testing.T, clients ...*testclient.RTCClient)
test/scenarios.go:330
↓ 8 callersMethodrecordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_participant_listener.go:344
↓ 8 callersMethodrecordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_room.go:529
↓ 8 callersFunctionverifyRedEncodings
(t *testing.T, red *rtp.Packet, redPkts []*rtp.Packet)
pkg/sfu/redreceiver_test.go:237
← previousnext →201–300 of 7,437, ranked by callers