Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/livekit/livekit
/ functions
Functions
7,437 in github.com/livekit/livekit
⨍
Functions
7,437
◇
Types & classes
718
↓ 11 callers
Method
StreamID
()
pkg/sfu/track_remote.go:25
↓ 11 callers
Method
UpdateAndGet
(extPkt *buffer.ExtPacket, snOutOfOrder bool, snHasGap bool, maxTemporal int32)
pkg/sfu/codecmunger/codecmunger.go:36
↓ 11 callers
Method
UpdateMuteAt
(isMuted bool, at time.Time)
pkg/sfu/connectionquality/connectionstats.go:120
↓ 11 callers
Method
Write
Write adds an RTP Packet, ordering is not guaranteed, newer packets may arrive later
pkg/sfu/buffer/buffer.go:141
↓ 11 callers
Method
getExtPacketMetas
(seqNo []uint16)
pkg/sfu/sequencer.go:309
↓ 11 callers
Function
newTrackEvent
(event livekit.AnalyticsEventType, room *livekit.Room, participantID livekit.ParticipantID, track *livekit.Tra
pkg/telemetry/events.go:615
↓ 11 callers
Method
push
( packetTime int64, extIncomingSN, extModifiedSN uint64, extModifiedTS uint64, marker bool, layer int8,
pkg/sfu/sequencer.go:151
↓ 11 callers
Function
stopClients
(clients ...*testclient.RTCClient)
test/integration_helpers.go:380
↓ 11 callers
Function
stopWriters
(writers ...testclient.TrackWriter)
test/integration_helpers.go:374
↓ 10 callers
Method
Completed
()
pkg/sfu/buffer/fps.go:41
↓ 10 callers
Method
GetFrameRate
()
pkg/sfu/buffer/fps.go:40
↓ 10 callers
Method
GetLevel
returns current smoothed audio level
pkg/sfu/audio/audiolevel.go:164
↓ 10 callers
Method
GetMaxSeen
()
pkg/sfu/videolayerselector/videolayerselector.go:58
↓ 10 callers
Method
GetRedReceiver
Get red receiver for primary codec, used by forward red encodings for opus only codec
pkg/sfu/receiver_base.go:135
↓ 10 callers
Method
GetRoom
(_ context.Context, roomName livekit.RoomName)
pkg/service/roommanager.go:185
↓ 10 callers
Method
Identity
()
pkg/rtc/participant.go:532
↓ 10 callers
Method
OnClose
(fn func())
pkg/rtc/types/interfaces.go:857
↓ 10 callers
Function
RecordServiceOperationError
(op string, error string)
pkg/telemetry/prometheus/node.go:300
↓ 10 callers
Method
String
()
pkg/rtc/participant.go:142
↓ 10 callers
Method
SubscriberID
()
pkg/rtc/types/interfaces.go:867
↓ 10 callers
Method
Type
()
pkg/sfu/bwe/bwe.go:81
↓ 10 callers
Method
Update
(arrival, left int64)
pkg/sfu/forwardstats.go:38
↓ 10 callers
Function
adminRoomToken
(name string)
test/integration_helpers.go:354
↓ 10 callers
Function
agentToken
()
test/agent_test.go:236
↓ 10 callers
Method
close
()
test/agent.go:192
↓ 10 callers
Function
createRoomToken
()
test/integration_helpers.go:344
↓ 10 callers
Function
getPacket
(sn uint16, ts uint32, payloadSize int)
pkg/sfu/rtpstats/rtpstats_test.go:26
↓ 10 callers
Function
lastRequestResponse
(t *testing.T, sink *routingfakes.FakeMessageSink, idx int)
pkg/rtc/participant_data_blob_handler_test.go:41
↓ 10 callers
Function
newAgentClient
(token string, port uint32)
test/agent.go:47
↓ 10 callers
Function
shouldLog
(count int)
pkg/sfu/rtpstats/rtpstats_base_lite.go:553
↓ 10 callers
Function
subscribedAudioCodecsAsString
(c1 []*livekit.SubscribedAudioCodec)
pkg/rtc/dynacast/dynacastmanager_test.go:513
↓ 10 callers
Method
updateTrackInfoOfReceivers
()
pkg/rtc/mediatrackreceiver.go:644
↓ 10 callers
Function
waitForServerToStart
(s *service.LivekitServer)
test/integration_helpers.go:114
↓ 9 callers
Method
AddDropped
(entity uint64)
pkg/sfu/videolayerselector/selectordecisioncache.go:74
↓ 9 callers
Method
AddTransceiverFromKind
( kind webrtc.RTPCodecType, init webrtc.RTPTransceiverInit, )
pkg/rtc/transport.go:1143
↓ 9 callers
Function
ConvertAudioLevel
--------------------------------------------------- convert decibel back to linear
pkg/sfu/audio/audiolevel.go:195
↓ 9 callers
Method
DeleteRoom
(ctx context.Context, roomName livekit.RoomName)
pkg/service/interfaces.go:55
↓ 9 callers
Method
GetAnswer
()
pkg/rtc/types/interfaces.go:458
↓ 9 callers
Method
GetDelayExtension
(seq uint16)
pkg/sfu/playoutdelay.go:172
↓ 9 callers
Method
GetLayeredBitrate
()
pkg/sfu/receiver_base.go:114
↓ 9 callers
Method
HandleStoreDataBlobRequest
(*livekit.StoreDataBlobRequest)
pkg/rtc/types/interfaces.go:568
↓ 9 callers
Method
IDReturns
(result1 livekit.TrackID)
pkg/rtc/types/typesfakes/fake_media_track.go:838
↓ 9 callers
Function
IncrementParticipantRtcCanceled
(canceled uint64)
pkg/telemetry/prometheus/packets.go:349
↓ 9 callers
Method
Join
( participant types.LocalParticipant, requestSource routing.MessageSource, opts *ParticipantOptions, iceSe
pkg/rtc/room.go:440
↓ 9 callers
Function
NewLocalNode
(conf *config.Config)
pkg/routing/node.go:49
↓ 9 callers
Function
NewStreamStateUpdate
()
pkg/sfu/streamallocator/streamstateupdate.go:58
↓ 9 callers
Method
NotifyEvent
(ctx context.Context, event *livekit.WebhookEvent, opts ...webhook.NotifyOption)
pkg/telemetry/events.go:32
↓ 9 callers
Method
OnOfferCalls
(stub func(webrtc.SessionDescription, uint32, map[string]string) error)
pkg/rtc/transport/transportfakes/fake_handler.go:569
↓ 9 callers
Method
ReadBool
()
pkg/sfu/rtpextension/dependencydescriptor/bitstreamreader.go:80
↓ 9 callers
Method
Receiver
()
pkg/rtc/wrappedreceiver.go:214
↓ 9 callers
Method
RecvPacket
(ep *ExtPacket)
pkg/sfu/buffer/fps.go:39
↓ 9 callers
Method
RemoveParticipant
(identity livekit.ParticipantIdentity, pID livekit.ParticipantID, reason ParticipantCloseReason)
pkg/rtc/types/interfaces.go:743
↓ 9 callers
Method
SeedState
(state any)
pkg/sfu/codecmunger/codecmunger.go:31
↓ 9 callers
Method
SetMaxPublishedLayer
(maxPublishedLayer int32)
pkg/sfu/forwarder.go:296
↓ 9 callers
Method
Source
()
pkg/rtc/types/interfaces.go:763
↓ 9 callers
Method
Stop
()
pkg/agent/client.go:55
↓ 9 callers
Method
SubscriberID
()
pkg/sfu/downtrack.go:66
↓ 9 callers
Method
ToProto
()
pkg/rtc/room.go:322
↓ 9 callers
Method
Update
(bytes int, time int64)
pkg/sfu/buffer/datastats.go:48
↓ 9 callers
Method
UpdateParticipant
(ctx context.Context, req *livekit.UpdateParticipantRequest)
pkg/service/roommanager.go:873
↓ 9 callers
Function
getPacketsExpected
(extStartSN, extHighestSN uint64)
pkg/sfu/rtpstats/rtpstats_base_lite.go:549
↓ 9 callers
Method
loadReceivers
()
pkg/rtc/mediatrackreceiver.go:1207
↓ 9 callers
Method
maybeSendUpdate
(update *StreamStateUpdate)
pkg/sfu/streamallocator/streamallocator.go:1237
↓ 9 callers
Function
newRTPMunger
()
pkg/sfu/rtpmunger_test.go:27
↓ 9 callers
Function
newTestTurnAuthHandler
()
pkg/service/turn_test.go:36
↓ 9 callers
Function
observeSamples
(a *AudioLevel, level uint8, count int, baseTime time.Time)
pkg/sfu/audio/audiolevel_test.go:140
↓ 9 callers
Method
queueReconcile
trigger an immediate reconciliation, when trackID is empty, will reconcile all subscriptions
pkg/rtc/subscriptionmanager.go:673
↓ 8 callers
Method
AddForwarded
(entity uint64)
pkg/sfu/videolayerselector/selectordecisioncache.go:70
↓ 8 callers
Method
AddICECandidate
(candidate webrtc.ICECandidateInit)
pkg/rtc/transport.go:995
↓ 8 callers
Method
GetMOSAndQuality
()
pkg/sfu/connectionquality/scorer.go:598
↓ 8 callers
Method
GetParticipant
(identity livekit.ParticipantIdentity)
pkg/rtc/room.go:343
↓ 8 callers
Method
GetPrimaryReceiverForRed
Get primary receiver if this receiver represents a RED codec; otherwise it will return itself
pkg/sfu/receiver_base.go:132
↓ 8 callers
Method
GetPublishedDataTracks
()
pkg/rtc/types/interfaces.go:325
↓ 8 callers
Method
GetState
()
pkg/sfu/codecmunger/codecmunger.go:30
↓ 8 callers
Method
IsClosed
()
pkg/rtc/participant.go:1531
↓ 8 callers
Method
LoadSIPInboundTrunk
(ctx context.Context, sipTrunkID string)
pkg/service/interfaces.go:94
↓ 8 callers
Method
LoadSIPOutboundTrunk
(ctx context.Context, sipTrunkID string)
pkg/service/interfaces.go:95
↓ 8 callers
Method
Logger
(ctx context.Context)
pkg/service/signal.go:37
↓ 8 callers
Method
MarshalSize
()
pkg/rtc/datatrack/packet.go:172
↓ 8 callers
Method
MaxLayer
()
pkg/sfu/downtrack.go:1534
↓ 8 callers
Function
NewConnectionStats
(params ConnectionStatsParams)
pkg/sfu/connectionquality/connectionstats.go:78
↓ 8 callers
Method
PublisherID
()
pkg/rtc/types/interfaces.go:838
↓ 8 callers
Method
RemoveSubscriber
(participantID livekit.ParticipantID)
pkg/rtc/types/interfaces.go:842
↓ 8 callers
Method
Resolve
(_subscriber types.LocalParticipant, trackID livekit.TrackID)
pkg/rtc/subscriptionmanager_test.go:581
↓ 8 callers
Method
SendMessage
(m *livekit.WorkerMessage)
pkg/agent/testutils/server.go:335
↓ 8 callers
Method
SetLast
(extPkt *buffer.ExtPacket)
pkg/sfu/codecmunger/codecmunger.go:33
↓ 8 callers
Method
SetLogger
(lgr logger.Logger)
pkg/sfu/buffer/buffer_base.go:84
↓ 8 callers
Method
SetRequestSpatial
(layer int32)
pkg/sfu/videolayerselector/videolayerselector.go:50
↓ 8 callers
Method
broadcastParticipantState
broadcast an update about participant p
pkg/rtc/room.go:1525
↓ 8 callers
Function
disable
(f *Forwarder)
pkg/sfu/forwarder_test.go:31
↓ 8 callers
Function
generatePkts
(header rtp.Header, count int, tsStep uint32)
pkg/sfu/redreceiver_test.go:265
↓ 8 callers
Method
getDataDownTrack
()
pkg/rtc/subscriptionmanager.go:1620
↓ 8 callers
Method
loadREDTransformer
()
pkg/sfu/receiver_base.go:1272
↓ 8 callers
Function
newParticipantForTestWithOpts
(identity livekit.ParticipantIdentity, opts *participantOpts)
pkg/rtc/participant_internal_test.go:767
↓ 8 callers
Function
newTestDataBlob
()
pkg/rtc/participant_data_blob_test.go:28
↓ 8 callers
Function
newTestSubscriptionManager
()
pkg/rtc/subscriptionmanager_test.go:531
↓ 8 callers
Function
publishTracksForClients
(t *testing.T, clients ...*testclient.RTCClient)
test/scenarios.go:330
↓ 8 callers
Method
recordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_participant_listener.go:344
↓ 8 callers
Method
recordInvocation
(key string, args []interface{})
pkg/rtc/types/typesfakes/fake_room.go:529
↓ 8 callers
Function
verifyRedEncodings
(t *testing.T, red *rtp.Packet, redPkts []*rtp.Packet)
pkg/sfu/redreceiver_test.go:237
← previous
next →
201–300 of 7,437, ranked by callers