Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DebugService ¶ added in v1.8.4
type DebugService struct {
// contains filtered or unexported fields
}
func NewDebugService ¶ added in v1.8.4
func NewDebugService(pm ProcessManager) *DebugService
func (*DebugService) GetGstPipelineDotFile ¶ added in v1.8.4
func (s *DebugService) GetGstPipelineDotFile(egressID string) (string, error)
func (*DebugService) StartDebugHandlers ¶ added in v1.8.4
func (s *DebugService) StartDebugHandlers(port int)
type MetricsService ¶ added in v1.8.4
type MetricsService struct {
// contains filtered or unexported fields
}
func NewMetricsService ¶ added in v1.8.4
func NewMetricsService(pm ProcessManager) *MetricsService
func (*MetricsService) CreateGatherer ¶ added in v1.8.4
func (s *MetricsService) CreateGatherer() prometheus.Gatherer
func (*MetricsService) PromHandler ¶ added in v1.8.4
func (s *MetricsService) PromHandler() http.Handler
func (*MetricsService) StoreProcessEndedMetrics ¶ added in v1.8.4
func (s *MetricsService) StoreProcessEndedMetrics(egressID string, metrics string) error
type ProcessManager ¶ added in v1.5.3
type ProcessManager interface {
Launch(ctx context.Context, handlerID string, req *rpc.StartEgressRequest, info *livekit.EgressInfo, cmd *exec.Cmd) error
GetContext(egressID string) context.Context
AlreadyExists(egressID string) bool
HandlerStarted(egressID string) error
GetActiveEgressIDs() []string
GetStatus(info map[string]interface{})
GetGatherers() []prometheus.Gatherer
GetGRPCClient(egressID string) (ipc.EgressHandlerClient, error)
KillAll()
AbortProcess(egressID string, err error)
KillProcess(egressID string, reason string, err error)
GetKillReason(egressID string) string
ProcessFinished(egressID string)
}
func NewProcessManager ¶ added in v1.5.3
func NewProcessManager() ProcessManager
Click to show internal directories.
Click to hide internal directories.