Functions — github.com/livekit/livekit

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

⨍ Functions 7,437◇ Types & classes 718

MethodWriteMessageArgsForCall

(i int)

pkg/routing/routingfakes/fake_message_sink.go:213

MethodWriteMessageCallCount

()

pkg/routing/routingfakes/fake_message_sink.go:201

MethodWriteMessageCalls

(stub func(int, []byte) error)

pkg/rtc/types/typesfakes/fake_websocket_client.go:348

MethodWriteMessageReturns

(result1 error)

pkg/rtc/types/typesfakes/fake_websocket_client.go:361

MethodWriteMessageReturns

(result1 error)

pkg/routing/routingfakes/fake_message_sink.go:220

MethodWriteMessageReturnsOnCall

(i int, result1 error)

pkg/rtc/types/typesfakes/fake_websocket_client.go:370

MethodWriteMessageReturnsOnCall

(i int, result1 error)

pkg/routing/routingfakes/fake_message_sink.go:229

MethodWritePacket

(data []byte, packet *datatrack.Packet, _arrivalTime int64)

pkg/rtc/datadowntrack.go:118

MethodWritePacket

(arg1 []byte, arg2 *datatrack.Packet, arg3 int64)

pkg/rtc/types/typesfakes/fake_data_track_sender.go:87

MethodWritePacketArgsForCall

(i int)

pkg/rtc/types/typesfakes/fake_data_track_sender.go:119

MethodWritePacketCallCount

()

pkg/rtc/types/typesfakes/fake_data_track_sender.go:107

MethodWritePacketCalls

(stub func([]byte, *datatrack.Packet, int64))

pkg/rtc/types/typesfakes/fake_data_track_sender.go:113

MethodWritePaddingRTP

(bytesToSend int)

pkg/sfu/streamallocator/track.go:133

MethodWriteProbePackets

(bytesToSend int, usePadding bool)

pkg/sfu/downtrack.go:2349

MethodWriteRTP

WriteRTP writes an RTP Packet to the DownTrack

pkg/sfu/downtrack.go:1081

MethodWriteRTP

(p *buffer.ExtPacket, _ int32)

pkg/sfu/redreceiver_test.go:38

MethodWriteServerMessage

(msg *livekit.ServerMessage)

pkg/service/wsprotocol.go:156

MethodWriteServerMessage

(m *livekit.ServerMessage)

pkg/agent/testutils/server.go:258

MethodWriteSubscriberRTCP

(pkts []rtcp.Packet)

pkg/rtc/transportmanager.go:316

MethodWriteSubscriberRTCP

(arg1 []rtcp.Packet)

pkg/rtc/types/typesfakes/fake_local_participant.go:9926

MethodWriteSubscriberRTCPArgsForCall

(i int)

pkg/rtc/types/typesfakes/fake_local_participant.go:9962

MethodWriteSubscriberRTCPCallCount

()

pkg/rtc/types/typesfakes/fake_local_participant.go:9950

MethodWriteSubscriberRTCPCalls

(stub func([]rtcp.Packet) error)

pkg/rtc/types/typesfakes/fake_local_participant.go:9956

MethodWriteSubscriberRTCPReturns

(result1 error)

pkg/rtc/types/typesfakes/fake_local_participant.go:9969

MethodWriteSubscriberRTCPReturnsOnCall

(i int, result1 error)

pkg/rtc/types/typesfakes/fake_local_participant.go:9978

Methodadd

(size int, isRTX bool, isProbe bool)

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

FunctioncreateForwardStats

(conf *config.Config)

pkg/service/wire.go:284

FunctioncreateKeyProvider

(conf *config.Config)

pkg/service/wire.go:134

FunctioncreateRedisClient

(conf *config.Config)

pkg/service/wire.go:182

FunctioncreateStore

(rc redis.UniversalClient)

pkg/service/wire.go:189

FunctioncreateTelemetryService

(notifier webhook.QueuedNotifier, analytics telemetry.AnalyticsService)

pkg/service/wire.go:174

FunctioncreateToken

(_ context.Context, c *cli.Command)

cmd/server/commands.go:104

FunctioncreateWebhookNotifier

(conf *config.Config, provider auth.KeyProvider)

pkg/service/wire.go:163

MethoddebugGoroutines

(w http.ResponseWriter, _ *http.Request)

pkg/service/server.go:379

MethoddebugInfo

(w http.ResponseWriter, _ *http.Request)

pkg/service/server.go:383

MethoddefaultHandler

(w http.ResponseWriter, r *http.Request)

pkg/service/server.go:400

FunctiongenerateKeys

(_ context.Context, _ *cli.Command)

cmd/server/commands.go:41

FunctiongenerateWire

code generation for wiring

magefile.go:204

FunctiongetAPIConf

(config *config.Config)

pkg/service/wire.go:303

FunctiongetAgentConfig

(config *config.Config)

pkg/service/wire.go:299

FunctiongetAgentStore

(s ObjectStore)

pkg/service/wire.go:221

MethodgetBase

()

pkg/sfu/videolayerselector/base.go:57

FunctiongetCPUStats

()

pkg/telemetry/prometheus/node_nonwindows.go:38

FunctiongetCPUStats

()

pkg/telemetry/prometheus/node_windows.go:27

FunctiongetEgressStore

(s ObjectStore)

pkg/service/wire.go:203

MethodgetH264BlankFrame

(_frameEndNeeded bool)

pkg/sfu/downtrack.go:1963

FunctiongetIngressConfig

(conf *config.Config)

pkg/service/wire.go:232

FunctiongetIngressStore

(s ObjectStore)

pkg/service/wire.go:212

FunctiongetLimitConf

(config *config.Config)

pkg/service/wire.go:262

FunctiongetLoadAvg

()

pkg/telemetry/prometheus/node_nonwindows.go:34

MethodgetLogger

()

pkg/sfu/videolayerselector/base.go:61

FunctiongetMessageBus

(rc redis.UniversalClient)

pkg/service/wire.go:196

FunctiongetNodeID

(currentNode routing.LocalNode)

pkg/service/wire.go:130

FunctiongetNodeStatsConfig

(config *config.Config)

pkg/service/wire.go:295

FunctiongetPSRPCClientParams

(config rpc.PSRPCConfig, bus psrpc.MessageBus)

pkg/service/wire.go:278

FunctiongetPSRPCConfig

(config *config.Config)

pkg/service/wire.go:274

FunctiongetRoomConfig

(config *config.Config)

pkg/service/wire.go:266

FunctiongetSIPConfig

(conf *config.Config)

pkg/service/wire.go:258

FunctiongetSIPStore

(s ObjectStore)

pkg/service/wire.go:249

FunctiongetSignalRelayConfig

(config *config.Config)

pkg/service/wire.go:270

FunctiongetTCStats

()

pkg/telemetry/prometheus/node_nonlinux.go:19

MethodgetVP8BlankFrame

(frameEndNeeded bool)

pkg/sfu/downtrack.go:1946

MethodhandleCodecChange

(newCodec webrtc.RTPCodecParameters)

pkg/sfu/receiver_base.go:1157

MethodhandleCreate

(w http.ResponseWriter, r *http.Request)

pkg/service/whipservice.go:211

MethodhandleDataMessage

(kind livekit.DataPacket_Kind, data []byte)

test/client/client.go:1138

MethodhandleDataMessageUnlabeled

(data []byte)

test/client/client.go:1152

MethodhandleDataTrackMessage

(data []byte, _arrivalTime int64)

test/client/client.go:1158

MethodhandleGet

(w http.ResponseWriter, r *http.Request)

pkg/service/whipservice.go:89

MethodhandleOptions

(w http.ResponseWriter, r *http.Request)

pkg/service/whipservice.go:94

MethodhandleParticipantDelete

(w http.ResponseWriter, r *http.Request)

pkg/service/whipservice.go:488

MethodhandleParticipantGet

(w http.ResponseWriter, r *http.Request)

pkg/service/whipservice.go:313

MethodhandleParticipantPatch

(w http.ResponseWriter, r *http.Request)

pkg/service/whipservice.go:429

MethodhandleReceiverReady

()

pkg/sfu/downtrack.go:696

FunctionhelpVerbose

(_ context.Context, c *cli.Command)

cmd/server/commands.go:90

pkg/telemetry/stats_test.go:31

Functioninit

()

pkg/service/signal_test.go:37

Functioninit

()

pkg/rtc/room_test.go:43

Functioninit

()

pkg/rtc/subscriptionmanager_test.go:34

Functioninit

()

test/integration_helpers.go:59

Functioninit

()

cmd/server/main.go:119

FunctioninstallDeps

implicitly install deps

magefile.go:227

FunctionlistNodes

(_ context.Context, c *cli.Command)

cmd/server/commands.go:170

FunctionloggerErrorReceived

(ctx context.Context, e twirp.Error)

pkg/service/twirp.go:155

FunctionloggerRequestRouted

(ctx context.Context)

pkg/service/twirp.go:110

Functionmain

()

cmd/server/main.go:123

MethodmarshalLogObject

(e zapcore.ObjectEncoder, packetsExpected, packetsSeenMinusPadding uint64)

pkg/sfu/rtpstats/rtpstats_base_lite.go:382

MethodmaybeReinit

(oldESN uint64, newESN uint64)

pkg/sfu/rtpstats/rtpstats_sender.go:177

MethodmaybeReinit

(oldESN uint64, newESN uint64)

pkg/sfu/rtpstats/rtpstats_sender.go:225

MethodmaybeUpdateMaxJitter

(jitter float64)

pkg/sfu/rtpstats/rtpstats_sender.go:240

MethodmaybeUpdateMaxJitterFeed

(jitter float64)

pkg/sfu/rtpstats/rtpstats_sender.go:183

MethodmaybeUpdateMaxRTT

(rtt uint32)

pkg/sfu/rtpstats/rtpstats_sender.go:234

MethodmaybeUpdateMaxRTT

(rtt uint32)

pkg/sfu/rtpstats/rtpstats_base.go:136

MethodneedsCleanup

()

pkg/rtc/subscriptionmanager.go:1557

FunctionnewInProcessTurnServer

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

pkg/service/wire.go:291

FunctionnewOpsQueueBase

(params OpsQueueParams)

pkg/utils/opsqueue.go:82

FunctionnewSIPClient

(p rpc.ClientParams)

pkg/service/wire.go:236

MethodonClosed

()

pkg/sfu/receiver.go:341

MethodonDownTrackCreated

(downTrack *sfu.DownTrack)

pkg/rtc/mediatrackreceiver.go:1139

MethodonICECandidateTrickle

(c *webrtc.ICECandidate)

pkg/rtc/transport.go:824

← previous next →7,301–7,400 of 7,437, ranked by callers