transport

package

v1.0.1 Latest Latest Go to latest Published: Aug 22, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func NewMemPair() (*MemConnection, *MemConnection)

NewMemPair creates two fully connected endpoints.

type Connection interface {
	Send(ctx context.Context, data []byte) error
	Receive(ctx context.Context) ([]byte, error)
	Close(reason string) error
}

type MemConnection struct {
	In  chan []byte
	Out chan []byte
}

MemConnection implements transport.Connection for in-memory tests.

func (m *MemConnection) Close(reason string) error

func (m *MemConnection) Receive(ctx context.Context) ([]byte, error)

func (m *MemConnection) Send(ctx context.Context, data []byte) error

type WSConnection struct {
	Conn *websocket.Conn
}

func (w *WSConnection) Close(reason string) error

func (w *WSConnection) Receive(ctx context.Context) ([]byte, error)

func (w *WSConnection) Send(ctx context.Context, data []byte) error

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

WSProvider encapsulates the logic for establishing the connection.

func NewWSProvider(logger *slog.Logger) *WSProvider

func (p *WSProvider) Dial(ctx context.Context, url string) (Connection, error)

Dial connects to a server (client side)

func (p *WSProvider) Listen(ctx context.Context, addr string, found chan<- Connection) error

Server is waiting for a connection (server-side) We use a channel to reconnect after the upgrade

type WSService interface {
	Listen(addr string, found chan<- Connection) error
	Dial(ctx context.Context, url string) (Connection, error)
}