Functions — github.com/peer-calls/peer-calls

hub / github.com/peer-calls/peer-calls / functions

Functions1,240 in github.com/peer-calls/peer-calls

⨍ Functions 1,240◇ Types & classes 551

↓ 3 callersFunctionNewManager

(params ManagerParams)

server/udptransport2/manager.go:37

↓ 3 callersFunctionNewMock

NewMock returns a mocked instance of a Clock.

server/clock/mock.go:19

↓ 3 callersFunctionNewPinger

NewPinger creates a new instance of Pinger and starts a ticker whose duration is set to dur. The ping callback is called on every interval. The main e

server/pinger.go:19

↓ 3 callersFunctionNewRedisAdapter

( log logger.Logger, pubRedis *redis.Client, subRedis *redis.Client, prefix string, room identifiers.Room

server/redisadapter.go:68

↓ 3 callersFunctionNewSignaller

( log logger.Logger, initiator bool, peerConnection *webrtc.PeerConnection, )

server/wrtcsignaller.go:30

↓ 3 callersFunctionNewTrackWithMID

(track Track, mid string)

server/transport/track_info.go:9

↓ 3 callersFunctionNewWSS

(log logger.Logger, rooms RoomManager)

server/wssub.go:22

↓ 3 callersMethodPushRTP

PushRTP pushes a RTP packet to buffer and returns a Nack RTCP packet if the buffer determines that there is a missing packet.

server/sfu/jitter_buffer.go:24

↓ 3 callersFunctionReadConfig

(filenames []string)

server/configread.go:48

↓ 3 callersFunctionReadConfigFiles

(filenames []string, c *Config)

server/configread.go:26

↓ 3 callersFunctionReadConfigFromEnv

(prefix string, c *Config)

server/configread.go:65

↓ 3 callersMethodRemoteTracksChannel

RemoteTracksChannel might never be closed. Use Done() in select when reading from this channel to prevent deadlocks.

server/transport/transport.go:26

↓ 3 callersMethodRemove

(clientID identifiers.ClientID)

server/wsadapter.go:18

↓ 3 callersMethodRemoveBuffer

(ssrc uint32)

server/sfu/jitter.go:12

↓ 3 callersMethodSetMetadata

(metadata string)

server/wsclient.go:72

↓ 3 callersMethodSignal

(signal message.Signal)

server/wrtcsignaller.go:191

↓ 3 callersMethodSub

(params sfu.SubParams)

server/mux.go:54

↓ 3 callersMethodTrackKind

()

server/transport/codec.go:16

↓ 3 callersMethodTransportsChannel

()

server/udptransport2/factory.go:496

↓ 3 callersMethodUnpub

Unpub unpublishes a track as well as unsubs all subscribers.

server/pubsub/pubsub.go:102

↓ 3 callersMethodUnsubscribe

()

server/pubsub/track_reader.go:176

↓ 3 callersMethodWithWriter

WithWriter returns a new Logger with writer set.

server/logger/logger.go:49

↓ 3 callersMethodWriteRTP

(*rtp.Packet)

server/transport/transport.go:50

↓ 3 callersFunctionaddMessage

(message: MessageType)

src/client/actions/ChatActions.ts:13

↓ 3 callersFunctionaddPeer

(payload: AddPeerParams)

src/client/actions/PeerActions.ts:207

↓ 3 callersFunctionaddTrackToPeer

( peer: PeerState, track: MediaStreamTrack, stream: MediaStream, )

src/client/reducers/peers.ts:50

↓ 3 callersMethodbroadcast

(msg message.Message)

server/memoryadapter.go:120

↓ 3 callersFunctioncanShare

(navigator: Navigator)

src/client/components/Toolbar.tsx:42

↓ 3 callersMethodcloseDescriptionSent

closeDescriptionSent closes the descriptionSent channel which allows the ICE candidates to be processed.

server/wrtcsignaller.go:331

↓ 3 callersMethodconnect

()

src/client/ws/index.ts:27

↓ 3 callersFunctioncreateAddStreamAction

(stream: MediaStream)

src/client/reducers/streams.test.ts:37

↓ 3 callersFunctioncreateMessagingMiddleware

( createEncoder = () => new Encoder(), )

src/client/messaging.ts:15

↓ 3 callersFunctioncreateReceiverStatsKey

( params: ReceiverStatsParams, )

src/client/reducers/receivers.ts:18

↓ 3 callersFunctiondecodeHeader

(data: Uint8Array)

src/client/codec/header.ts:59

↓ 3 callersFunctionencode

(encoder: Encoder, d: DataContainer)

src/client/codec/index.test.ts:14

↓ 3 callersFunctionerrIs

(err error, target error)

server/errors.go:12

↓ 3 callersMethodfocus

()

src/client/components/Chat.tsx:69

↓ 3 callersFunctiongetCases

(start, end int)

server/basen/basen_test.go:11

↓ 3 callersFunctiongetLocalNickname

()

src/client/reducers/nicknames.ts:16

↓ 3 callersFunctiongetTemplates

()

server/render_test.go:15

↓ 3 callersFunctiongetTracksByKind

(stream: MediaStream, kind: MediaKind)

src/client/actions/MediaActions.ts:341

↓ 3 callersFunctiongetValueFromBool

(b bool)

server/atomic/bool.go:16

↓ 3 callersMethodlocalBroadcast

(clients map[identifiers.ClientID]ClientWriter, msg message.Message)

server/redisadapter.go:471

↓ 3 callersMethodlocalClients

()

server/redisadapter.go:437

↓ 3 callersMethodmaybeRecalculateMinMax

()

server/pubsub/remb.go:53

↓ 3 callersFunctionmustSub

(dir fs.FS, path string)

main.go:34

↓ 3 callersFunctionnewControlTransport

( log logger.Logger, stream io.ReadWriteCloser, )

server/udptransport2/control_transport.go:24

↓ 3 callersFunctionnewPubTrack

newPubTrack creates a new instance of PubTrack.

server/pubsub/pub_track.go:28

↓ 3 callersFunctionnewStreamKey

(params: StreamProps)

src/client/insertable-streams/index.ts:102

↓ 3 callersFunctionnewTransportMock

(clientID identifiers.ClientID)

server/pubsub/pubsub_test.go:459

↓ 3 callersFunctionnotify

(type: NotifyType, args: string[])

src/client/actions/NotifyActions.ts:12

↓ 3 callersFunctionpubTrack

( state: StreamsState, payload: PubTrackEvent, )

src/client/reducers/streams.ts:382

↓ 3 callersFunctionreduce

( state: State, action: AsyncAction<T, P>, handlePending: (state: State, action: PendingAction<T, P>) =>

src/client/async/reducer.ts:3

↓ 3 callersFunctionremoveNickname

( payload: NicknameRemovePayload, )

src/client/actions/NicknameActions.ts:28

↓ 3 callersFunctionremovePeer

(peerId: string)

src/client/actions/PeerActions.ts:237

↓ 3 callersFunctionrender

(args?: Partial<Flags>)

src/client/components/Video.test.tsx:65

↓ 3 callersFunctionrender

()

src/client/containers/App.test.tsx:44

↓ 3 callersMethodreplaceTrack

(streamId: string, track: MediaStreamTrack)

src/client/audio/AudioProcessor.ts:100

↓ 3 callersFunctionsave

(state: SettingsState)

src/client/reducers/settings.ts:57

↓ 3 callersFunctionsaveConstraints

(state: PersistedState)

src/client/reducers/media.ts:61

↓ 3 callersFunctionsetEnvInt

(dest *int, name string)

server/configread.go:131

↓ 3 callersFunctionsetEnvStringArray

(interfaces *[]string, name string)

server/configread.go:189

↓ 3 callersFunctionsetNicknames

(payload: NicknamesSetPayload)

src/client/actions/NicknameActions.ts:12

↓ 3 callersFunctionsetupMeshServer

(rooms server.RoomManager)

server/mesh_test.go:139

↓ 3 callersFunctiontr

(mid: string)

src/client/actions/SocketActions.test.ts:148

↓ 3 callersMethodunsub

unsub caller must hold the lock.

server/pubsub/pubsub.go:213

↓ 3 callersMethodunsubscribe

()

server/servertransport/track_local.go:142

↓ 3 callersFunctionupdateDecryptContext

( streamProps: StreamProps, peerId: string, )

src/client/insertable-streams/index.ts:149

↓ 3 callersFunctionvalueOf

(id: string)

src/client/window.ts:5

↓ 3 callersFunctionwaitForMock

(fn: (...args: any[]) => void)

src/client/messaging.test.ts:59

↓ 3 callersFunctionwithGauge

(counter prometheus.Counter, h http.HandlerFunc)

server/mux.go:58

↓ 2 callersMethodAcceptConn

AcceptConn reads from Conns channel. It returns io.ErrClosedPipe when the channel is closed. Users should use either AcceptConn or Conns, but never bo

server/udpmux/udpmux.go:72

↓ 2 callersMethodAdapter

Adapter returns the websocket adapter.

server/wssub.go:51

↓ 2 callersMethodAdd

(client ClientWriter)

server/redisadapter.go:104

↓ 2 callersMethodBitrateEstimator

BitrateEstimator returns the instance of BitrateEstimatro for a track.

server/pubsub/pubsub.go:241

↓ 2 callersMethodBroadcast

(msg message.Message)

server/redisadapter.go:458

↓ 2 callersMethodClientID

ClientID return sthe client identifier.

server/wssub.go:61

↓ 2 callersMethodClients

()

server/wsadapter.go:23

↓ 2 callersMethodClients

Returns clients with metadata

server/memoryadapter.go:92

↓ 2 callersMethodClose

Close invokes the Close method on the underlying connection. It also invokes the onClose handler.

server/wssub.go:72

↓ 2 callersMethodClose

Close exists for tests. This channel should always stay open IRL.

server/room.go:87

↓ 2 callersMethodClose

()

server/servertransport/transport.go:138

↓ 2 callersMethodClose

()

server/udptransport2/manager.go:343

↓ 2 callersFunctionCreateNackPair

(sequenceNumbers []uint16)

server/sfu/buffer.go:218

↓ 2 callersMethodCreateTransport

(streamID identifiers.RoomID)

server/udptransport2/factory.go:500

↓ 2 callersMethodCtx

Ctx returns the current logger's context.

server/logger/logger.go:40

↓ 2 callersMethodEmit

Sends a message to specific socket.

server/memoryadapter.go:133

↓ 2 callersMethodEmpty

Empty returns true when there are no estimations, false otherwise.

server/pubsub/remb.go:83

↓ 2 callersMethodEnter

(room identifiers.RoomID)

server/mux.go:66

↓ 2 callersMethodErr

Err returns all errors that have occurred or nil when no errors had occurred. When only one error had occurred, that error is returned. When multiple

server/multierr/multierr.go:38

↓ 2 callersMethodEvents

()

server/udptransport2/control_transport.go:113

↓ 2 callersMethodFactories

()

server/udptransport2/manager.go:328

↓ 2 callersMethodFactoriesChannel

FactoriesChannel contains factories created from incoming connections. Users must read from this channel to prevent deadlocks.

server/udptransport2/manager.go:64

↓ 2 callersMethodFeed

Feed records the estimated bitrate for client.

server/pubsub/remb.go:25

↓ 2 callersMethodGetFactory

(raddr net.Addr)

server/udptransport2/manager.go:306

↓ 2 callersFunctionInitConfig

(c *Config)

server/configread.go:37

↓ 2 callersMethodInitSeq

InitSeq is implemented according to the RFC 3550 Appendix A.1.

server/sfu/stats/source.go:51

↓ 2 callersMethodInitiator

()

server/wrtcsignaller.go:103

↓ 2 callersFunctionLevelFromString

(str string)

server/logger/level.go:64

↓ 2 callersMethodLocalAddr

()

server/udpmux/udpmux.go:59

← previous next →201–300 of 1,240, ranked by callers