service

package

v0.0.2 Latest Latest Go to latest Published: Feb 28, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Handler struct {
	// contains filtered or unexported fields
}

func NewHandler(conf *config.Config, rpcClient rpc.IOInfoClient) *Handler

func (h *Handler) DeleteIngress(ctx context.Context, req *livekit.DeleteIngressRequest) (*livekit.IngressState, error)

func (h *Handler) HandleIngress(ctx context.Context, info *livekit.IngressInfo, wsUrl string, token string)

func (h *Handler) Kill()

func (h *Handler) UpdateIngress(ctx context.Context, req *livekit.UpdateIngressRequest) (*livekit.IngressState, error)

type ProcessManager struct {
	// contains filtered or unexported fields
}

func NewProcessManager(conf *config.Config, monitor *stats.Monitor) *ProcessManager

type Service struct {
	// contains filtered or unexported fields
}

func NewService(conf *config.Config, psrpcClient rpc.IOInfoClient) *Service

func (s *Service) CanAccept() bool

func (s *Service) HandleRTMPPublishRequest(streamKey string) error

func (s *Service) ListActiveIngress(ctx context.Context, _ *rpc.ListActiveIngressRequest) (*rpc.ListActiveIngressResponse, error)

func (s *Service) ListIngress() []string

func (s *Service) Run() error

func (s *Service) Stop(kill bool)