service

Aug 19, 2024

Changes in this version

type ProcessManager

+ func (pm *ProcessManager) AlreadyExists(egressID string) bool

May 20, 2024

Changes in this version

+ type DebugService struct

+ func NewDebugService(pm *ProcessManager) *DebugService

+ func (s *DebugService) GetGstPipelineDotFile(egressID string) (string, error)

+ func (s *DebugService) StartDebugHandlers(port int)

+ type MetricsService struct

+ func NewMetricsService(pm *ProcessManager) *MetricsService

+ func (s *MetricsService) CreateGatherer() prometheus.Gatherer

+ func (s *MetricsService) PromHandler() http.Handler

+ func (s *MetricsService) StoreProcessEndedMetrics(egressID string, metrics string) error

type ProcessManager

+ func (pm *ProcessManager) GetActiveEgressIDs() []string

+ func (pm *ProcessManager) GetContext(egressID string) context.Context

+ func (pm *ProcessManager) GetGRPCClient(egressID string) (ipc.EgressHandlerClient, error)

+ func (pm *ProcessManager) GetGatherers() []prometheus.Gatherer

+ func (pm *ProcessManager) GetStatus(info map[string]interface{})

+ func (pm *ProcessManager) HandlerStarted(egressID string) error

+ func (pm *ProcessManager) KillAll()

+ func (pm *ProcessManager) KillProcess(egressID string, maxUsage float64)

+ func (pm *ProcessManager) Launch(ctx context.Context, handlerID string, req *rpc.StartEgressRequest, ...) error

+ func (pm *ProcessManager) ProcessFinished(egressID string)

Jan 24, 2024

Changes in this version

type IOClient

+ func (c *IOClient) UpdateMetrics(ctx context.Context, req *rpc.UpdateMetricsRequest, ...) (*emptypb.Empty, error)

type Process

+ func (p *Process) Gather() ([]*dto.MetricFamily, error)

type Service

+ func (s *Service) CreateGatherer() prometheus.Gatherer

+ func (s *Service) HandlerReady(ctx context.Context, req *ipc.HandlerReadyRequest) (*emptypb.Empty, error)

+ func (s *Service) HandlerShuttingDown(ctx context.Context, req *ipc.HandlerShuttingDownRequest) (*emptypb.Empty, error)

+ func (s *Service) PromHandler() http.Handler

+ func (s *Service) RegisterListEgress(topic string) error

Nov 1, 2023

Changes in this version

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

+ type IOClient struct

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

Oct 18, 2023

Changes in this version

type Handler

+ func (h *Handler) UpdateOutputs(ctx context.Context, req *livekit.UpdateOutputsRequest) (*livekit.EgressInfo, error)

Sep 8, 2023

Changes in this version

+ type Process struct

+ func NewProcess(handlerID string, req *rpc.StartEgressRequest, info *livekit.EgressInfo, ...) (*Process, error)

type Service

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

+ func (s *Service) IsIdle() bool

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

Jul 11, 2023

Changes in this version

type Service

+ func (s *Service) Close()

+ func (s *Service) Reset()

Jun 13, 2023

Changes in this version

type Service

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

Feb 27, 2023

Changes in this version

type Service

+ func (s *Service) KillAll()

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

Jan 23, 2023

Changes in this version

type Handler

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

Jan 3, 2023

Changes in this version

type Handler

+ func (h *Handler) GetDebugInfo(ctx context.Context, req *ipc.GetDebugInfoRequest) (*ipc.GetDebugInfoResponse, 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 struct

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

+ func (h *HandlerV0) GetDebugInfo(ctx context.Context, req *ipc.GetDebugInfoRequest) (*ipc.GetDebugInfoResponse, error)

+ func (h *HandlerV0) Kill()

+ func (h *HandlerV0) Run() error

type Service

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

+ func (s *Service) StartDebugHandlers()

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

+ func (s *Service) StartEgressAffinity(req *livekit.StartEgressRequest) float32

Dec 16, 2022

Changes in this version

type Handler

+ func (h *Handler) Run() error

+ type ProcessManager struct

+ func NewProcessManager(conf *config.ServiceConfig, monitor *stats.Monitor) *ProcessManager

Aug 3, 2022

Changes in this version

type Service

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

Jun 7, 2022

Changes in this version

+ type Handler struct

+ func NewHandler(conf *config.Config, bus utils.MessageBus) *Handler

+ func (h *Handler) HandleRequest(req *livekit.StartEgressRequest)

+ func (h *Handler) Kill()

May 19, 2022

Changes in this version

+ type Service struct

+ func NewService(conf *config.Config, bus utils.MessageBus) *Service

+ func (s *Service) Run() error

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

+ func (s *Service) Stop(kill bool)