quic

type Connection interface {
	// AcceptStream returns the next stream opened by the peer, blocking until one is available.
	// If the connection was closed due to a timeout, the error satisfies
	// the net.Error interface, and Timeout() will be true.
	AcceptStream(context.Context) (Stream, error)
	// AcceptUniStream returns the next unidirectional stream opened by the peer, blocking until one is available.
	// If the connection was closed due to a timeout, the error satisfies
	// the net.Error interface, and Timeout() will be true.
	//AcceptUniStream(context.Context) (Stream, error)
	// OpenStream opens a new bidirectional QUIC stream.
	// There is no signaling to the peer about new streams:
	// The peer can only accept the stream after data has been sent on the stream,
	// or the stream has been reset or closed.
	// When reaching the peer's stream limit, it is not possible to open a new stream until the
	// peer raises the stream limit. In that case, a StreamLimitReachedError is returned.
	OpenStream() (Stream, error)
	// OpenStreamSync opens a new bidirectional QUIC stream.
	// It blocks until a new stream can be opened.
	// There is no signaling to the peer about new streams:
	// The peer can only accept the stream after data has been sent on the stream,
	// or the stream has been reset or closed.
	//OpenStreamSync(context.Context) (Stream, error)
	// OpenUniStream opens a new outgoing unidirectional QUIC stream.
	// There is no signaling to the peer about new streams:
	// The peer can only accept the stream after data has been sent on the stream,
	// or the stream has been reset or closed.
	// When reaching the peer's stream limit, it is not possible to open a new stream until the
	// peer raises the stream limit. In that case, a StreamLimitReachedError is returned.
	//OpenUniStream() (Stream, error)
	// OpenUniStreamSync opens a new outgoing unidirectional QUIC stream.
	// It blocks until a new stream can be opened.
	// There is no signaling to the peer about new streams:
	// The peer can only accept the stream after data has been sent on the stream,
	// or the stream has been reset or closed.
	//OpenUniStreamSync(context.Context) (Stream, error)
	// LocalAddr returns the local address.
	//LocalAddr() net.Addr
	// RemoteAddr returns the address of the peer.
	//RemoteAddr() net.Addr
	// CloseWithError closes the connection with an error.
	// The error string will be sent to the peer.
	CloseWithError(quic.ApplicationErrorCode, string) error
}

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

type Dialer interface {
	DialQuic(ctx context.Context, url *url.URL) (Connection, error)
}

type Egress interface {
	// HandleWrp is called whenever a message targets something other than this device.
	HandleWrp(m wrp.Message) error
}

type Http3ClientConfig struct {
	QuicConfig quic.Config
	TlsConfig  tls.Config
}

type Option interface {
	// contains filtered or unexported methods
}

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

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

type Redirector interface {
	GetUrl(ctx context.Context, inUrl *url.URL) (*url.URL, error)
}

type Stream interface {
	StreamID() quic.StreamID
	Read(p []byte) (int, error)
	Write(p []byte) (int, error)
	CancelRead(errorCode quic.StreamErrorCode)
	Context() context.Context
	Close() error
	SetReadDeadline(t time.Time) error
	SetDeadline(t time.Time) error
}

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