Functions — github.com/livekit/livekit

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

⨍ Functions 7,437◇ Types & classes 718

↓ 2 callersMethodGetTrend

()

pkg/sfu/bwe/remotebwe/channel_observer.go:170

↓ 2 callersMethodGetUnmatchMediaForOffer

(parsedOffer *sdp.SessionDescription, mediaType string)

pkg/rtc/transportmanager.go:472

↓ 2 callersMethodHandle

()

pkg/rtc/types/interfaces.go:859

↓ 2 callersMethodHandleAnswer

(sd *livekit.SessionDescription)

pkg/rtc/types/interfaces.go:464

↓ 2 callersMethodHandleAvailability

(*livekit.AvailabilityResponse)

pkg/agent/worker.go:75

↓ 2 callersMethodHandleConnection

(context.Context, agent.SignalConn, agent.WorkerRegistration)

pkg/agent/testutils/server.go:31

↓ 2 callersMethodHandleICERestartSDPFragment

(sdpFragment string)

pkg/rtc/types/interfaces.go:460

↓ 2 callersMethodHandleICETrickleSDPFragment

(sdpFragment string)

pkg/rtc/types/interfaces.go:459

↓ 2 callersMethodHandleIncomingPacketLocked

( rawPkt []byte, rtpPacket *rtp.Packet, arrivalTime int64, isBuffered bool, isRTX bool, skippedSeqs []ui

pkg/sfu/buffer/buffer_base.go:725

↓ 2 callersMethodHandleStreamingChange

(track *Track, streamState StreamState)

pkg/sfu/streamallocator/streamstateupdate.go:62

↓ 2 callersMethodHandleSyncState

(*livekit.SyncState)

pkg/rtc/types/interfaces.go:561

↓ 2 callersMethodHandleTWCCFeedback

(report *rtcp.TransportLayerCC)

pkg/sfu/bwe/bwe.go:103

↓ 2 callersMethodHandleUpdateJob

(*livekit.UpdateJobStatus)

pkg/agent/worker.go:76

↓ 2 callersMethodHandleUpdateSubscriptions

( []livekit.TrackID, []*livekit.ParticipantTracks, bool, )

pkg/rtc/types/interfaces.go:555

↓ 2 callersMethodHasParticipant

(context.Context, livekit.RoomName, livekit.ParticipantIdentity)

pkg/service/interfaces.go:56

↓ 2 callersMethodHasParticipants

()

pkg/service/roommanager.go:230

↓ 2 callersMethodHasPermission

HasPermission checks permission of the subscriber by identity. Returns true if subscriber is allowed to subscribe to the track with trackID

pkg/rtc/types/interfaces.go:333

↓ 2 callersMethodHidden

()

pkg/rtc/participant.go:1808

↓ 2 callersMethodICERestart

()

pkg/rtc/transport.go:2021

pkg/rtc/datatrack.go:108

↓ 2 callersMethodID

()

pkg/sfu/track_remote.go:20

↓ 2 callersFunctionIncrementParticipantRtcActive

(active uint32)

pkg/telemetry/prometheus/packets.go:342

↓ 2 callersFunctionIncrementParticipantRtcInit

(init uint32)

pkg/telemetry/prometheus/packets.go:328

↓ 2 callersMethodIngressUpdated

(ctx context.Context, info *livekit.IngressInfo)

pkg/telemetry/telemetryservice.go:80

↓ 2 callersMethodIsConnected

()

pkg/telemetry/statsworker.go:124

↓ 2 callersMethodIsDeficient

()

pkg/sfu/streamallocator/track.go:181

↓ 2 callersMethodIsEncrypted

()

pkg/rtc/types/interfaces.go:805

↓ 2 callersMethodIsFinalized

()

pkg/sfu/bwe/sendsidebwe/packet_group.go:249

↓ 2 callersFunctionIsICECandidateMDNS

(candidate ice.Candidate)

pkg/rtc/types/ice.go:407

↓ 2 callersMethodIsPublisher

()

pkg/rtc/participant.go:1788

↓ 2 callersMethodIsPublisher

()

pkg/rtc/types/interfaces.go:320

↓ 2 callersMethodIsReady

()

pkg/rtc/types/interfaces.go:414

↓ 2 callersMethodIsSealed

()

pkg/sfu/bwe/sendsidebwe/congestion_detector.go:266

↓ 2 callersMethodIsSubscribeMutable

check if subscription mute can be applied

pkg/sfu/downtrack.go:253

↓ 2 callersMethodIsSubscriber

(subID livekit.ParticipantID)

pkg/rtc/types/interfaces.go:843

↓ 2 callersMethodIsValid

(pci ccutils.ProbeClusterInfo)

pkg/sfu/bwe/sendsidebwe/congestion_detector.go:97

↓ 2 callersFunctionIsWebSocketCloseError

IsWebSocketCloseError checks that error is normal/expected closure

pkg/service/wsprotocol.go:191

↓ 2 callersFunctionJobStatusIsEnded

(s livekit.JobStatus)

pkg/agent/worker.go:67

↓ 2 callersMethodJobs

()

pkg/agent/testutils/server.go:428

↓ 2 callersMethodKeyFrame

()

pkg/sfu/rtpstats/rtpstats_base.go:364

↓ 2 callersMethodKindDetails

()

pkg/rtc/types/interfaces.go:308

↓ 2 callersMethodLaunchJob

LaunchJob starts a room or participant job on an agent. it will launch a job once for each worker in each namespace

pkg/agent/client.go:53

↓ 2 callersMethodLayeredTracker

(layer int32)

pkg/sfu/streamtracker/streamtracker_dd.go:275

↓ 2 callersFunctionLimitsReached

TODO: check remote node configured limit, instead of this node's config

pkg/routing/selector/utils.go:59

↓ 2 callersMethodListNodes

()

pkg/routing/interfaces.go:133

↓ 2 callersMethodLoadRoom

(_ context.Context, roomName livekit.RoomName, includeInternal bool)

pkg/service/localstore.go:72

↓ 2 callersMethodLoadRoom

(_ context.Context, roomName livekit.RoomName, includeInternal bool)

pkg/service/redisstore.go:159

↓ 2 callersMethodLogger

()

pkg/agent/worker.go:307

↓ 2 callersFunctionLoggerWithPCTarget

(l logger.Logger, target livekit.SignalTarget)

pkg/rtc/utils.go:152

↓ 2 callersFunctionLoggerWithParticipant

logger helpers

pkg/rtc/utils.go:119

↓ 2 callersFunctionLoggerWithRoom

(l logger.Logger, name livekit.RoomName, roomID livekit.RoomID)

pkg/rtc/utils.go:132

↓ 2 callersFunctionMakeWorkerRegistration

()

pkg/agent/worker.go:160

↓ 2 callersMethodMarkCompleted

(result ProbeClusterResult)

pkg/sfu/ccutils/prober.go:538

↓ 2 callersMethodMarshalLogObject

(e zapcore.ObjectEncoder)

pkg/sfu/rtpstats/rtpstats_sender.go:84

↓ 2 callersMethodMarshalTo

(buf []byte)

pkg/rtc/datatrack/packet.go:288

↓ 2 callersMethodMediaTrack

()

pkg/rtc/subscribedtrack.go:288

↓ 2 callersMethodMerge

(other *livekit.MetricsBatch)

pkg/metric/metrics_reporter.go:79

↓ 2 callersMethodName

()

pkg/rtc/room.go:326

↓ 2 callersMethodName

()

pkg/rtc/datatrack.go:112

↓ 2 callersFunctionNewAPIKeyAuthMiddleware

(provider auth.KeyProvider)

pkg/service/auth.go:56

↓ 2 callersFunctionNewAgentDispatchService

( limitConf config.LimitConfig, agentDispatchClient rpc.TypedAgentDispatchInternalClient, topicFormatter rp

pkg/service/agent_dispatch_service.go:40

↓ 2 callersFunctionNewAgentService

( conf *config.Config, currentNode routing.LocalNode, bus psrpc.MessageBus, keyProvider auth.KeyProvider,

pkg/service/agentservice.go:167

↓ 2 callersFunctionNewBitStreamWriter

(buf []byte)

pkg/sfu/rtpextension/dependencydescriptor/bitstreamwriter.go:28

↓ 2 callersFunctionNewChangeNotifierManager

()

pkg/utils/changenotifier.go:77

↓ 2 callersFunctionNewConn

(c net.Conn, direction prometheus.Direction)

pkg/telemetry/statsconn.go:47

↓ 2 callersFunctionNewDefaultMessageChannel

(connectionID livekit.ConnectionID)

pkg/routing/messagechannel.go:34

↓ 2 callersFunctionNewDependencyDescriptorFromOther

(vls VideoLayerSelector)

pkg/sfu/videolayerselector/dependencydescriptor.go:60

↓ 2 callersFunctionNewDependencyDescriptorWriter

(buf []byte, structure *FrameDependencyStructure, activeChains uint32, descriptor *DependencyDescriptor)

pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorwriter.go:40

↓ 2 callersFunctionNewDummyRedReceiver

(d *DummyReceiver, isRedEncoding bool)

pkg/rtc/wrappedreceiver.go:508

↓ 2 callersFunctionNewDynacastManagerAudio

(params DynacastManagerAudioParams)

pkg/rtc/dynacast/dynacastmanageraudio.go:43

↓ 2 callersFunctionNewForwardStats

(latencyUpdateInterval, reportInterval, latencyWindowLength time.Duration)

pkg/sfu/forwardstats.go:27

↓ 2 callersFunctionNewForwarder

( kind webrtc.RTPCodecType, logger logger.Logger, skipReferenceTS bool, disableOpportunisticAllocation boo

pkg/sfu/forwarder.go:265

↓ 2 callersFunctionNewIOInfoService

( bus psrpc.MessageBus, es EgressStore, is IngressStore, ss SIPStore, ts telemetry.TelemetryService, )

pkg/service/ioservice.go:42

↓ 2 callersFunctionNewListener

(l net.Listener)

pkg/telemetry/statsconn.go:29

↓ 2 callersFunctionNewLocalStore

()

pkg/service/localstore.go:45

↓ 2 callersFunctionNewMediaLossProxy

(params MediaLossProxyParams)

pkg/rtc/medialossproxy.go:48

↓ 2 callersFunctionNewMockTrack

(kind livekit.TrackType, name string)

pkg/rtc/testutils.go:78

↓ 2 callersFunctionNewNoQueue

(logger logger.Logger, bwe bwe.BWE)

pkg/sfu/pacer/no_queue.go:37

↓ 2 callersFunctionNewOpsQueue

(params OpsQueueParams)

pkg/utils/opsqueue.go:42

↓ 2 callersFunctionNewPacketConn

(c net.PacketConn, direction prometheus.Direction)

pkg/telemetry/statsconn.go:80

↓ 2 callersFunctionNewParticipant

(params ParticipantParams)

pkg/rtc/participant.go:343

↓ 2 callersFunctionNewParticipantDataBlob

(params ParticipantDataBlobParams)

pkg/rtc/participant_data_blob.go:34

↓ 2 callersFunctionNewPassThrough

(logger logger.Logger, bwe bwe.BWE)

pkg/sfu/pacer/pass_through.go:26

↓ 2 callersFunctionNewPlayoutDelayController

(minDelay, maxDelay uint32, logger logger.Logger, rtpStats *rtpstats.RTPStatsSender)

pkg/sfu/playoutdelay.go:86

↓ 2 callersFunctionNewProbeRegulator

(params ProbeRegulatorParams)

pkg/sfu/ccutils/probe_regulator.go:63

↓ 2 callersFunctionNewRTPMunger

(logger logger.Logger)

pkg/sfu/rtpmunger.go:73

↓ 2 callersFunctionNewRoom

( room *livekit.Room, internal *livekit.RoomInternal, config WebRTCConfig, roomConfig config.RoomConfig,

pkg/rtc/room.go:243

↓ 2 callersFunctionNewRoomAllocator

(conf *config.Config, router routing.Router, rs ObjectStore)

pkg/service/roomallocator.go:40

↓ 2 callersFunctionNewRoomManagerClient

(clientParams rpc.ClientParams, config config.RoomConfig)

pkg/routing/roommanager.go:37

↓ 2 callersFunctionNewRoomService

( limitConf config.LimitConfig, apiConf config.APIConfig, router routing.MessageRouter, roomAllocator Room

pkg/service/roomservice.go:48

↓ 2 callersFunctionNewSignalMessageSink

(params SignalSinkParams[SendType, RecvType])

pkg/routing/signal.go:266

↓ 2 callersFunctionNewStableJobLoad

(load float32)

pkg/agent/testutils/server.go:438

↓ 2 callersFunctionNewStreamTracker

(params StreamTrackerParams)

pkg/sfu/streamtracker/streamtracker.go:78

↓ 2 callersFunctionNewStreamTrackerDependencyDescriptor

(params StreamTrackerParams)

pkg/sfu/streamtracker/streamtracker_dd.go:45

↓ 2 callersFunctionNewStreamTrackerPacket

(params StreamTrackerPacketParams)

pkg/sfu/streamtracker/streamtracker_packet.go:83

↓ 2 callersFunctionNewSubscriptionManager

(params SubscriptionManagerParams)

pkg/rtc/subscriptionmanager.go:89

↓ 2 callersFunctionNewTurnServer

(conf *config.Config, authHandler turn.AuthHandler, standalone bool)

pkg/service/turn.go:49

↓ 2 callersFunctionNewVP8

(logger logger.Logger)

pkg/sfu/codecmunger/vp8.go:55

↓ 2 callersFunctionNewVP9FromOther

(vls VideoLayerSelector)

pkg/sfu/videolayerselector/vp9.go:34

← previous next →1,101–1,200 of 7,437, ranked by callers