quic

type DataStreamer ¶

type DataStreamer interface {
	DataStream() quic.Stream
}

DataSreamer is implemented by response writer on server side to take over the stream.

type Quic ¶

type Quic struct {
	Auth *meshauth.MeshAuth

	// UgateSVC - for node tracking
	UG *ugate.UGate
	// contains filtered or unexported fields
}

Quic is the adapter to QUIC/H3/MASQUE for uGate.

func New(ug *ugate.UGate, ll *meshauth.PortListener) *Quic

func (qd *Quic) DialMux(ctx context.Context, node *ugate.MeshCluster) (*QuicMUX, error)

func (qd *Quic) Start() error

type QuicMUX ¶

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

QuicMUX is a mux to a specific node. May be accepted or dialed. Equivalent with quic/h3/client.go ( when dialing ), and Quic server when accepting.

func (ugs *QuicMUX) Close() error

func (ugs *QuicMUX) DialContext(ctx context.Context, net, addr string) (net.Conn, error)

type QuicNetCon ¶

type QuicNetCon struct {
	quic.Stream
}

func (q QuicNetCon) LocalAddr() net.Addr

func (q QuicNetCon) RemoteAddr() net.Addr