handler

Documentation

Index

• type Handler
  • func NewHandler(conf *config.PipelineConfig, bus psrpc.MessageBus) (*Handler, error)
  • 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()
  • 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)

Types

type Handler

type Handler struct {
	ipc.UnimplementedEgressHandlerServer
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(conf *config.PipelineConfig, bus psrpc.MessageBus) (*Handler, error)

func (*Handler) GenerateMetrics

func (h *Handler) GenerateMetrics(_ context.Context) (string, error)

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) Kill

func (h *Handler) Kill()

func (*Handler) Run

func (h *Handler) Run()

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)