Documentation
¶
Index ¶
- type Handler
- func (h *Handler) GenerateMetrics(_ context.Context) (string, error)
- func (h *Handler) GetMetrics(ctx context.Context, _ *ipc.MetricsRequest) (*ipc.MetricsResponse, error)
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
ipc.UnimplementedEgressHandlerServer
// contains filtered or unexported fields
}
func NewHandler ¶
func NewHandler(conf *config.PipelineConfig, bus psrpc.MessageBus, ioClient rpc.IOInfoClient) (*Handler, error)
func (*Handler) GenerateMetrics ¶
func (*Handler) GetMetrics ¶
func (h *Handler) GetMetrics(ctx context.Context, _ *ipc.MetricsRequest) (*ipc.MetricsResponse, error)
GetMetrics implement the handler-side gathering of metrics to return over IPC
func (*Handler) GetPProf ¶
func (h *Handler) GetPProf(ctx context.Context, req *ipc.PProfRequest) (*ipc.PProfResponse, error)
func (*Handler) GetPipelineDot ¶
func (h *Handler) GetPipelineDot(ctx context.Context, _ *ipc.GstPipelineDebugDotRequest) (*ipc.GstPipelineDebugDotResponse, error)
func (*Handler) StopEgress ¶
func (h *Handler) StopEgress(ctx context.Context, _ *livekit.StopEgressRequest) (*livekit.EgressInfo, error)
func (*Handler) UpdateStream ¶
func (h *Handler) UpdateStream(ctx context.Context, req *livekit.UpdateStreamRequest) (*livekit.EgressInfo, error)
Source Files
Click to show internal directories.
Click to hide internal directories.