internal

Documentation

Index

• func EncodingPipelineStr(mimeType string) (string, error)
• func NewTSPacketizer(mtu uint16, payloader rtp.Payloader, sequencer rtp.Sequencer) rtp.Packetizer
• func NewTranscoderPeerConnection(configuration webrtc.Configuration) (*webrtc.PeerConnection, error)
• func PipelineString(trCodec webrtc.RTPCodecParameters, encodingStr string) (string, error)
• func TargetCodec(mimeType string) (*webrtc.RTPCodecCapability, rtp.Payloader, error)
• func ToRTPCaps(codec webrtc.RTPCodecParameters) string
• func TranscodeTrackRemote(parent *gst.Pipeline, tr *webrtc.TrackRemote, pipelineStr, mimeType string) (webrtc.TrackLocal, 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 EncodingPipelineStr

func EncodingPipelineStr(mimeType string) (string, error)

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 NewTranscoderPeerConnection

func NewTranscoderPeerConnection(configuration webrtc.Configuration) (*webrtc.PeerConnection, error)

NewTranscoderPeerConnection creates a new PeerConnection with additional video types supported.

func PipelineString

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

func TargetCodec

func TargetCodec(mimeType string) (*webrtc.RTPCodecCapability, rtp.Payloader, error)

func ToRTPCaps

func ToRTPCaps(codec webrtc.RTPCodecParameters) string

func TranscodeTrackRemote

func TranscodeTrackRemote(parent *gst.Pipeline, tr *webrtc.TrackRemote, pipelineStr, mimeType string) (webrtc.TrackLocal, error)

Types

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)