scan

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

type ICMPSweeperOption func(*ICMPSweeper)

type IPv4Hdr struct {
	IHL      uint8
	Protocol uint8
	SrcIP    net.IP
	DstIP    net.IP
}

type Mmsghdr struct {
	Hdr    unix.Msghdr
	MsgLen uint32
	// contains filtered or unexported fields
}

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

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

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

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

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

type ResultProcessor interface {
	// Process takes a Result and updates internal state
	Process(result *models.Result) error
	// GetSummary returns the current summary of all processed results
	GetSummary() (*models.SweepSummary, error)
	// Reset clears the processor's state
	Reset()
}

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

type SYNScannerOptions struct {
	// SendBatchSize is the number of packets to send per sendmmsg call
	// If 0, defaults to defaultSendBatchSize or SENDMMSG_BATCH_SIZE env var
	SendBatchSize int
	// RateLimit is the packets per second limit
	// If 0, a safe default will be calculated based on port window and timeout
	RateLimit int
	// RateLimitBurst is the burst size for rate limiting
	// If 0, defaults to RateLimit
	RateLimitBurst int
	// RouteDiscoveryHost is the target address for local IP discovery
	// If empty, defaults to "8.8.8.8:80"
	RouteDiscoveryHost string

	// Ring buffer tuning options for memory vs latency tradeoffs
	// RingBlockSize is the size of each ring buffer block in bytes
	// If 0, defaults to defaultBlockSize (1 MiB)
	RingBlockSize uint32
	// RingBlockCount is the number of blocks in the ring buffer
	// If 0, defaults to defaultBlockCount (8 blocks = 8 MiB total)
	RingBlockCount uint32
	// RingFrameSize is the frame size hint for packet alignment
	// If 0, defaults to defaultFrameSize (2048 bytes)
	RingFrameSize uint32

	// Interface specifies which network interface to use for scanning
	// If empty, the interface will be auto-detected based on routing table
	// Examples: "eth0", "wlan0", "enp0s3"
	// Useful for multi-homed hosts or container environments
	Interface string

	// NAT/Firewall options for advanced environments
	// SuppressRSTReply can be set to true to avoid generating RST packets
	// This helps in environments where firewall rules might interfere
	// Note: This is optional and most environments don't need it
	SuppressRSTReply bool

	// GlobalRingMemoryMB is the total memory cap (in MB) for all ring buffers
	// across all CPU cores. If 0, defaults to 64MB total. This prevents
	// excessive memory usage on high-CPU systems by distributing the cap.
	GlobalRingMemoryMB int

	// RingReaders limits the number of AF_PACKET ring readers (and rings).
	// If 0, defaults to min(4, runtime.NumCPU()). More readers can increase
	// wakeups on low-reply scans without benefit.
	RingReaders int

	// RingPollTimeoutMs sets the poll() timeout in milliseconds for ring readers.
	// If 0, defaults to max(TPACKET_RETIRE_TOV_MS, 50). Raising this reduces
	// wakeups when traffic is sparse, cutting CPU in listenForReplies.
	RingPollTimeoutMs int
}

type Scanner interface {
	// Scan performs the sweep and returns results through the channel
	Scan(context.Context, []models.Target) (<-chan models.Result, error)
	// Stop gracefully stops any ongoing scans
	Stop() error
}

type ScannerStats struct {
	// Packet statistics
	PacketsSent    uint64 // Total SYN packets sent
	PacketsRecv    uint64 // Total packets received (SYN-ACK, RST, etc.)
	PacketsDropped uint64 // Packets dropped by kernel (ring buffer full)

	// Ring buffer statistics
	RingBlocksProcessed uint64 // TPACKET_V3 blocks processed
	RingBlocksDropped   uint64 // TPACKET_V3 blocks lost due to buffer overruns (TP_STATUS_LOSING)

	// Retry statistics
	RetriesAttempted  uint64 // Number of retry attempts made
	RetriesSuccessful uint64 // Number of successful retries

	// Port allocation statistics
	PortsAllocated uint64 // Total port allocations
	PortsReleased  uint64 // Total port releases
	PortExhaustion uint64 // Number of times port allocator was exhausted

	// Rate limiting statistics
	RateLimitDeferrals uint64 // Packet send operations deferred due to rate limiting

	// Timing statistics (in nanoseconds, for precision)
	LastStatsReset int64 // Timestamp of last stats reset (UnixNano)
}

type StatsProvider interface {
	// GetStats returns a snapshot of scanner performance statistics
	GetStats() ScannerStats
}

type TCPHdr struct {
	SrcPort uint16
	DstPort uint16
	Seq     uint32
	Ack     uint32
	Flags   uint8
}

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