service

Documentation

Index

• func NewIOClient(bus psrpc.MessageBus) (rpc.IOInfoClient, error)
• type Handler
  • func NewHandler(conf *config.PipelineConfig, bus psrpc.MessageBus, ioClient rpc.IOInfoClient) (*Handler, error)
  • func (h *Handler) GetPProf(ctx context.Context, req *ipc.PProfRequest) (*ipc.PProfResponse, error)
  • func (h *Handler) GetPipelineDot(ctx context.Context, _ *ipc.GstPipelineDebugDotRequest) (*ipc.GstPipelineDebugDotResponse, error)
  • func (h *Handler) Kill()
  • func (h *Handler) Run() error
  • func (h *Handler) StopEgress(ctx context.Context, _ *livekit.StopEgressRequest) (*livekit.EgressInfo, error)
  • func (h *Handler) UpdateStream(ctx context.Context, req *livekit.UpdateStreamRequest) (*livekit.EgressInfo, error)
• type IOClient
  • func (c *IOClient) CreateEgress(ctx context.Context, info *livekit.EgressInfo, opts ...psrpc.RequestOption) (*emptypb.Empty, error)
  • func (c *IOClient) UpdateEgress(ctx context.Context, info *livekit.EgressInfo, opts ...psrpc.RequestOption) (*emptypb.Empty, error)
• type Process
  • func NewProcess(ctx context.Context, handlerID string, req *rpc.StartEgressRequest, ...) (*Process, error)
• type Service
  • func NewService(conf *config.ServiceConfig, ioClient rpc.IOInfoClient) (*Service, error)
  • func (s *Service) AddHandler(egressID string, h *Process)
  • func (s *Service) Close()
  • func (s *Service) GetGstPipelineDotFile(egressID string) (string, error)
  • func (s *Service) IsIdle() bool
  • func (s *Service) KillAll()
  • func (s *Service) ListActiveEgress(ctx context.Context, _ *rpc.ListActiveEgressRequest) (*rpc.ListActiveEgressResponse, error)
  • func (s *Service) Register(psrpcServer rpc.EgressInternalServer)
  • func (s *Service) Reset()
  • func (s *Service) Run() error
  • func (s *Service) StartDebugHandlers()
  • func (s *Service) StartEgress(ctx context.Context, req *rpc.StartEgressRequest) (*livekit.EgressInfo, error)
  • func (s *Service) StartEgressAffinity(ctx context.Context, req *rpc.StartEgressRequest) float32
  • func (s *Service) StartTemplatesServer(fs fs.FS) error
  • func (s *Service) Status() ([]byte, error)
  • func (s *Service) Stop(kill bool)

Functions

func NewIOClient

func NewIOClient(bus psrpc.MessageBus) (rpc.IOInfoClient, error)

Types

type Handler

type Handler struct {
	ipc.UnimplementedEgressHandlerServer
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(conf *config.PipelineConfig, bus psrpc.MessageBus, ioClient rpc.IOInfoClient) (*Handler, error)

func (*Handler) GetPProf

func (h *Handler) GetPProf(ctx context.Context, req *ipc.PProfRequest) (*ipc.PProfResponse, error)

func (*Handler) GetPipelineDot

func (h *Handler) GetPipelineDot(ctx context.Context, _ *ipc.GstPipelineDebugDotRequest) (*ipc.GstPipelineDebugDotResponse, error)

func (*Handler) Kill

func (h *Handler) Kill()

func (*Handler) Run

func (h *Handler) Run() error

func (*Handler) StopEgress

func (h *Handler) StopEgress(ctx context.Context, _ *livekit.StopEgressRequest) (*livekit.EgressInfo, error)

func (*Handler) UpdateStream

func (h *Handler) UpdateStream(ctx context.Context, req *livekit.UpdateStreamRequest) (*livekit.EgressInfo, error)

type IOClient

type IOClient struct {
	rpc.IOInfoClient
}

func (*IOClient) CreateEgress

func (c *IOClient) CreateEgress(ctx context.Context, info *livekit.EgressInfo, opts ...psrpc.RequestOption) (*emptypb.Empty, error)

func (*IOClient) UpdateEgress

func (c *IOClient) UpdateEgress(ctx context.Context, info *livekit.EgressInfo, opts ...psrpc.RequestOption) (*emptypb.Empty, error)

type Process

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

func NewProcess

func NewProcess(
	ctx context.Context,
	handlerID string,
	req *rpc.StartEgressRequest,
	info *livekit.EgressInfo,
	cmd *exec.Cmd,
	tmpDir string,
) (*Process, error)

type Service

type Service struct {
	*stats.Monitor
	// contains filtered or unexported fields
}

func NewService

func NewService(conf *config.ServiceConfig, ioClient rpc.IOInfoClient) (*Service, error)

func (*Service) AddHandler

func (s *Service) AddHandler(egressID string, h *Process)

func (*Service) Close

func (s *Service) Close()

func (*Service) GetGstPipelineDotFile

func (s *Service) GetGstPipelineDotFile(egressID string) (string, error)

func (*Service) IsIdle

func (s *Service) IsIdle() bool

func (*Service) KillAll

func (s *Service) KillAll()

func (*Service) ListActiveEgress

func (s *Service) ListActiveEgress(ctx context.Context, _ *rpc.ListActiveEgressRequest) (*rpc.ListActiveEgressResponse, error)

func (*Service) Register

func (s *Service) Register(psrpcServer rpc.EgressInternalServer)

func (*Service) Reset

func (s *Service) Reset()

func (*Service) Run

func (s *Service) Run() error

func (*Service) StartDebugHandlers

func (s *Service) StartDebugHandlers()

func (*Service) StartEgress

func (s *Service) StartEgress(ctx context.Context, req *rpc.StartEgressRequest) (*livekit.EgressInfo, error)

func (*Service) StartEgressAffinity

func (s *Service) StartEgressAffinity(ctx context.Context, req *rpc.StartEgressRequest) float32

func (*Service) StartTemplatesServer

func (s *Service) StartTemplatesServer(fs fs.FS) error

func (*Service) Status

func (s *Service) Status() ([]byte, error)

func (*Service) Stop

func (s *Service) Stop(kill bool)