server

Apr 24, 2025

Changes in this version

+ type HTTPServer struct

+ func NewHTTPServer(cfg *config.Config, ps pubsub.PubSub) *HTTPServer

+ func (s *HTTPServer) Serve()

+ type Server struct

+ func NewServer(cfg *config.Config, ps pubsub.PubSub) *Server

+ func (s *Server) Close() error

+ func (s *Server) CloseSession(id string)

+ func (s *Server) HandlePubSub(ctx context.Context, msg []byte)

+ func (s *Server) OnStart() error

+ func (s *Server) PublishPubSub(msg interface{})

+ type Session struct

+ func NewSession(id string, s *Server, wrtc *webrtc.WebRTC, lk *livekit.LiveKitWebRTC, ...) *Session

+ func (s *Session) StartRecording(e *events.StartRecording) (string, error)

+ func (s *Session) StopRecording() time.Duration