Documentation
¶
Index ¶
- type Controller
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶ added in v1.7.8
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 ¶ added in v1.7.8
func (c *Controller) BuildPipeline() error
func (*Controller) Close ¶ added in v1.7.9
func (c *Controller) Close()
func (*Controller) GetGstPipelineDebugDot ¶ added in v1.7.8
func (c *Controller) GetGstPipelineDebugDot() string
func (*Controller) OnError ¶ added in v1.7.8
func (c *Controller) OnError(err error)
func (*Controller) Run ¶ added in v1.7.8
func (c *Controller) Run(ctx context.Context) *livekit.EgressInfo
func (*Controller) SendEOS ¶ added in v1.7.8
func (c *Controller) SendEOS(ctx context.Context)
func (*Controller) UpdateStream ¶ added in v1.7.8
func (c *Controller) UpdateStream(ctx context.Context, req *livekit.UpdateStreamRequest) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.