service

Documentation

Index

• 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 HandlerV0
  • func NewHandlerV0(conf *config.PipelineConfig, rpcServer egress.RPCServer) (*HandlerV0, error)
  • func (h *HandlerV0) Kill()
  • func (h *HandlerV0) Run() error
• type ProcessManager
  • func NewProcessManager(conf *config.ServiceConfig, monitor *stats.Monitor, ...) *ProcessManager
• type Service
  • func NewService(conf *config.ServiceConfig, bus psrpc.MessageBus, rpcServerV0 egress.RPCServer, ...) (*Service, error)
  • func (s *Service) GetGstPipelineDotFile(egressID string) (string, error)
  • func (s *Service) KillAll()
  • func (s *Service) ListActiveEgress(ctx context.Context, _ *rpc.ListActiveEgressRequest) (*rpc.ListActiveEgressResponse, error)
  • func (s *Service) ListEgress() []string
  • 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(req *rpc.StartEgressRequest) float32
  • func (s *Service) StartTemplatesServer(fs fs.FS) error
  • func (s *Service) Status() ([]byte, error)
  • func (s *Service) Stop(kill bool)

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 HandlerV0

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

func NewHandlerV0

func NewHandlerV0(conf *config.PipelineConfig, rpcServer egress.RPCServer) (*HandlerV0, error)

func (*HandlerV0) Kill

func (h *HandlerV0) Kill()

func (*HandlerV0) Run

func (h *HandlerV0) Run() error

type ProcessManager

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

func NewProcessManager

func NewProcessManager(conf *config.ServiceConfig, monitor *stats.Monitor, onFatalError func(*livekit.EgressInfo)) *ProcessManager

type Service

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

func NewService

func NewService(conf *config.ServiceConfig, bus psrpc.MessageBus, rpcServerV0 egress.RPCServer, ioClient rpc.IOInfoClient) (*Service, error)

func (*Service) GetGstPipelineDotFile

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

func (*Service) KillAll

func (s *Service) KillAll()

func (*Service) ListActiveEgress

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

func (*Service) ListEgress

func (s *Service) ListEgress() []string

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(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)