pipeline

Documentation

Index

• type Controller
  • func New(ctx context.Context, conf *config.PipelineConfig, ...) (*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) *info.EgressInfo
  • func (c *Controller) SendEOS(ctx context.Context, reason string)
  • 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, ipcServiceClient ipc.EgressServiceClient) (*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) *info.EgressInfo

func (*Controller) SendEOS

func (c *Controller) SendEOS(ctx context.Context, reason string)

func (*Controller) UpdateStream

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