transcoder

Documentation

Index

• Variables
• func NewPipelineBuilder(kind webrtc.RTPCodecType, to string, via string) (string, error)
• type Caps
  • func CapsFromRTPCodecParameters(codec *webrtc.RTPCodecParameters) (*Caps, error)
  • func CapsFromString(str string) *Caps
  • func (c *Caps) RTPCodecParameters() (*webrtc.RTPCodecParameters, error)
  • func (c *Caps) SSRC() (webrtc.SSRC, error)
  • func (c *Caps) String() string
• type Client
  • func NewClient(ctx context.Context, conn *grpc.ClientConn) (*Client, error)
  • func (c *Client) Transcode(tl *webrtc.TrackLocalStaticRTP, options ...TranscodeOption) (*webrtc.TrackRemote, error)
• type Element
  • func (e *Element) GetInt(name string) int
  • func (e *Element) GetString(name string) string
  • func (e *Element) Set(name string, value interface{})
• type ReadOnlyPipeline
• type ReadWritePipeline
• type Source
• type TranscodeOption
  • func ToMimeType(mimeType string) TranscodeOption
• type Transcoder
  • func NewTranscoder() (*Transcoder, error)
  • func (s *Transcoder) Close() error
  • func (s *Transcoder) NewReadOnlyPipeline(str string) (ReadOnlyPipeline, error)
  • func (s *Transcoder) NewReadWritePipeline(in *webrtc.RTPCodecParameters, str string) (ReadWritePipeline, error)
  • func (s *Transcoder) NewWriteOnlyPipeline(in *webrtc.RTPCodecParameters, str string) (WriteOnlyPipeline, error)
• type TranscoderServer
  • func NewTranscoderServer(config webrtc.Configuration) *TranscoderServer
  • func (s *TranscoderServer) Publish(conn api.Transcoder_PublishServer) error
  • func (s *TranscoderServer) Subscribe(conn api.Transcoder_SubscribeServer) error
• type WriteOnlyPipeline

Variables

var ErrPropertyNotFound = errors.New("property not found")

Functions

func NewPipelineBuilder

func NewPipelineBuilder(kind webrtc.RTPCodecType, to string, via string) (string, error)

Types

type Caps

type Caps struct {
	// contains filtered or unexported fields
}

func CapsFromRTPCodecParameters

func CapsFromRTPCodecParameters(codec *webrtc.RTPCodecParameters) (*Caps, error)

func CapsFromString

func CapsFromString(str string) *Caps

func (*Caps) RTPCodecParameters

func (c *Caps) RTPCodecParameters() (*webrtc.RTPCodecParameters, error)

func (*Caps) SSRC

func (c *Caps) SSRC() (webrtc.SSRC, error)

func (*Caps) String

func (c *Caps) String() string

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, conn *grpc.ClientConn) (*Client, error)

func (*Client) Transcode

func (c *Client) Transcode(tl *webrtc.TrackLocalStaticRTP, options ...TranscodeOption) (*webrtc.TrackRemote, error)

type Element

type Element struct {
	// contains filtered or unexported fields
}

func (*Element) GetInt

func (e *Element) GetInt(name string) int

func (*Element) GetString

func (e *Element) GetString(name string) string

func (*Element) Set

func (e *Element) Set(name string, value interface{})

type ReadOnlyPipeline

type ReadOnlyPipeline interface {
	rtpio.RTPReader
	Codec() (*webrtc.RTPCodecParameters, error)
	SSRC() (webrtc.SSRC, error)
}

type ReadWritePipeline

type ReadWritePipeline interface {
	ReadOnlyPipeline
	WriteOnlyPipeline
}

type Source

type Source struct {
	*webrtc.PeerConnection
	*webrtc.TrackRemote
	// contains filtered or unexported fields
}

type TranscodeOption

type TranscodeOption func(*api.TranscodeRequest)

func ToMimeType

func ToMimeType(mimeType string) TranscodeOption

type Transcoder

type Transcoder struct {
	// contains filtered or unexported fields
}

func NewTranscoder

func NewTranscoder() (*Transcoder, error)

func (*Transcoder) Close

func (s *Transcoder) Close() error

func (*Transcoder) NewReadOnlyPipeline

func (s *Transcoder) NewReadOnlyPipeline(str string) (ReadOnlyPipeline, error)

func (*Transcoder) NewReadWritePipeline

func (s *Transcoder) NewReadWritePipeline(in *webrtc.RTPCodecParameters, str string) (ReadWritePipeline, error)

func (*Transcoder) NewWriteOnlyPipeline

func (s *Transcoder) NewWriteOnlyPipeline(in *webrtc.RTPCodecParameters, str string) (WriteOnlyPipeline, error)

type TranscoderServer

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

func NewTranscoderServer

func NewTranscoderServer(config webrtc.Configuration) *TranscoderServer

func (*TranscoderServer) Publish

func (s *TranscoderServer) Publish(conn api.Transcoder_PublishServer) error

func (*TranscoderServer) Subscribe

func (s *TranscoderServer) Subscribe(conn api.Transcoder_SubscribeServer) error

type WriteOnlyPipeline

type WriteOnlyPipeline interface {
	rtpio.RTPWriteCloser
	OnUpstreamForceKeyUnit(func())
}