sockloop

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

type ClientLoop struct {
	*BaseLoop
	// contains filtered or unexported fields
}

type ClientLoopConfig struct {
	// BaseConfig is the base loop configuration
	BaseConfig *LoopConfig

	// DNSTimeout is the timeout for DNS queries
	DNSTimeout time.Duration

	// PollInterval is the interval between poll messages
	PollInterval time.Duration

	// MaxRetries is the maximum number of retries for failed queries
	MaxRetries int

	// EnableMultipath enables sending to multiple resolvers
	EnableMultipath bool
}

type ClientLoopStats struct {
	// Base stats
	LoopStats

	// Query stats
	QueriesSent       uint64
	ResponsesReceived uint64
	Timeouts          uint64
	Retries           uint64

	// Resolver stats
	ResolverCount int
}

type LoopConfig struct {
	// BatchSize is the maximum number of packets to process in a batch
	BatchSize int

	// ReceiveTimeout is the timeout for receive operations
	ReceiveTimeout time.Duration

	// SendTimeout is the timeout for send operations
	SendTimeout time.Duration

	// BufferSize is the size of packet buffers
	BufferSize int

	// EnableGSO enables Generic Segmentation Offload
	EnableGSO bool

	// MaxGSOSegments is the maximum number of GSO segments
	MaxGSOSegments int
}

type LoopState int32

type LoopStats struct {
	// Packets received
	PacketsReceived uint64

	// Packets sent
	PacketsSent uint64

	// Bytes received
	BytesReceived uint64

	// Bytes sent
	BytesSent uint64

	// Receive errors
	ReceiveErrors uint64

	// Send errors
	SendErrors uint64

	// Encode errors
	EncodeErrors uint64

	// Decode errors
	DecodeErrors uint64

	// Handler errors
	HandlerErrors uint64
}

type Packet struct {
	// Data is the packet data
	Data []byte

	// PeerAddr is the remote address
	PeerAddr *net.UDPAddr

	// LocalAddr is the local address (for server)
	LocalAddr *net.UDPAddr

	// PathID identifies the path for multipath
	PathID int

	// Timestamp is when the packet was received/created
	Timestamp time.Time

	// IsPoll indicates if this is a poll packet
	IsPoll bool

	// MessageID is the DNS message ID
	MessageID uint16
}

type PacketDecoder interface {
	// Decode decodes a DNS packet into data
	Decode(packet []byte) ([]byte, error)
}

type PacketEncoder interface {
	// Encode encodes data into a DNS packet
	Encode(data []byte) ([]byte, uint16, error)
}

type PacketHandler interface {
	// HandlePacket processes a received packet
	// Returns response data to send, or nil if no response
	HandlePacket(ctx context.Context, packet *Packet) ([]byte, error)
}

type PacketHandlerFunc func(ctx context.Context, packet *Packet) ([]byte, error)

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

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

type ResolverInfo struct {
	// ID is the resolver identifier
	ID int

	// Addr is the resolver address
	Addr *net.UDPAddr

	// Conn is the UDP connection to the resolver
	Conn *net.UDPConn

	// RTT is the estimated round-trip time
	RTT time.Duration

	// Available indicates if the resolver is available
	Available bool

	// LastResponse is the time of the last response
	LastResponse time.Time

	// Stats
	QueriesSent   uint64
	ResponsesRecv uint64
	Timeouts      uint64
	Errors        uint64
}

type ServerLoop struct {
	*BaseLoop
	// contains filtered or unexported fields
}

type ServerLoopConfig struct {
	// BaseConfig is the base loop configuration
	BaseConfig *LoopConfig

	// ListenAddr is the address to listen on
	ListenAddr string

	// Domain is the domain for DNS queries
	Domain string

	// ResponseTimeout is the timeout for generating responses
	ResponseTimeout time.Duration
}

type ServerLoopStats struct {
	// Base stats
	LoopStats

	// Query stats
	QueriesReceived    uint64
	ResponsesSent      uint64
	ErrorResponsesSent uint64
}