client

type CallbackEvent struct {
	// Type is the type of callback event
	Type CallbackType

	// StreamID is the QUIC stream ID (if applicable)
	StreamID int64

	// PathID is the path ID (if applicable)
	PathID int

	// Data is the event data (if applicable)
	Data []byte

	// Error is the error (if applicable)
	Error error

	// Context provides additional context
	Context context.Context
}

type CallbackHandler func(event *CallbackEvent)

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

type CallbackType int

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

type ClientCallbacks struct {
	// OnConnected is called when the QUIC connection is established
	OnConnected func()

	// OnConnectionClosed is called when the QUIC connection is closed
	OnConnectionClosed func(error)

	// OnStreamData is called when data is received on a stream
	OnStreamData func(streamID int64, data []byte)

	// OnStreamOpened is called when a new stream is opened
	OnStreamOpened func(streamID int64)

	// OnStreamClosed is called when a stream is closed
	OnStreamClosed func(streamID int64)

	// OnStreamReset is called when a stream is reset by the server
	OnStreamReset func(streamID int64, errorCode uint64)

	// OnPollResponse is called when a poll response is received
	OnPollResponse func(pathID int, data []byte)

	// OnPathAdded is called when a new path is added
	OnPathAdded func(pathID int)

	// OnPathRemoved is called when a path is removed
	OnPathRemoved func(pathID int)

	// OnError is called when an error occurs
	OnError func(error)
}

type ClientState int32

type ClientStats struct {
	// Connection stats
	ConnectionAttempts uint64
	ConnectionFailures uint64
	ConnectionTime     time.Time

	// Data stats
	BytesSent         uint64
	BytesReceived     uint64
	QueriesSent       uint64
	ResponsesReceived uint64

	// Stream stats
	StreamsOpened uint64
	StreamsClosed uint64

	// Error stats
	Errors uint64
}

type Config struct {
	// ListenPort is the TCP port to listen on for incoming connections
	// Default: 5201
	ListenPort int

	// ListenAddr is the address to bind the TCP listener to
	// Default: "127.0.0.1" (localhost only)
	ListenAddr string

	// Resolvers is the list of DNS resolver addresses
	// At least one resolver is required
	Resolvers []string

	// Domain is the base domain used for DNS tunneling
	Domain string

	// CongestionControl specifies the congestion control algorithm
	// Default: BBR
	CongestionControl CongestionControlAlgorithm

	// EnableGSO enables Generic Segmentation Offload
	// Default: false
	EnableGSO bool

	// KeepAliveInterval is the interval between keep-alive packets
	// Default: 400ms
	KeepAliveInterval time.Duration

	// ConnectTimeout is the timeout for establishing the QUIC connection
	// Default: 10s
	ConnectTimeout time.Duration

	// MaxStreams is the maximum number of concurrent TCP streams
	// Default: 100
	MaxStreams int

	// BufferSize is the buffer size for TCP connections
	// Default: 32KB
	BufferSize int

	// DNSTimeout is the timeout for DNS queries
	// Default: 2s
	DNSTimeout time.Duration

	// PollInterval is the interval between poll messages when no data
	// Default: 50ms
	PollInterval time.Duration

	// MaxRetries is the maximum number of retries for failed operations
	// Default: 3
	MaxRetries int
}

type CongestionControlAlgorithm = quic.CongestionControlAlgorithm

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

type DataQueueItem struct {
	// Stream is the source stream
	Stream *Stream

	// Data is the data to send
	Data []byte

	// Timestamp is when the item was queued
	Timestamp time.Time
}

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

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

type PathManagerConfig struct {
	// MaxPaths is the maximum number of paths
	MaxPaths int

	// Scheduler is the path selection scheduler
	Scheduler PathScheduler

	// ProbeTimeout is the timeout for path probing
	ProbeTimeout time.Duration
}

type PathScheduler interface {
	// SelectPath returns the next path ID to use, or -1 if none available
	SelectPath() int

	// AddPath adds a path to the scheduler
	AddPath(pathID int)

	// RemovePath removes a path from the scheduler
	RemovePath(pathID int)

	// UpdatePathMetrics updates metrics for a path
	UpdatePathMetrics(pathID int, rtt time.Duration, loss float64)
}

type PathState int32

type PollEvent struct {
	// Stream is the stream with data ready
	Stream *Stream

	// Data is the data read from the stream (if any)
	Data []byte

	// Error is any error that occurred
	Error error

	// IsClosed indicates the stream was closed
	IsClosed bool
}

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

type PollerConfig struct {
	// PollInterval is the interval between poll cycles for idle streams
	PollInterval time.Duration

	// ReadTimeout is the timeout for read operations
	ReadTimeout time.Duration

	// BufferSize is the size of read buffers
	BufferSize int

	// EventBufferSize is the size of the event channel buffer
	EventBufferSize int
}

type ResolverAddress struct {
	// Address is the resolver address (IP:port or hostname:port)
	Address string

	// ParsedAddr is the parsed network address
	ParsedAddr *net.UDPAddr

	// PathID is the unique identifier for this path
	PathID int
}

type ResolverPath struct {
	// ID is the unique path identifier
	ID int

	// Address is the resolver address
	Address *net.UDPAddr
	// contains filtered or unexported fields
}

type ResolverPathStats struct {
	ID               int
	Address          string
	State            PathState
	RTT              time.Duration
	QueriesSent      uint64
	ResponsesRecv    uint64
	BytesSent        uint64
	BytesRecv        uint64
	Timeouts         uint64
	Errors           uint64
	LastResponseTime time.Time
}

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

type Stream struct {
	// ID is the unique stream identifier (assigned by QUIC)
	ID int64

	// LocalID is a local identifier for tracking
	LocalID uint64

	// TCPConn is the local TCP connection from the client
	TCPConn net.Conn
	// contains filtered or unexported fields
}

type StreamCallback struct {
	// OnData is called when data is received
	OnData func([]byte)

	// OnClose is called when the stream is closed
	OnClose func()

	// OnError is called when an error occurs
	OnError func(error)
}

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

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

type StreamConfig struct {
	// BufferSize is the size of read/write buffers
	BufferSize int

	// ReadTimeout is the timeout for TCP read operations
	ReadTimeout time.Duration

	// WriteTimeout is the timeout for TCP write operations
	WriteTimeout time.Duration
}

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

type StreamManagerStats struct {
	TotalStreams   uint64
	ActiveStreams  uint64
	ClosedStreams  uint64
	TotalBytesSent uint64
	TotalBytesRecv uint64
}

type StreamState int32

type StreamStats struct {
	ID            int64
	LocalID       uint64
	State         StreamState
	CreatedAt     time.Time
	LastActivity  time.Time
	BytesReceived uint64
	BytesSent     uint64
}

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

type TCPAcceptorConfig struct {
	// ListenAddr is the address to listen on
	ListenAddr string

	// StreamConfig is the configuration for new streams
	StreamConfig *StreamConfig

	// AcceptTimeout is the timeout for accepting connections
	AcceptTimeout time.Duration
}

type TCPAcceptorStats struct {
	AcceptedCount uint64
	RejectedCount uint64
	ListenAddr    string
}

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