MCPcopy Create free account

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

↓ 1 callersFunctionRecordJitter
(country string, direction Direction, trackSource livekit.TrackSource, trackType livekit.TrackType, jitter uin
pkg/telemetry/prometheus/packets.go:285
↓ 1 callersMethodRecordPacket
(size int, isRTX bool, probeClusterId ccutils.ProbeClusterId, isProbe bool)
pkg/sfu/pacer/probe_observer.go:103
↓ 1 callersMethodRecordPacketIndicationFromRemote
(sn uint16, recvTime int64)
pkg/sfu/bwe/sendsidebwe/packet_tracker.go:105
↓ 1 callersFunctionRecordPacketLoss
( country string, direction Direction, trackSource livekit.TrackSource, trackType livekit.TrackType, lost
pkg/telemetry/prometheus/packets.go:260
↓ 1 callersFunctionRecordPacketOutOfOrder
(country string, direction Direction, trackSource livekit.TrackSource, trackType livekit.TrackType, ooo, total
pkg/telemetry/prometheus/packets.go:276
↓ 1 callersFunctionRecordPublishTime
( country string, source livekit.TrackSource, trackType livekit.TrackType, d time.Duration, sdk livekit.C
pkg/telemetry/prometheus/rooms.go:200
↓ 1 callersFunctionRecordQuality
(rating livekit.ConnectionQuality, score float32)
pkg/telemetry/prometheus/quality.go:48
↓ 1 callersFunctionRecordRTT
(country string, direction Direction, trackSource livekit.TrackSource, trackType livekit.TrackType, rtt uint32
pkg/telemetry/prometheus/packets.go:291
↓ 1 callersFunctionRecordSessionDuration
(protocolVersion int, d time.Duration)
pkg/telemetry/prometheus/rooms.go:291
↓ 1 callersFunctionRecordSessionJoinLatency
(protocolVersion int, d time.Duration)
pkg/telemetry/prometheus/rooms.go:283
↓ 1 callersFunctionRecordSessionStartTime
(protocolVersion int, d time.Duration)
pkg/telemetry/prometheus/rooms.go:287
↓ 1 callersFunctionRecordSubscribeTime
( country string, source livekit.TrackSource, trackType livekit.TrackType, d time.Duration, sdk livekit.C
pkg/telemetry/prometheus/rooms.go:211
↓ 1 callersFunctionRecordTrackPublishAttempt
(kind string)
pkg/telemetry/prometheus/rooms.go:185
↓ 1 callersFunctionRecordTrackPublishCancels
(kind string, numCancels int32)
pkg/telemetry/prometheus/rooms.go:195
↓ 1 callersFunctionRecordTrackPublishSuccess
(kind string)
pkg/telemetry/prometheus/rooms.go:190
↓ 1 callersFunctionRecordTrackSubscribeAttempt
()
pkg/telemetry/prometheus/rooms.go:264
↓ 1 callersFunctionRecordTrackSubscribeFailure
(err error, isUserError bool)
pkg/telemetry/prometheus/rooms.go:269
↓ 1 callersFunctionRecordTrackSubscribeSuccess
(kind string)
pkg/telemetry/prometheus/rooms.go:248
↓ 1 callersFunctionRecordTrackUnsubscribed
(kind string)
pkg/telemetry/prometheus/rooms.go:257
↓ 1 callersFunctionRecordTwirpRequestLatency
(service, method string, duration time.Duration)
pkg/telemetry/prometheus/node.go:308
↓ 1 callersFunctionRecordTwirpRequestStatus
(service string, method string, statusFamily string, code twirp.ErrorCode)
pkg/telemetry/prometheus/node.go:304
↓ 1 callersMethodRegisterNode
()
pkg/routing/interfaces.go:129
↓ 1 callersMethodRegistered
()
pkg/agent/worker.go:195
↓ 1 callersMethodRegistration
()
pkg/agent/worker.go:191
↓ 1 callersMethodRelaySignal
(stream psrpc.ServerStream[*rpc.RelaySignalResponse, *rpc.RelaySignalRequest])
pkg/service/signal.go:133
↓ 1 callersMethodRelease
(guard *ReferenceGuard)
pkg/telemetry/statsworker.go:46
↓ 1 callersMethodRemoveDeadNodes
()
pkg/routing/interfaces.go:131
↓ 1 callersMethodRemovePublishedTrack
(track MediaTrack, isExpectedToResume bool)
pkg/rtc/types/interfaces.go:323
↓ 1 callersMethodRemoveSubscribedTrack
(subTrack types.SubscribedTrack)
pkg/rtc/transportmanager.go:340
↓ 1 callersMethodRemoveSubscriber
(subID livekit.ParticipantID)
pkg/rtc/datatrack.go:153
↓ 1 callersMethodRemoveTracker
(layer int32)
pkg/sfu/streamtrackermanager.go:316
↓ 1 callersMethodReplaceParticipantRequestSource
(identity livekit.ParticipantIdentity, reqSource routing.MessageSource)
pkg/rtc/room.go:533
↓ 1 callersMethodReset
()
pkg/rtc/signalanddatastats.go:254
↓ 1 callersMethodReset
()
pkg/sfu/bwe/remotebwe/remote_bwe.go:104
↓ 1 callersMethodReset
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:569
↓ 1 callersMethodReset
()
pkg/sfu/streamtracker/streamtracker_frame.go:101
↓ 1 callersMethodResetBuf
(buf []byte)
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorwriter.go:51
↓ 1 callersMethodResolveDataTrack
(LocalParticipant, livekit.TrackID)
pkg/rtc/types/interfaces.go:387
↓ 1 callersMethodResolveDataTrackForSubscriber
(sub LocalParticipant, trackID livekit.TrackID)
pkg/rtc/types/interfaces.go:751
↓ 1 callersMethodResolveMediaTrack
(LocalParticipant, livekit.TrackID)
pkg/rtc/types/interfaces.go:386
↓ 1 callersMethodResolveMediaTrackForSubscriber
(sub LocalParticipant, trackID livekit.TrackID)
pkg/rtc/types/interfaces.go:750
↓ 1 callersMethodRestart
()
pkg/rtc/dynacast/dynacastqualityvideo.go:66
↓ 1 callersMethodRestart
(reason string)
pkg/sfu/receiver_base.go:373
↓ 1 callersMethodRestartStream
(reason string)
pkg/sfu/buffer/buffer_base.go:127
↓ 1 callersMethodResumeParticipant
( p types.LocalParticipant, requestSource routing.MessageSource, responseSink routing.MessageSink, iceConf
pkg/rtc/room.go:548
↓ 1 callersMethodRevokeDisallowedSubscribers
(allowedSubscriberIdentities []livekit.ParticipantIdentity)
pkg/rtc/datatrack.go:172
↓ 1 callersMethodRewrite
(offset time.Duration)
pkg/sfu/rtpextension/abscapturetime/abscapturetime.go:76
↓ 1 callersFunctionRidToSpatialLayer
(mimeType mime.MimeType, rid string, trackInfo *livekit.TrackInfo, ridSpace VideoLayersRid)
pkg/sfu/buffer/videolayerutils.go:66
↓ 1 callersFunctionRoomEnded
(startedAt time.Time)
pkg/telemetry/prometheus/rooms.go:157
↓ 1 callersMethodRoomEnded
(ctx context.Context, room *livekit.Room)
pkg/telemetry/telemetryservice.go:38
↓ 1 callersMethodRoomProjectReporter
(ctx context.Context)
pkg/telemetry/analyticsservice.go:38
↓ 1 callersFunctionRoomStarted
()
pkg/telemetry/prometheus/rooms.go:152
↓ 1 callersMethodRoomStarted
events
pkg/telemetry/telemetryservice.go:37
↓ 1 callersMethodRun
create an offer for the server
test/client/client.go:476
↓ 1 callersMethodRunningJobs
()
pkg/agent/worker.go:311
↓ 1 callersMethodSSRCRTX
()
pkg/sfu/downtrack.go:972
↓ 1 callersMethodSecondsSinceNodeStatsUpdate
()
pkg/routing/node.go:39
↓ 1 callersMethodSelectNode
(nodes []*livekit.Node)
pkg/routing/selector/interfaces.go:30
↓ 1 callersMethodSelectTemporal
(extPkt *buffer.ExtPacket)
pkg/sfu/videolayerselector/videolayerselector.go:64
↓ 1 callersMethodSendAddTrack
send AddTrack command to server to initiate server-side negotiation
test/client/client.go:997
↓ 1 callersMethodSendDataMessage
(kind livekit.DataPacket_Kind, data []byte, sender livekit.ParticipantID, seq uint32)
pkg/rtc/participant.go:3841
↓ 1 callersMethodSendDataPacket
(dp *livekit.DataPacket, kind livekit.DataPacket_Kind)
pkg/rtc/room.go:840
↓ 1 callersMethodSendDataTrackSubscriberHandles
(handles map[uint32]*livekit.DataTrackSubscriberHandles_PublishedDataTrack)
pkg/rtc/types/interfaces.go:509
↓ 1 callersMethodSendJoinResponse
server sent messages
pkg/rtc/types/interfaces.go:497
↓ 1 callersMethodSendNodeRoomStates
(ctx context.Context, nodeRooms *livekit.AnalyticsNodeRooms)
pkg/telemetry/analyticsservice.go:37
↓ 1 callersMethodSendPLI
(force bool)
pkg/sfu/buffer/buffer_base.go:91
↓ 1 callersMethodSendPLI
(force bool)
pkg/sfu/buffer/buffer_base.go:653
↓ 1 callersMethodSendPing
()
test/client/client.go:818
↓ 1 callersMethodSendRefreshToken
(token string)
pkg/rtc/types/interfaces.go:505
↓ 1 callersMethodSendRegister
(m *livekit.RegisterWorkerRequest)
pkg/agent/testutils/server.go:342
↓ 1 callersMethodSendRoomUpdateArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_local_participant.go:7686
↓ 1 callersMethodSendSimulateJob
(m *livekit.SimulateJobRequest)
pkg/agent/testutils/server.go:372
↓ 1 callersMethodSendSpeakerUpdateArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_local_participant.go:7753
↓ 1 callersMethodSendSpeakerUpdateCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:7741
↓ 1 callersMethodSendStats
(ctx context.Context, stats []*livekit.AnalyticsStat)
pkg/telemetry/analyticsservice.go:35
↓ 1 callersMethodSendSubscriptionPermissionUpdateArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_local_participant.go:7816
↓ 1 callersMethodSendSubscriptionPermissionUpdateCallCount
()
pkg/rtc/types/typesfakes/fake_local_participant.go:7804
↓ 1 callersMethodSendUpdateWorker
(m *livekit.UpdateWorkerStatus)
pkg/agent/testutils/server.go:354
↓ 1 callersMethodSendWindow
()
pkg/sfu/bwe/sendsidebwe/packet_group.go:229
↓ 1 callersMethodSetActivePaddingOnMuteUpTrack
SetActivePaddingOnMuteUpTrack will enable padding on the track when its uptrack is muted. Pion will not fire OnTrack event until it receives packet fo
pkg/sfu/downtrack.go:2175
↓ 1 callersMethodSetAllowPause
(allowPause bool)
pkg/sfu/streamallocator/streamallocator.go:375
↓ 1 callersMethodSetAttributes
(attrs map[string]string)
pkg/rtc/participant.go:762
↓ 1 callersMethodSetAudioConfig
(audioConfig AudioConfig)
pkg/sfu/receiver_base.go:304
↓ 1 callersMethodSetAudioLevelConfig
(audioLevelConfig audio.AudioLevelConfig)
pkg/sfu/buffer/buffer_base.go:85
↓ 1 callersFunctionSetAuthorizationToken
(header http.Header, token string)
test/client/client.go:225
↓ 1 callersMethodSetChannelCapacity
(channelCapacity int64)
pkg/sfu/streamallocator/streamallocator.go:382
↓ 1 callersMethodSetEnableRTPStreamRestartDetection
(enableRTPStremRestartDetection bool)
pkg/sfu/receiver_base.go:308
↓ 1 callersMethodSetForwardStats
(forwardStats *ForwardStats)
pkg/sfu/receiver_base.go:316
↓ 1 callersMethodSetICEConfig
(iceConfig *livekit.ICEConfig)
pkg/rtc/transportmanager.go:643
↓ 1 callersMethodSetICEConfig
(iceConfig *livekit.ICEConfig)
pkg/rtc/types/interfaces.go:538
↓ 1 callersMethodSetLBThreshold
(lbThreshold int)
pkg/sfu/receiver_base.go:312
↓ 1 callersMethodSetListener
(listener StreamTrackerManagerListener)
pkg/sfu/streamtrackermanager.go:175
↓ 1 callersMethodSetMaxSeenSpatial
(layer int32)
pkg/sfu/videolayerselector/videolayerselector.go:56
↓ 1 callersMethodSetMaxSeenTemporal
(layer int32)
pkg/sfu/videolayerselector/videolayerselector.go:57
↓ 1 callersMethodSetMaxSpatial
(layer int32)
pkg/sfu/videolayerselector/videolayerselector.go:43
↓ 1 callersMethodSetMetadata
SetMetadata attaches metadata to the participant
pkg/rtc/participant.go:738
↓ 1 callersMethodSetMetadataCalls
(stub func(string))
pkg/rtc/types/typesfakes/fake_local_participant.go:7929
↓ 1 callersMethodSetMigrateInfo
( previousOffer *webrtc.SessionDescription, previousAnswer *webrtc.SessionDescription, mediaTracks []*li
pkg/rtc/types/interfaces.go:520
↓ 1 callersMethodSetName
SetName attaches name to the participant
pkg/rtc/participant.go:714
↓ 1 callersMethodSetNeedsNegotiation
(needs bool)
pkg/rtc/subscribedtrack.go:394
← previousnext →2,201–2,300 of 7,437, ranked by callers