kuic

README

kuic

基于 quic-go 实现同一端口，同时当服务端又当客户端，从而实现nat穿透

使用前可能需要

go mod edit -replace github.com/quic-go/quic-go=github.com/chuccp/quic-go@v0.0.4

Documentation

Index

• Constants
• Variables
• func NewBaseServer(udpConn *net.UDPConn, context context.Context) *baseServer
• func NewBasicConn(conn *net.UDPConn, writeToFunc WriteToFunc, lAddr net.Addr, ...) *basicConn
• type Addr
  • func NewAddr(addr net.Addr, seq byte) *Addr
  • func (a *Addr) Network() string
  • func (a *Addr) String() string
• type BaseServer
• type Connection
• type Listener
  • func Listen(addr *net.UDPAddr) (*Listener, error)
  • func (l *Listener) Accept() (Connection, error)
  • func (l *Listener) Close() error
  • func (l *Listener) Dial(addr *net.UDPAddr) (Connection, error)
  • func (l *Listener) GetClientConn() (net.PacketConn, error)
  • func (l *Listener) GetServerConn() (net.PacketConn, error)
• type WriteToFunc

Constants

const MaxPacketBufferSize = 1452

const MaxSeqNum byte = 0x7F

Variables

var ErrConnNumOver = errors.New("conn number Over")

Functions

func NewBaseServer

func NewBaseServer(udpConn *net.UDPConn, context context.Context) *baseServer

func NewBasicConn

func NewBasicConn(conn *net.UDPConn, writeToFunc WriteToFunc, lAddr net.Addr, ctx context.Context) *basicConn

Types

type Addr

type Addr struct {
	net.Addr
	// contains filtered or unexported fields
}

func NewAddr

func NewAddr(addr net.Addr, seq byte) *Addr

func (*Addr) Network

func (a *Addr) Network() string

func (*Addr) String

func (a *Addr) String() string

type BaseServer

type BaseServer interface {
	GetServerConn() (net.PacketConn, error)
	GetClientConn() (net.PacketConn, error)
}

type Connection

type Connection interface {
	AcceptStream() (quic.Stream, error)
	OpenStreamSync() (quic.Stream, error)
	Close() error
}

type Listener

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

func Listen

func Listen(addr *net.UDPAddr) (*Listener, error)

func (*Listener) Accept

func (l *Listener) Accept() (Connection, error)

func (*Listener) Close

func (l *Listener) Close() error

func (*Listener) Dial

func (l *Listener) Dial(addr *net.UDPAddr) (Connection, error)

func (*Listener) GetClientConn

func (l *Listener) GetClientConn() (net.PacketConn, error)

func (*Listener) GetServerConn

func (l *Listener) GetServerConn() (net.PacketConn, error)

type WriteToFunc

type WriteToFunc func(ps []byte, addr net.Addr) (n int, err error)