quic

Documentation

Index

• Variables
• func Listen(ctx context.Context, addr string) (*common.Listener, error)
• type QuicSession
  • func Dial(ctx context.Context, addr string) (*QuicSession, error)
  • func (s *QuicSession) Accept(ctx context.Context) (tunnel.Stream, error)
  • func (s *QuicSession) Close() error
  • func (s *QuicSession) Open(ctx context.Context) (tunnel.Stream, error)
• type StreamConn
  • func (sc *StreamConn) LocalAddr() net.Addr
  • func (sc *StreamConn) RemoteAddr() net.Addr
  • func (sc *StreamConn) SetDeadline(time.Time) error
  • func (sc *StreamConn) SetReadDeadline(time.Time) error
  • func (sc *StreamConn) SetWriteDeadline(time.Time) error
• type Transport
  • func (t *Transport) Dial(ctx context.Context, addr string) (tunnel.Session, error)
  • func (t *Transport) Listen(ctx context.Context, addr string) (net.Listener, error)
• type Upgrader
  • func (s *Upgrader) Upgrade() (*edge.Edge, error)

Variables

var (
	GoQuicConnsAccepted = expvar.NewInt("go_quic_conns_accepted")
	GoQuicConnsOpened   = expvar.NewInt("go_quic_conns_opened")
	GoQuicConnsClosed   = expvar.NewInt("go_quic_conns_closed")
)

var MaxBidiRemoteStreams int64 = 1 << 60

2^60 == 1152921504606846976

var QUICConfig = &quic.Config{
	TLSConfig:            TLSConfig,
	MaxBidiRemoteStreams: MaxBidiRemoteStreams,
	QLogLogger: slog.New(slog.NewJSONHandler(os.Stderr, &slog.HandlerOptions{
		AddSource: true,
		Level:     quic.QLogLevelFrame,
	})),
}

var TLSConfig = &tls.Config{
	InsecureSkipVerify: true,
	MinVersion:         tls.VersionTLS13,
}

Functions

func Listen

func Listen(ctx context.Context, addr string) (*common.Listener, error)

Types

type QuicSession

type QuicSession struct {
	Session *quic.Conn
}

func Dial

func Dial(ctx context.Context, addr string) (*QuicSession, error)

func (*QuicSession) Accept

func (s *QuicSession) Accept(ctx context.Context) (tunnel.Stream, error)

func (*QuicSession) Close

func (s *QuicSession) Close() error

func (*QuicSession) Open

func (s *QuicSession) Open(ctx context.Context) (tunnel.Stream, error)

type StreamConn

type StreamConn struct {
	*quic.Stream
	Session *quic.Conn
}

StreamsConn wraps quic.Stream into net.Conn

func (*StreamConn) LocalAddr

func (sc *StreamConn) LocalAddr() net.Addr

LocalAddr is required to impl net.Conn

func (*StreamConn) RemoteAddr

func (sc *StreamConn) RemoteAddr() net.Addr

RemoteAddr is required to impl net.Conn

func (*StreamConn) SetDeadline

func (sc *StreamConn) SetDeadline(time.Time) error

SetDeadline is required to impl net.Conn

func (*StreamConn) SetReadDeadline

func (sc *StreamConn) SetReadDeadline(time.Time) error

SetReadDeadline is required to impl net.Conn

func (*StreamConn) SetWriteDeadline

func (sc *StreamConn) SetWriteDeadline(time.Time) error

SetWriteDeadline is required to impl net.Conn

type Transport

type Transport struct{}

func (*Transport) Dial

func (t *Transport) Dial(ctx context.Context, addr string) (tunnel.Session, error)

func (*Transport) Listen

func (t *Transport) Listen(ctx context.Context, addr string) (net.Listener, error)

type Upgrader

type Upgrader struct {
	Listener *quic.Endpoint
	common.RootPatterns
}

func (*Upgrader) Upgrade

func (s *Upgrader) Upgrade() (*edge.Edge, error)