quic

package

v0.5.30 Latest Latest Go to latest Published: May 15, 2024 License: MIT Imports: 17 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/webteleport/webteleport

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Listen(ctx context.Context, addr string) (*common.Listener, error)
type QuicSession
- func Dial(ctx context.Context, addr string) (*QuicSession, error)
type StreamConn
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) Root() string
- func (s *Upgrader) Upgrade() (*edge.Edge, error)

Constants ¶

This section is empty.

Variables ¶

View Source

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

View Source

var MaxBidiRemoteStreams int64 = 1 << 60

2^60 == 1152921504606846976

View Source

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

View Source

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 ¶ added in v0.5.24

type Upgrader struct {
	Listener *quic.Endpoint
	HOST     string
}

func (*Upgrader) Root ¶ added in v0.5.24

func (s *Upgrader) Root() string

func (*Upgrader) Upgrade ¶ added in v0.5.24

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL