server

package

v0.10.0 Latest Latest Go to latest Published: Jul 3, 2025 License: LGPL-3.0 Imports: 23 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func (s *HTTPServer) Serve()

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

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 {
	// contains filtered or unexported fields
}

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

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

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