websocket

package

v0.2.0 Latest Latest Go to latest Published: Mar 15, 2026 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

func NewWebSocketClient(log *slog.Logger, peer domain.Peer, sStorage sessionstorage.SessionStorage) client.Client

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

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

func (c *WebSocketClient) Connect(ctx context.Context, peer *domain.Peer) (session.Session, error)

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