server

Documentation

Index

• type Server
  • func NewServer(conf *config.ServiceConfig, bus psrpc.MessageBus, ioClient rpc.IOInfoClient) (*Server, error)
  • func (s *Server) Drain()
  • func (s *Server) HandlerFinished(ctx context.Context, req *ipc.HandlerFinishedRequest) (*emptypb.Empty, error)
  • func (s *Server) HandlerReady(_ context.Context, req *ipc.HandlerReadyRequest) (*emptypb.Empty, error)
  • func (s *Server) HandlerUpdate(ctx context.Context, info *livekit.EgressInfo) (*emptypb.Empty, error)
  • func (s *Server) IsDisabled() bool
  • func (s *Server) IsIdle() bool
  • func (s *Server) IsTerminating() bool
  • func (s *Server) ListActiveEgress(ctx context.Context, _ *rpc.ListActiveEgressRequest) (*rpc.ListActiveEgressResponse, error)
  • func (s *Server) Run() error
  • func (s *Server) Shutdown(terminating, kill bool)
  • func (s *Server) StartEgress(ctx context.Context, req *rpc.StartEgressRequest) (*livekit.EgressInfo, error)
  • func (s *Server) StartEgressAffinity(_ context.Context, req *rpc.StartEgressRequest) float32
  • func (s *Server) StartTemplatesServer(fs fs.FS) error
  • func (s *Server) Status() ([]byte, error)

Types

type Server

type Server struct {
	ipc.UnimplementedEgressServiceServer

	*service.ProcessManager
	*service.MetricsService
	*service.DebugService
	// contains filtered or unexported fields
}

func NewServer

func NewServer(conf *config.ServiceConfig, bus psrpc.MessageBus, ioClient rpc.IOInfoClient) (*Server, error)

func (*Server) Drain

func (s *Server) Drain()

func (*Server) HandlerFinished

func (s *Server) HandlerFinished(ctx context.Context, req *ipc.HandlerFinishedRequest) (*emptypb.Empty, error)

func (*Server) HandlerReady

func (s *Server) HandlerReady(_ context.Context, req *ipc.HandlerReadyRequest) (*emptypb.Empty, error)

func (*Server) HandlerUpdate

func (s *Server) HandlerUpdate(ctx context.Context, info *livekit.EgressInfo) (*emptypb.Empty, error)

func (*Server) IsDisabled

func (s *Server) IsDisabled() bool

func (*Server) IsIdle

func (s *Server) IsIdle() bool

func (*Server) IsTerminating

func (s *Server) IsTerminating() bool

func (*Server) ListActiveEgress

func (s *Server) ListActiveEgress(ctx context.Context, _ *rpc.ListActiveEgressRequest) (*rpc.ListActiveEgressResponse, error)

func (*Server) Run

func (s *Server) Run() error

func (*Server) Shutdown

func (s *Server) Shutdown(terminating, kill bool)

func (*Server) StartEgress

func (s *Server) StartEgress(ctx context.Context, req *rpc.StartEgressRequest) (*livekit.EgressInfo, error)

func (*Server) StartEgressAffinity

func (s *Server) StartEgressAffinity(_ context.Context, req *rpc.StartEgressRequest) float32

func (*Server) StartTemplatesServer

func (s *Server) StartTemplatesServer(fs fs.FS) error

func (*Server) Status

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