server

package
v1.8.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 19, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v1.8.6

func (s *Server) IsTerminating() bool

func (*Server) ListActiveEgress

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL