Handle incoming RPC call events like join, answer, offer and trickle

Close disconnects the websocket

Endpoint public endpoint to hit

Join a session

NewClient returns a new jsonrpc2 client that manages a pub and sub peerConnection

NewGSTProducer will create a new producer for a given client and a videoFile

NewJSONRPCSignalClient constructor

Open connects to the given url

Ping sends a ping message

Play sets the pipeline to PLAYING

CreatePlayerPipeline creates a GStreamer Pipeline

CreateTestSrcPipeline creates a GStreamer Pipeline with test sources

Execute executes the root command.

NewCompositorPipeline will create a pipeline controller for AV compositing. It will include tee's (vtee,atee) for linking extra elements to the compo

Publish takes a producer and publishes its data to the peer connection

SeekToTime seeks on the pipeline

ServeWebsocket listens for incoming websocket signaling requests

export goHandleAppsrcForceKeyUnit

export goHandlePipelineBuffer

Pub PC re-negotiation

Push pushes a buffer on the appsrc of the GStreamer Pipeline

Answer an sdp offer that originated from the server

AudioTrack returns the audio track for the pipeline

CreateClientPipeline creates a GStreamer Pipeline that decodes and shows video

CreateDatachannel to publish

Handle handles incoming jsonrpc2 messages

Join a session id with an sdp offer (returns an sdp answer or error)

MetricsGetActiveClientsCount returns number of active clients connected to this node

NewCoordinator configures coordinator for this node

NewSignal creates a signaling server

Offer a new sdp to the server (returns an sdp answer)

OnNegotiate hook a negotiation handler

OnTrickle hook a trickle handler

Pause the pipeline

Pause sets the pipeline to PAUSED

Push pushes a buffer on the appsrc of the GStreamer Pipeline

SeekP to a timestamp

Start the pipeline

Start starts the GStreamer Pipeline

Stop the pipeline

Trickle send ice candiates to the server

VideoTrack returns the video track for the pipeline

This pad probe will get triggered when UPSTREAM events get fired on the appsrc. We use this to listen for GstEventForceKeyUnit, and forward that to th