service

Documentation

Index

• type Handler
  • func NewHandler(conf *config.Config, rpcServer egress.RPCServer) *Handler
  • func (h *Handler) HandleRequest(ctx context.Context, req *livekit.StartEgressRequest)
  • func (h *Handler) Kill()
• type Service
  • func NewService(conf *config.Config, rpcServer egress.RPCServer) *Service
  • func (s *Service) ListEgress() []string
  • func (s *Service) Run() error
  • func (s *Service) Status() ([]byte, error)
  • func (s *Service) Stop(kill bool)

Types

type Handler

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

func NewHandler

func NewHandler(conf *config.Config, rpcServer egress.RPCServer) *Handler

func (*Handler) HandleRequest

func (h *Handler) HandleRequest(ctx context.Context, req *livekit.StartEgressRequest)

func (*Handler) Kill

func (h *Handler) Kill()

type Service

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

func NewService

func NewService(conf *config.Config, rpcServer egress.RPCServer) *Service

func (*Service) ListEgress

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

func (*Service) Run

func (s *Service) Run() error

func (*Service) Status

func (s *Service) Status() ([]byte, error)

func (*Service) Stop

func (s *Service) Stop(kill bool)