MCPcopy Create free account

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

⨍ Functions 7,437◇ Types & classes 718
↓ 2 callersFunctionNewWSSignalConnection
(conn types.WebsocketClient)
pkg/service/wsprotocol.go:46
↓ 2 callersFunctionNewWebRTCConfig
(conf *config.Config)
pkg/rtc/config.go:62
↓ 2 callersFunctionNormalizeVideoLayersRid
(rids VideoLayersRid)
pkg/sfu/buffer/videolayerutils.go:498
↓ 2 callersMethodNotifyEgressEvent
(ctx context.Context, event string, info *livekit.EgressInfo)
pkg/telemetry/telemetryservice.go:93
↓ 2 callersMethodNotifySubscriberNodeMaxQuality
(nodeID livekit.NodeID, qualities []SubscribedCodecQuality)
pkg/rtc/types/interfaces.go:823
↓ 2 callersMethodNotifySubscriptionNode
(nodeID livekit.NodeID, codecs []*livekit.SubscribedAudioCodec)
pkg/rtc/types/interfaces.go:824
↓ 2 callersMethodOnAvailableLayersChanged
()
pkg/sfu/streamtrackermanager.go:36
↓ 2 callersMethodOnBitrateAvailabilityChanged
video layer bitrate availability changed
pkg/sfu/downtrack.go:229
↓ 2 callersMethodOnBitrateAvailable
(f func())
pkg/sfu/streamtracker/interfaces.go:65
↓ 2 callersMethodOnBitrateReport
(availableLayers []int32, bitrates Bitrates)
pkg/sfu/streamtrackermanager.go:41
↓ 2 callersMethodOnCloseArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_data_down_track.go:152
↓ 2 callersMethodOnCloseHandler
OnCloseHandler method to be called on remote track removed
pkg/sfu/receiver.go:286
↓ 2 callersMethodOnCodecChange
(fn func(webrtc.RTPCodecParameters))
pkg/sfu/buffer/buffer_base.go:110
↓ 2 callersMethodOnCongestionStateChange
(fromState CongestionState, toState CongestionState, estimatedAvailableChannelCapacity int64)
pkg/sfu/bwe/bwe.go:120
↓ 2 callersMethodOnDataMessageCalls
(stub func(livekit.DataPacket_Kind, []byte))
pkg/rtc/transport/transportfakes/fake_handler.go:223
↓ 2 callersMethodOnDataMessageUnlabeledCalls
(stub func([]byte))
pkg/rtc/transport/transportfakes/fake_handler.go:260
↓ 2 callersMethodOnDataSendError
(err error)
pkg/rtc/transport/handler.go:45
↓ 2 callersMethodOnDataTrackMessageCalls
(stub func([]byte, int64))
pkg/rtc/transport/transportfakes/fake_handler.go:330
↓ 2 callersMethodOnDownTrackCreated
(f func(downTrack *sfu.DownTrack))
pkg/rtc/mediatracksubscriptions.go:66
↓ 2 callersMethodOnFullyEstablishedCalls
(stub func())
pkg/rtc/transport/transportfakes/fake_handler.go:394
↓ 2 callersMethodOnInitialConnected
()
pkg/rtc/transport/handler.go:38
↓ 2 callersMethodOnMaxPublishedLayerChanged
(maxPublishedLayer int32)
pkg/sfu/streamtrackermanager.go:38
↓ 2 callersMethodOnMaxSubscribedLayerChanged
(layer int32)
pkg/sfu/downtrack.go:261
↓ 2 callersMethodOnMaxTemporalLayerSeenChanged
(maxTemporalLayerSeen int32)
pkg/sfu/streamtrackermanager.go:39
↓ 2 callersMethodOnMetrics
(Participant, *livekit.DataPacket)
pkg/rtc/types/interfaces.go:596
↓ 2 callersMethodOnNegotiationStateChanged
(f func(state transport.NegotiationState))
pkg/rtc/transport.go:1957
↓ 2 callersMethodOnOffer
(sd webrtc.SessionDescription, offerId uint32, midToTrackID map[string]string)
pkg/rtc/transport/handler.go:46
↓ 2 callersMethodOnParticipantChanged
(f func(participant types.Participant))
pkg/rtc/room.go:836
↓ 2 callersMethodOnREMB
RTCP received
pkg/sfu/downtrack.go:222
↓ 2 callersMethodOnSetRemoteDescriptionOffer
()
pkg/rtc/transport/handler.go:47
↓ 2 callersMethodOnStreamRestart
()
pkg/sfu/receiver_base.go:168
↓ 2 callersMethodOnSubscriberAudioCodecChange
(f func(subscriberID livekit.ParticipantID, mime mime.MimeType, enabled bool))
pkg/rtc/mediatracksubscriptions.go:74
↓ 2 callersMethodOnSubscriptionChanged
subscription changed - mute/unmute
pkg/sfu/downtrack.go:238
↓ 2 callersMethodOnTrackCalls
(stub func(*webrtc.TrackRemote, *webrtc.RTPReceiver))
pkg/rtc/transport/transportfakes/fake_handler.go:710
↓ 2 callersMethodOnTrackSubscribeFailedCallCount
()
pkg/rtc/types/typesfakes/fake_participant_telemetry_listener.go:380
↓ 2 callersMethodOnTrackUnsubscribed
(pID livekit.ParticipantID, ti *livekit.TrackInfo, shouldSendEvent bool)
pkg/rtc/types/interfaces.go:686
↓ 2 callersMethodOnTransportCCFeedback
(dt *DownTrack, cc *rtcp.TransportLayerCC)
pkg/sfu/downtrack.go:223
↓ 2 callersMethodOnVideoSizeChanged
(fn func([]codec.VideoSize))
pkg/sfu/buffer/buffer_base.go:109
↓ 2 callersFunctionPackStreamID
(participantID livekit.ParticipantID, trackID livekit.TrackID)
pkg/rtc/utils.go:45
↓ 2 callersFunctionParseClientInfo
(r *http.Request)
pkg/service/utils.go:145
↓ 2 callersMethodParseUsername
(username string)
pkg/service/turn.go:213
↓ 2 callersFunctionParticipantInitFromStartSession
(ss *livekit.StartSession, region string)
pkg/routing/interfaces.go:288
↓ 2 callersMethodPause
()
pkg/sfu/downtrack.go:1736
↓ 2 callersMethodPause
()
pkg/sfu/streamallocator/track.go:177
↓ 2 callersMethodPerformRpc
(req *livekit.PerformRpcRequest, resultCh chan string, errorCh chan error)
pkg/rtc/types/interfaces.go:574
↓ 2 callersMethodProbeClusterFinalize
()
pkg/sfu/bwe/bwe.go:114
↓ 2 callersMethodProcess
()
pkg/sfu/ccutils/prober.go:546
↓ 2 callersMethodProcessPacketGroup
(pg *packetGroup, groupIdx int)
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:213
↓ 2 callersMethodProvisionalAllocate
(availableChannelCapacity int64, layer buffer.VideoLayer, allowPause bool, allowOvershoot bool)
pkg/sfu/streamallocator/track.go:153
↓ 2 callersMethodProvisionalAllocateGetCooperativeTransition
(allowOvershoot bool)
pkg/sfu/streamallocator/track.go:157
↓ 2 callersMethodProvisionalAllocateReset
()
pkg/sfu/streamallocator/track.go:149
↓ 2 callersMethodPubHandle
()
pkg/rtc/types/interfaces.go:834
↓ 2 callersMethodPublishData
(data []byte, kind livekit.DataPacket_Kind)
test/client/client.go:1015
↓ 2 callersFunctionPushAndDequeueUpdates
push a participant update for batched broadcast, optionally returning immediate updates to broadcast. it handles the following scenarios * subscriber-
pkg/rtc/room.go:2229
↓ 2 callersMethodQueuingRegion
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:270
↓ 2 callersMethodRTCTrack
()
pkg/sfu/track_remote.go:28
↓ 2 callersMethodRead
(p []byte, sid string)
test/client/datachannel_reader.go:21
↓ 2 callersMethodReadChan
()
pkg/routing/messagechannel.go:73
↓ 2 callersMethodReadExtended
(buf []byte)
pkg/sfu/buffer/buffer_base.go:93
↓ 2 callersMethodReadNonSymmetric
Reads value in range [0, `num_values` - 1]. This encoding is similar to ReadBits(val, Ceil(Log2(num_values)), but reduces wastage incurred when encodi
pkg/sfu/rtpextension/dependencydescriptor/bitstreamreader.go:102
↓ 2 callersMethodReconcileAll
()
pkg/rtc/subscriptionmanager.go:430
↓ 2 callersFunctionReconcileRTPDeltaInfoWithRTX
(primaryDeltaInfo *RTPDeltaInfo, rtxDeltaInfo *RTPDeltaInfo)
pkg/sfu/rtpstats/rtpstats_base.go:977
↓ 2 callersMethodRecordPacketSendAndGetSequenceNumber
TWCC sequence number
pkg/sfu/bwe/bwe.go:95
↓ 2 callersFunctionRecordSignalRequestFailure
()
pkg/telemetry/prometheus/node.go:284
↓ 2 callersMethodRefreshToken
()
test/client/client.go:804
↓ 2 callersMethodRegisterNode
()
pkg/routing/redisrouter.go:69
↓ 2 callersMethodRegressTo
(other dynacastQuality)
pkg/rtc/dynacast/interfaces.go:161
↓ 2 callersFunctionReleaseExtDependencyDescriptor
------------------------------------------------------------------------------
pkg/sfu/buffer/dependencydescriptorparser.go:333
↓ 2 callersMethodRemoveDataTrack
(dataTrack types.DataTrack)
pkg/rtc/roomtrackmanager.go:201
↓ 2 callersMethodRemoveObserver
(key string)
pkg/rtc/types/interfaces.go:903
↓ 2 callersMethodRemovePublishedDataTrack
(track DataTrack)
pkg/rtc/types/interfaces.go:327
↓ 2 callersMethodRemoveSubscriber
RemoveSubscriber removes participant from subscription stop all forwarders to the client
pkg/rtc/mediatrackreceiver.go:610
↓ 2 callersMethodRemoveTrackFromStreamAllocator
(subTrack types.SubscribedTrack)
pkg/rtc/transport.go:2053
↓ 2 callersMethodRemoveTrackLocal
(sender *webrtc.RTPSender)
pkg/rtc/types/interfaces.go:469
↓ 2 callersMethodResetShortConnOnICERestart
()
pkg/rtc/transport.go:2033
↓ 2 callersMethodRestart
()
pkg/rtc/dynacast/interfaces.go:53
↓ 2 callersMethodRestart
closes all associated buffers and issues a resync to all attached downtracks so that they can resync and have proper sequncing without gaps in sequenc
pkg/sfu/receiver_base.go:153
↓ 2 callersMethodRevokeDisallowedSubscribers
(allowedSubscriberIdentities []livekit.ParticipantIdentity)
pkg/rtc/types/interfaces.go:844
↓ 2 callersMethodRollback
()
pkg/sfu/videolayerselector/videolayerselector.go:65
↓ 2 callersMethodRoomExists
(ctx context.Context, roomName livekit.RoomName)
pkg/service/interfaces.go:47
↓ 2 callersMethodSeedState
(seed any)
pkg/sfu/codecmunger/vp8.go:87
↓ 2 callersMethodSelect
(extPkt *buffer.ExtPacket, layer int32)
pkg/sfu/videolayerselector/videolayerselector.go:63
↓ 2 callersMethodSelectSIPDispatchRule
(ctx context.Context, trunkID string)
pkg/service/ioservice_sip.go:73
↓ 2 callersMethodSelectSIPInboundTrunk
(ctx context.Context, called string)
pkg/service/ioservice_sip.go:50
↓ 2 callersMethodSendAvailability
(m *livekit.AvailabilityResponse)
pkg/agent/testutils/server.go:348
↓ 2 callersMethodSendConnectionQualityUpdate
(update *livekit.ConnectionQualityUpdate)
pkg/rtc/types/interfaces.go:503
↓ 2 callersMethodSendDataMessageArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_local_participant.go:7247
↓ 2 callersMethodSendDataTrackMessage
(data []byte)
pkg/rtc/types/interfaces.go:874
↓ 2 callersMethodSendIceCandidate
(ic *webrtc.ICECandidate, target livekit.SignalTarget)
test/client/client.go:845
↓ 2 callersMethodSendJoinResponseArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_local_participant.go:7437
↓ 2 callersMethodSendParticipantUpdate
(participantsToUpdate []*livekit.ParticipantInfo)
pkg/rtc/participant_signal.go:77
↓ 2 callersFunctionSendParticipantUpdates
(updates []*ParticipantUpdate, participants []types.LocalParticipant, batchTargetSize int)
pkg/rtc/room.go:2284
↓ 2 callersMethodSendRoomUpdate
(room *livekit.Room)
pkg/rtc/types/interfaces.go:502
↓ 2 callersMethodSendSubscriptionPermissionUpdate
(publisherID livekit.ParticipantID, trackID livekit.TrackID, allowed bool)
pkg/rtc/types/interfaces.go:504
↓ 2 callersMethodSetAllowPauseOfStreamAllocator
(allowPause bool)
pkg/rtc/transport.go:2061
↓ 2 callersMethodSetAudioLossProxying
(enable bool)
pkg/sfu/buffer/buffer.go:98
↓ 2 callersFunctionSetAuthorizationToken
(r *http.Request, token string)
pkg/service/auth.go:164
↓ 2 callersMethodSetBWEListener
(bweListner BWEListener)
pkg/sfu/bwe/bwe.go:83
↓ 2 callersMethodSetChannelCapacityOfStreamAllocator
(channelCapacity int64)
pkg/rtc/transport.go:2069
↓ 2 callersMethodSetClosing
(isExpectedToResume bool)
pkg/rtc/mediatrackreceiver.go:409
← previousnext →1,201–1,300 of 7,437, ranked by callers