service

Documentation

Index

• func NewIOClient(bus psrpc.MessageBus) (rpc.IOInfoClient, error)
• type DebugService
  • func NewDebugService(pm *ProcessManager) *DebugService
  • func (s *DebugService) GetGstPipelineDotFile(egressID string) (string, error)
  • func (s *DebugService) StartDebugHandlers(port int)
• 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)
  • func (c *IOClient) UpdateMetrics(ctx context.Context, req *rpc.UpdateMetricsRequest, ...) (*emptypb.Empty, error)
• type MetricsService
  • 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 Process
  • func (p *Process) Gather() ([]*dto.MetricFamily, error)
• type ProcessManager
  • func NewProcessManager() *ProcessManager
  • func (pm *ProcessManager) AlreadyExists(egressID string) bool
  • 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)

Functions

func NewIOClient

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

Types

type DebugService

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

func NewDebugService

func NewDebugService(pm *ProcessManager) *DebugService

func (*DebugService) GetGstPipelineDotFile

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

func (*DebugService) StartDebugHandlers

func (s *DebugService) StartDebugHandlers(port int)

type IOClient

type IOClient struct {
	rpc.IOInfoClient
	// contains filtered or unexported fields
}

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)

func (*IOClient) UpdateMetrics

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

type MetricsService

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

func NewMetricsService

func NewMetricsService(pm *ProcessManager) *MetricsService

func (*MetricsService) CreateGatherer

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

func (*MetricsService) PromHandler

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

func (*MetricsService) StoreProcessEndedMetrics

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

type Process

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

func (*Process) Gather

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

Gather implements the prometheus.Gatherer interface on server-side to allow aggregation of handler ms

type ProcessManager

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

func NewProcessManager

func NewProcessManager() *ProcessManager

func (*ProcessManager) AlreadyExists

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

func (*ProcessManager) GetActiveEgressIDs

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

func (*ProcessManager) GetContext

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

func (*ProcessManager) GetGRPCClient

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

func (*ProcessManager) GetGatherers

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

func (*ProcessManager) GetStatus

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

func (*ProcessManager) HandlerStarted

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

func (*ProcessManager) KillAll

func (pm *ProcessManager) KillAll()

func (*ProcessManager) KillProcess

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

func (*ProcessManager) Launch

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

func (*ProcessManager) ProcessFinished

func (pm *ProcessManager) ProcessFinished(egressID string)