websocket

package

v0.1.0 Latest Latest Go to latest Published: Mar 4, 2026 License: MIT Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

func NewWebSocketServer(port int, sessionsStorage sessionstorage.SessionStorage) server.Server

func NewWebSocketSession(conn *websocket.Conn, peer *domain.Peer, incoming bool, lastDial time.Time) session.Session

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

func (s *WebSocketServer) Serve() error

func (s *WebSocketServer) Stop(ctx context.Context)

type WebSocketSession struct {
	session.BaseSession
	// contains filtered or unexported fields
}

func (s *WebSocketSession) Close(ctx context.Context)

func (s *WebSocketSession) GetID() uuid.UUID

func (s *WebSocketSession) GetReadChannel(context.Context) (chan *pb.Message, error)

func (s *WebSocketSession) GetWriteChannel(context.Context) (chan *pb.Message, error)

func (s *WebSocketSession) IsIncoming() bool

func (s *WebSocketSession) IsOpen() bool

func (s *WebSocketSession) Read(ctx context.Context)

func (s *WebSocketSession) Write(ctx context.Context)