server

Documentation

Index

• func NewTSPacketizer(mtu uint16, payloader rtp.Payloader, sequencer rtp.Sequencer) rtp.Packetizer
• func PipelineString(trCodec webrtc.RTPCodecParameters, encodingStr string) (string, error)
• func ToRTPCaps(codec webrtc.RTPCodecParameters) string
• func TranscodeTrackRemote(parent *gst.Pipeline, tr *webrtc.TrackRemote, outputCodec *OutputCodec) (webrtc.TrackLocal, error)
• type OutputCodec
  • func ResolveOutputCodec(tr *webrtc.TrackRemote, mimeType, pipelineStr string) (*OutputCodec, error)
• type Source
• type TranscoderServer
  • func NewTranscoderServer(config webrtc.Configuration) *TranscoderServer
  • func (s *TranscoderServer) Signal(conn api.Transcoder_SignalServer) error
  • func (s *TranscoderServer) Transcode(ctx context.Context, request *api.TranscodeRequest) (*api.TranscodeResponse, error)

Functions

func NewTSPacketizer

func NewTSPacketizer(mtu uint16, payloader rtp.Payloader, sequencer rtp.Sequencer) rtp.Packetizer

NewTSPacketizer returns a new instance of a Packetizer for a specific payloader

func PipelineString

func PipelineString(trCodec webrtc.RTPCodecParameters, encodingStr string) (string, error)

func ToRTPCaps

func ToRTPCaps(codec webrtc.RTPCodecParameters) string

func TranscodeTrackRemote

func TranscodeTrackRemote(parent *gst.Pipeline, tr *webrtc.TrackRemote, outputCodec *OutputCodec) (webrtc.TrackLocal, error)

Types

type OutputCodec

type OutputCodec struct {
	webrtc.RTPCodecCapability
	rtp.Payloader
	GStreamerEncoder string
}

func ResolveOutputCodec

func ResolveOutputCodec(tr *webrtc.TrackRemote, mimeType, pipelineStr string) (*OutputCodec, error)

type Source

type Source struct {
	*webrtc.PeerConnection
	*webrtc.TrackRemote

	Parent *gst.Pipeline
}

type TranscoderServer

type TranscoderServer struct {
	api.UnimplementedTranscoderServer
	// contains filtered or unexported fields
}

func NewTranscoderServer

func NewTranscoderServer(config webrtc.Configuration) *TranscoderServer

func (*TranscoderServer) Signal

func (s *TranscoderServer) Signal(conn api.Transcoder_SignalServer) error

func (*TranscoderServer) Transcode

func (s *TranscoderServer) Transcode(ctx context.Context, request *api.TranscodeRequest) (*api.TranscodeResponse, error)