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
- type Service
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewIOClient ¶ added in v1.8.0
func NewIOClient(bus psrpc.MessageBus) (rpc.IOInfoClient, error)
Types ¶
type IOClient ¶ added in v1.8.0
type IOClient struct {
rpc.IOInfoClient
}
func (*IOClient) CreateEgress ¶ added in v1.8.0
func (c *IOClient) CreateEgress(ctx context.Context, info *livekit.EgressInfo, opts ...psrpc.RequestOption) (*emptypb.Empty, error)
func (*IOClient) UpdateEgress ¶ added in v1.8.0
func (c *IOClient) UpdateEgress(ctx context.Context, info *livekit.EgressInfo, opts ...psrpc.RequestOption) (*emptypb.Empty, error)
func (*IOClient) UpdateMetrics ¶ added in v1.8.1
func (c *IOClient) UpdateMetrics(ctx context.Context, req *rpc.UpdateMetricsRequest, opts ...psrpc.RequestOption) (*emptypb.Empty, error)
type Process ¶ added in v1.7.8
type Process struct {
// contains filtered or unexported fields
}
func NewProcess ¶ added in v1.7.8
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 ¶ added in v1.7.8
func (*Service) CreateGatherer ¶ added in v1.8.1
func (s *Service) CreateGatherer() prometheus.Gatherer
func (*Service) GetGstPipelineDotFile ¶ added in v1.7.3
func (*Service) HandlerReady ¶ added in v1.8.1
func (*Service) HandlerShuttingDown ¶ added in v1.8.1
func (*Service) ListActiveEgress ¶ added in v1.5.4
func (s *Service) ListActiveEgress(ctx context.Context, _ *rpc.ListActiveEgressRequest) (*rpc.ListActiveEgressResponse, error)
func (*Service) PromHandler ¶ added in v1.8.1
func (*Service) Register ¶ added in v1.7.8
func (s *Service) Register(psrpcServer rpc.EgressInternalServer)
func (*Service) RegisterListEgress ¶ added in v1.8.1
func (*Service) StartDebugHandlers ¶ added in v1.5.4
func (s *Service) StartDebugHandlers()
func (*Service) StartEgress ¶ added in v1.5.4
func (s *Service) StartEgress(ctx context.Context, req *rpc.StartEgressRequest) (*livekit.EgressInfo, error)
func (*Service) StartEgressAffinity ¶ added in v1.5.4
func (*Service) StartTemplatesServer ¶ added in v1.5.6
Click to show internal directories.
Click to hide internal directories.