websocket

package

v0.4.1 Latest Latest Go to latest Published: Mar 19, 2026 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

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

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

func (s *WebSocketSession) GetLastDial() time.Time

func (s *WebSocketSession) GetPeerID() 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