pipeline

Documentation

Index

• type Pipeline
  • func New(conf *config.Config, p *params.Params) (*Pipeline, error)
  • func (p *Pipeline) GetInfo() *livekit.EgressInfo
  • func (p *Pipeline) OnStatusUpdate(f func(info *livekit.EgressInfo))
  • func (p *Pipeline) Run() *livekit.EgressInfo
  • func (p *Pipeline) SendEOS()
  • func (p *Pipeline) UpdateStream(req *livekit.UpdateStreamRequest) error

Types

type Pipeline

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

func New

func New(conf *config.Config, p *params.Params) (*Pipeline, error)

func (*Pipeline) GetInfo

func (p *Pipeline) GetInfo() *livekit.EgressInfo

func (*Pipeline) OnStatusUpdate

func (p *Pipeline) OnStatusUpdate(f func(info *livekit.EgressInfo))

func (*Pipeline) Run

func (p *Pipeline) Run() *livekit.EgressInfo

func (*Pipeline) SendEOS

func (p *Pipeline) SendEOS()

func (*Pipeline) UpdateStream

func (p *Pipeline) UpdateStream(req *livekit.UpdateStreamRequest) error