media

Documentation

Index

• type AudioOutput
  • func NewAudioOutput(options *livekit.IngressAudioEncodingOptions, ...) (*AudioOutput, error)
• type Input
  • func NewInput(ctx context.Context, p *params.Params, g *stats.LocalMediaStatsGatherer) (*Input, error)
  • func (i *Input) Close() error
  • func (i *Input) OnOutputReady(f OutputReadyFunc)
  • func (i *Input) Start(ctx context.Context) error
• type Output
  • func (e *Output) Bin() *gst.Bin
  • func (e *Output) Close() error
  • func (e *Output) ForceKeyFrame() error
  • func (o *Output) SinkReady(localTrack *lksdk.LocalTrack)
• type OutputReadyFunc
• type Pipeline
  • func New(ctx context.Context, conf *config.Config, params *params.Params, ...) (*Pipeline, error)
  • func (p *Pipeline) GetGstPipelineDebugDot() string
  • func (p *Pipeline) Run(ctx context.Context) error
  • func (p *Pipeline) SendEOS(ctx context.Context)
• type Source
  • func CreateSource(ctx context.Context, p *params.Params) (Source, error)
• type VideoOutput
  • func NewVideoOutput(codec livekit.VideoCodec, layer *livekit.VideoLayer, ...) (*VideoOutput, error)
• type VideoOutputBin
  • func NewVideoOutputBin(options *livekit.IngressVideoEncodingOptions, outputs []*Output) (*VideoOutputBin, error)
  • func (o *VideoOutputBin) GetBin() *gst.Bin
• type WebRTCSink
  • func NewWebRTCSink(ctx context.Context, p *params.Params, onFailure func(), ...) (*WebRTCSink, error)
  • func (s *WebRTCSink) AddTrack(kind types.StreamKind, caps *gst.Caps) (*gst.Bin, error)
  • func (s *WebRTCSink) Close() error

Types

type AudioOutput

type AudioOutput struct {
	*Output
	// contains filtered or unexported fields
}

func NewAudioOutput

func NewAudioOutput(options *livekit.IngressAudioEncodingOptions, outputSync *utils.TrackOutputSynchronizer, statsGatherer *stats.LocalMediaStatsGatherer) (*AudioOutput, error)

type Input

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

func NewInput

func NewInput(ctx context.Context, p *params.Params, g *stats.LocalMediaStatsGatherer) (*Input, error)

func (*Input) Close

func (i *Input) Close() error

func (*Input) OnOutputReady

func (i *Input) OnOutputReady(f OutputReadyFunc)

func (*Input) Start

func (i *Input) Start(ctx context.Context) error

type Output

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

Output manages GStreamer elements that converts & encodes video to the specification that's suitable for WebRTC

func (*Output) Bin

func (e *Output) Bin() *gst.Bin

func (*Output) Close

func (e *Output) Close() error

func (*Output) ForceKeyFrame

func (e *Output) ForceKeyFrame() error

func (*Output) SinkReady

func (o *Output) SinkReady(localTrack *lksdk.LocalTrack)

type OutputReadyFunc

type OutputReadyFunc func(pad *gst.Pad, kind types.StreamKind)

type Pipeline

type Pipeline struct {
	*params.Params
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, conf *config.Config, params *params.Params, g *stats.LocalMediaStatsGatherer) (*Pipeline, error)

func (*Pipeline) GetGstPipelineDebugDot

func (p *Pipeline) GetGstPipelineDebugDot() string

func (*Pipeline) Run

func (p *Pipeline) Run(ctx context.Context) error

func (*Pipeline) SendEOS

func (p *Pipeline) SendEOS(ctx context.Context)

type Source

type Source interface {
	GetSources() []*gst.Element
	ValidateCaps(*gst.Caps) error
	Start(ctx context.Context) error
	Close() error
}

func CreateSource

func CreateSource(ctx context.Context, p *params.Params) (Source, error)

type VideoOutput

type VideoOutput struct {
	*Output
	// contains filtered or unexported fields
}

FIXME Use generics instead?

func NewVideoOutput

func NewVideoOutput(codec livekit.VideoCodec, layer *livekit.VideoLayer, outputSync *utils.TrackOutputSynchronizer, statsGatherer *stats.LocalMediaStatsGatherer) (*VideoOutput, error)

type VideoOutputBin

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

func NewVideoOutputBin

func NewVideoOutputBin(options *livekit.IngressVideoEncodingOptions, outputs []*Output) (*VideoOutputBin, error)

func (*VideoOutputBin) GetBin

func (o *VideoOutputBin) GetBin() *gst.Bin

type WebRTCSink

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

func NewWebRTCSink

func NewWebRTCSink(ctx context.Context, p *params.Params, onFailure func(), statsGatherer *stats.LocalMediaStatsGatherer) (*WebRTCSink, error)

func (*WebRTCSink) AddTrack

func (s *WebRTCSink) AddTrack(kind types.StreamKind, caps *gst.Caps) (*gst.Bin, error)

func (*WebRTCSink) Close

func (s *WebRTCSink) Close() error