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
• type Addr
  • func NewAddr(addr net.Addr, seq uint16) *Addr
  • func (a *Addr) Network() string
  • func (a *Addr) String() string
• type BaseServer
• type BasicConn
  • func NewBasicConn(conn *net.UDPConn, writeToFunc WriteToFunc, lAddr net.Addr, ...) *BasicConn
  • func (c *BasicConn) Close() error
  • func (c *BasicConn) GetContext() context.Context
  • func (c *BasicConn) LocalAddr() net.Addr
  • func (c *BasicConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)
  • func (c *BasicConn) SetReadBuffer(bytes int) error
  • func (c *BasicConn) SetReadDeadline(t time.Time) error
  • func (c *BasicConn) SetWriteBuffer(bytes int) error
  • func (c *BasicConn) WaitClose()
  • func (c *BasicConn) WriteTo(ps []byte, rAddr net.Addr) (n int, err error)
• 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 uint16 = 0x7FFF

Variables

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

Functions

func NewBaseServer

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

Types

type Addr

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

func NewAddr

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

func (*Addr) Network

func (a *Addr) Network() string

func (*Addr) String

func (a *Addr) String() string

type BaseServer

type BaseServer interface {
	GetServerConn() (*BasicConn, error)
	GetClientConn() (*BasicConn, error)
}

type BasicConn

type BasicConn struct {
	net.PacketConn
	UDPConn *net.UDPConn
	// contains filtered or unexported fields
}

func NewBasicConn

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

func (*BasicConn) Close

func (c *BasicConn) Close() error

func (*BasicConn) GetContext

func (c *BasicConn) GetContext() context.Context

func (*BasicConn) LocalAddr

func (c *BasicConn) LocalAddr() net.Addr

func (*BasicConn) ReadFrom

func (c *BasicConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)

func (*BasicConn) SetReadBuffer

func (c *BasicConn) SetReadBuffer(bytes int) error

func (*BasicConn) SetReadDeadline

func (c *BasicConn) SetReadDeadline(t time.Time) error

func (*BasicConn) SetWriteBuffer

func (c *BasicConn) SetWriteBuffer(bytes int) error

func (*BasicConn) WaitClose

func (c *BasicConn) WaitClose()

func (*BasicConn) WriteTo

func (c *BasicConn) WriteTo(ps []byte, rAddr net.Addr) (n int, err 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)