Documentation ¶
Index ¶
- type Handler
- func (h *Handler) GetPProf(ctx context.Context, req *ipc.PProfRequest) (*ipc.PProfResponse, error)
- func (h *Handler) GetPipelineDot(ctx context.Context, _ *ipc.GstPipelineDebugDotRequest) (*ipc.GstPipelineDebugDotResponse, error)
- func (h *Handler) Kill()
- func (h *Handler) Run() error
- func (h *Handler) StopEgress(ctx context.Context, _ *livekit.StopEgressRequest) (*livekit.EgressInfo, error)
- func (h *Handler) UpdateStream(ctx context.Context, req *livekit.UpdateStreamRequest) (*livekit.EgressInfo, error)
- type HandlerV0
- type ProcessManager
- type Service
- func (s *Service) ListActiveEgress(ctx context.Context, _ *rpc.ListActiveEgressRequest) (*rpc.ListActiveEgressResponse, error)
- func (s *Service) ListEgress() []string
- func (s *Service) Run() error
- func (s *Service) StartDebugHandlers()
- func (s *Service) StartEgress(ctx context.Context, req *livekit.StartEgressRequest) (*livekit.EgressInfo, error)
- func (s *Service) StartEgressAffinity(req *livekit.StartEgressRequest) float32
- func (s *Service) Status() ([]byte, error)
- func (s *Service) Stop(kill bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶ added in v1.0.2
type Handler struct { ipc.UnimplementedEgressHandlerServer // contains filtered or unexported fields }
func NewHandler ¶ added in v1.0.2
func NewHandler(conf *config.PipelineConfig, bus psrpc.MessageBus, ioClient rpc.IOInfoClient) (*Handler, error)
func (*Handler) GetPProf ¶ added in v1.5.5
func (h *Handler) GetPProf(ctx context.Context, req *ipc.PProfRequest) (*ipc.PProfResponse, error)
func (*Handler) GetPipelineDot ¶ added in v1.5.5
func (h *Handler) GetPipelineDot(ctx context.Context, _ *ipc.GstPipelineDebugDotRequest) (*ipc.GstPipelineDebugDotResponse, error)
func (*Handler) StopEgress ¶ added in v1.5.4
func (h *Handler) StopEgress(ctx context.Context, _ *livekit.StopEgressRequest) (*livekit.EgressInfo, error)
func (*Handler) UpdateStream ¶ added in v1.5.4
func (h *Handler) UpdateStream(ctx context.Context, req *livekit.UpdateStreamRequest) (*livekit.EgressInfo, error)
type HandlerV0 ¶ added in v1.5.4
type HandlerV0 struct { ipc.UnimplementedEgressHandlerServer // contains filtered or unexported fields }
func NewHandlerV0 ¶ added in v1.5.4
type ProcessManager ¶ added in v1.5.3
type ProcessManager struct {
// contains filtered or unexported fields
}
func NewProcessManager ¶ added in v1.5.3
func NewProcessManager(conf *config.ServiceConfig, monitor *stats.Monitor) *ProcessManager
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func NewService(conf *config.ServiceConfig, bus psrpc.MessageBus, rpcServerV0 egress.RPCServer) (*Service, error)
func (*Service) ListActiveEgress ¶ added in v1.5.4
func (s *Service) ListActiveEgress(ctx context.Context, _ *rpc.ListActiveEgressRequest) (*rpc.ListActiveEgressResponse, error)
func (*Service) ListEgress ¶ added in v1.1.0
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 *livekit.StartEgressRequest) (*livekit.EgressInfo, error)
func (*Service) StartEgressAffinity ¶ added in v1.5.4
func (s *Service) StartEgressAffinity(req *livekit.StartEgressRequest) float32
Click to show internal directories.
Click to hide internal directories.