quic

package

v0.3.1-rc.12 Latest Latest Go to latest Published: Nov 9, 2023 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

View Source

var MaxDatagramFrameSize int64 = 1200 - 3

func New(config *protocol.Protocol_Quic) protocol.WrapProxy

type Client struct {
	netapi.EmptyDispatch
	// contains filtered or unexported fields
}

func (c *Client) Conn(ctx context.Context, s netapi.Address) (net.Conn, error)

func (c *Client) PacketConn(ctx context.Context, host netapi.Address) (net.PacketConn, error)

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

func NewConnectionPacketConn(ctx context.Context, conn quic.Connection) *ConnectionPacketConn

func (c *ConnectionPacketConn) Receive() (uint16, []byte, net.Addr, error)

func (c *ConnectionPacketConn) Write(b []byte, id uint16, addr net.Addr) error

type Frag struct {
	SplitID atomic.Uint64
	// contains filtered or unexported fields
}

func (f *Frag) Merge(buf []byte) []byte

func (f *Frag) Split(buf []byte, maxSize int) [][]byte

type FragData struct {
	PacketID uint64
	Total    uint16
	Current  uint16
}

type MergeFrag struct {
	Count uint16
	Data  [][]byte
}

type QuicAddr struct {
	Addr net.Addr
	ID   quic.StreamID
}

func (q *QuicAddr) Network() string

func (q *QuicAddr) String() string

type Server struct {
	*quic.Listener
	// contains filtered or unexported fields
}

func NewServer(packetConn net.PacketConn, tlsConfig *tls.Config, handler netapi.Handler) (*Server, error)

func (s *Server) Accept() (net.Conn, error)

func (s *Server) Close() error