service

Documentation

Index

• func NewIOClient(bus psrpc.MessageBus) (rpc.IOInfoClient, 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)
  • func (c *IOClient) UpdateMetrics(ctx context.Context, req *rpc.UpdateMetricsRequest, ...) (*emptypb.Empty, error)
• type Process
  • func NewProcess(ctx context.Context, handlerID string, req *rpc.StartEgressRequest, ...) (*Process, error)
  • func (p *Process) Gather() ([]*dto.MetricFamily, error)
• type Service
  • func NewService(conf *config.ServiceConfig, ioClient rpc.IOInfoClient) (*Service, error)
  • func (s *Service) AddHandler(egressID string, p *Process) error
  • func (s *Service) Close()
  • func (s *Service) CreateGatherer() prometheus.Gatherer
  • func (s *Service) GetGstPipelineDotFile(egressID string) (string, error)
  • func (s *Service) HandlerReady(_ context.Context, req *ipc.HandlerReadyRequest) (*emptypb.Empty, error)
  • func (s *Service) HandlerShuttingDown(_ context.Context, req *ipc.HandlerShuttingDownRequest) (*emptypb.Empty, error)
  • func (s *Service) KillAll()
  • func (s *Service) ListActiveEgress(ctx context.Context, _ *rpc.ListActiveEgressRequest) (*rpc.ListActiveEgressResponse, error)
  • func (s *Service) PromHandler() http.Handler
  • func (s *Service) Register(psrpcServer rpc.EgressInternalServer)
  • func (s *Service) RegisterListEgress(topic string) error
  • 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(_ 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 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)

func (*IOClient) UpdateMetrics

func (c *IOClient) UpdateMetrics(ctx context.Context, req *rpc.UpdateMetricsRequest, 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)

func (*Process) Gather

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

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

type Service

type Service struct {
	ipc.UnimplementedEgressServiceServer

	*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, p *Process) error

func (*Service) Close

func (s *Service) Close()

func (*Service) CreateGatherer

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

func (*Service) GetGstPipelineDotFile

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

func (*Service) HandlerReady

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

func (*Service) HandlerShuttingDown

func (s *Service) HandlerShuttingDown(_ context.Context, req *ipc.HandlerShuttingDownRequest) (*emptypb.Empty, 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) PromHandler

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

func (*Service) Register

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

func (*Service) RegisterListEgress

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

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