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 *auth.Auth
	Port int

	// Incoming streams are mapped to HTTP
	HTTPHandler http.Handler

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

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

Implements: - MuxDialer

Will start a H3 server and dispatch streams and H3 requests to uGate ¶

Integration with Quic library: - fork to expose few internal methods needed - low level UDP will be multiplexed with STUN/TURN - feature is supported upstream - using the raw QUIC library for streams, to get access to the reverse path - main RoundTripper is uGate, this acts as 'client.go'.

TODO: Datagram will also be dispatched - either as UDP or as Webpush messages TODO: define 'webpush over MASQUE' TODO: also MASQUE-IP, if TUN support is enabled ( Android )

func New(ug *ugatesvc.UGate) *Quic

func (qd *Quic) DialMux(ctx context.Context, node *ugate.DMNode, meta http.Header, ev func(t string, stream *ugate.Stream)) (ugate.Muxer, 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) DialStream(ctx context.Context, addr string, inStream *ugate.Stream) (*ugate.Stream, error)

func (ugs *QuicMUX) RoundTrip(request *http.Request) (*http.Response, error)