service

package
v1.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 24, 2024 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

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 

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

func (*Process) Gather added in v1.8.1 

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 added in v1.7.8 

func (s *Service) AddHandler(egressID string, p *Process) error

func (*Service) Close added in v1.7.7 

func (s *Service) Close()

func (*Service) CreateGatherer added in v1.8.1 

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

func (*Service) GetGstPipelineDotFile added in v1.7.3 

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

func (*Service) HandlerReady added in v1.8.1 

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

func (*Service) HandlerShuttingDown added in v1.8.1 

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

func (*Service) KillAll added in v1.5.6 

func (s *Service) KillAll()

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 (s *Service) PromHandler() http.Handler

func (*Service) Register added in v1.7.8 

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

func (*Service) RegisterListEgress added in v1.8.1 

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

func (*Service) Reset added in v1.7.7 

func (s *Service) Reset()

func (*Service) Run 

func (s *Service) Run() error

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 (s *Service) StartEgressAffinity(ctx context.Context, req *rpc.StartEgressRequest) float32

func (*Service) StartTemplatesServer added in v1.5.6 

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.