gst

Documentation

Overview

Package gst provides an easy API to create a GStreamer pipeline

Package gst provides an easy API to create a GStreamer pipeline

Index

• Constants
• func StartMainLoop()
• type Pipeline
  • func NewPipeline(jp types.JoinPayload, plir types.PLIRequester, dataFolder, iRandomId string, ...) *Pipeline
  • func (p *Pipeline) BindTrackAutoStart(kind string, t types.TrackWriter)
  • func (p *Pipeline) GetCurrentLevelTime(name string) uint64
  • func (p *Pipeline) GetFxPropFloat(name string, prop string) float32
  • func (p *Pipeline) PushRTCP(kind string, buffer []byte)
  • func (p *Pipeline) PushRTP(kind string, buffer []byte)
  • func (p *Pipeline) SendPLI()
  • func (p *Pipeline) SetEncodingBitrate(kind string, value int)
  • func (p *Pipeline) SetFxPolyProp(name string, prop string, kind string, value string)
  • func (p *Pipeline) SetFxPropFloat(name string, prop string, value float32)
  • func (p *Pipeline) Started() chan struct{}
  • func (p *Pipeline) Stop()

Constants

const GstLevelError = 1

const GstLevelWarning = 2

Functions

func StartMainLoop

func StartMainLoop()

Types

type Pipeline

type Pipeline struct {

	// API
	RecordingFiles []string
	// contains filtered or unexported fields
}

Pipeline is a wrapper for a GStreamer pipeline and output track

func NewPipeline

func NewPipeline(jp types.JoinPayload, plir types.PLIRequester, dataFolder, iRandomId string, connectionCount int, logger zerolog.Logger) *Pipeline

create a GStreamer pipeline

func (*Pipeline) BindTrackAutoStart

func (p *Pipeline) BindTrackAutoStart(kind string, t types.TrackWriter)

func (*Pipeline) GetCurrentLevelTime

func (p *Pipeline) GetCurrentLevelTime(name string) uint64

func (*Pipeline) GetFxPropFloat

func (p *Pipeline) GetFxPropFloat(name string, prop string) float32

func (*Pipeline) PushRTCP

func (p *Pipeline) PushRTCP(kind string, buffer []byte)

func (*Pipeline) PushRTP

func (p *Pipeline) PushRTP(kind string, buffer []byte)

func (*Pipeline) SendPLI

func (p *Pipeline) SendPLI()

func (*Pipeline) SetEncodingBitrate

func (p *Pipeline) SetEncodingBitrate(kind string, value int)

func (*Pipeline) SetFxPolyProp

func (p *Pipeline) SetFxPolyProp(name string, prop string, kind string, value string)

func (*Pipeline) SetFxPropFloat

func (p *Pipeline) SetFxPropFloat(name string, prop string, value float32)

func (*Pipeline) Started

func (p *Pipeline) Started() chan struct{}

func (*Pipeline) Stop

func (p *Pipeline) Stop()

stop the GStreamer pipeline