pipeline

Documentation

Index

• type Controller
  • func New(ctx context.Context, conf *config.PipelineConfig, ioClient rpc.IOInfoClient) (*Controller, error)
  • func (c *Controller) BuildPipeline() error
  • func (c *Controller) Close()
  • func (c *Controller) GetGstPipelineDebugDot() string
  • func (c *Controller) OnError(err error)
  • func (c *Controller) Run(ctx context.Context) *livekit.EgressInfo
  • func (c *Controller) SendEOS(ctx context.Context)
  • func (c *Controller) UpdateStream(ctx context.Context, req *livekit.UpdateStreamRequest) error

Types

type Controller

type Controller struct {
	*config.PipelineConfig
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, conf *config.PipelineConfig, ioClient rpc.IOInfoClient) (*Controller, error)

func (*Controller) BuildPipeline

func (c *Controller) BuildPipeline() error

func (*Controller) Close

func (c *Controller) Close()

func (*Controller) GetGstPipelineDebugDot

func (c *Controller) GetGstPipelineDebugDot() string

func (*Controller) OnError

func (c *Controller) OnError(err error)

func (*Controller) Run

func (c *Controller) Run(ctx context.Context) *livekit.EgressInfo

func (*Controller) SendEOS

func (c *Controller) SendEOS(ctx context.Context)

func (*Controller) UpdateStream

func (c *Controller) UpdateStream(ctx context.Context, req *livekit.UpdateStreamRequest) error