pipeline

Documentation

Index

• Variables
• type InputBin
  • func (b *InputBin) Link() error
• type OutputBin
  • func (b *OutputBin) AddRtmpSink(url string) error
  • func (b *OutputBin) Link() error
  • func (b *OutputBin) RemoveRtmpSink(url string) error
  • func (b *OutputBin) RemoveSinkByName(name string) error
• type Pipeline
  • func NewFilePipeline(filename string, options *livekit.RecordingOptions) (*Pipeline, error)
  • func NewRtmpPipeline(urls []string, options *livekit.RecordingOptions) (*Pipeline, error)
  • func (p *Pipeline) Abort()
  • func (p *Pipeline) AddOutput(url string) error
  • func (p *Pipeline) Close()
  • func (p *Pipeline) GetStartTime() time.Time
  • func (p *Pipeline) RemoveOutput(url string) error
  • func (p *Pipeline) Run() error
• type RtmpOut

Variables

var (
	ErrPipelineNotFound     = errors.New("pipeline not initialized")
	ErrCannotAddToFile      = errors.New("cannot add rtmp output to file recording")
	ErrCannotRemoveFromFile = errors.New("cannot remove rtmp output from file recording")
	ErrGhostPadFailed       = errors.New("failed to add ghost pad to bin")
	ErrOutputAlreadyExists  = errors.New("output already exists")
	ErrOutputNotFound       = errors.New("output not found")

	GErrNoURI            = "No URI set before starting"
	GErrFailedToStart    = "Failed to start"
	GErrCouldNotConnect  = "Could not connect to RTMP stream"
	GErrStreamingStopped = "streaming stopped, reason error (-5)"
)

Types

type InputBin

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

func (*InputBin) Link

func (b *InputBin) Link() error

type OutputBin

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

func (*OutputBin) AddRtmpSink

func (b *OutputBin) AddRtmpSink(url string) error

func (*OutputBin) Link

func (b *OutputBin) Link() error

func (*OutputBin) RemoveRtmpSink

func (b *OutputBin) RemoveRtmpSink(url string) error

func (*OutputBin) RemoveSinkByName

func (b *OutputBin) RemoveSinkByName(name string) error

type Pipeline

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

func NewFilePipeline

func NewFilePipeline(filename string, options *livekit.RecordingOptions) (*Pipeline, error)

func NewRtmpPipeline

func NewRtmpPipeline(urls []string, options *livekit.RecordingOptions) (*Pipeline, error)

func (*Pipeline) Abort

func (p *Pipeline) Abort()

Abort can only be called before the pipeline has started

func (*Pipeline) AddOutput

func (p *Pipeline) AddOutput(url string) error

func (*Pipeline) Close

func (p *Pipeline) Close()

Close waits for the pipeline to start before closing

func (*Pipeline) GetStartTime

func (p *Pipeline) GetStartTime() time.Time

func (*Pipeline) RemoveOutput

func (p *Pipeline) RemoveOutput(url string) error

func (*Pipeline) Run

func (p *Pipeline) Run() error

type RtmpOut

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