performance

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

type CacheItem[K comparable, V any] struct {
	Key   K
	Value V
}

type ConsoleProgressReporter struct {
	*DefaultProgressReporter
	// contains filtered or unexported fields
}

type DeduplicationStats struct {
	UniqueItems int `json:"unique_items"`
}

type Deduplicator[T any] struct {
	// contains filtered or unexported fields
}

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

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

type LRUCache[K comparable, V any] struct {
	// contains filtered or unexported fields
}

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

type MemoryOptimizedStatement struct {
	*types.Statement
	// contains filtered or unexported fields
}

type MemoryStats struct {
	MaxMemoryBytes     int64   `json:"max_memory_bytes"`
	CurrentMemoryBytes int64   `json:"current_memory_bytes"`
	SystemMemoryBytes  int64   `json:"system_memory_bytes"`
	CacheSize          int     `json:"cache_size"`
	CacheHitRate       float64 `json:"cache_hit_rate"`
}

type MigrationFile struct {
	Path     string
	Content  []byte
	Sequence int
	Size     int64
}

type PhaseInfo struct {
	StartTime  time.Time     `json:"start_time"`
	EndTime    time.Time     `json:"end_time"`
	Duration   time.Duration `json:"duration"`
	Total      int           `json:"total"`
	Current    int           `json:"current"`
	Progress   float64       `json:"progress"`
	Message    string        `json:"message"`
	Success    bool          `json:"success"`
	IsActive   bool          `json:"is_active"`
	IsComplete bool          `json:"is_complete"`
}

type ProcessedFile struct {
	OriginalFile *MigrationFile
	Migration    *types.Migration
	ProcessTime  time.Duration
	MemoryUsed   int64
	Errors       []error
}

type ProcessingPhase string

type ProcessingStats struct {
	FilesProcessed  int64   `json:"files_processed"`
	FilesSkipped    int64   `json:"files_skipped"`
	FilesErrored    int64   `json:"files_errored"`
	TotalBytes      int64   `json:"total_bytes"`
	ProcessingTime  int64   `json:"processing_time_ms"`
	PeakMemoryUsage int64   `json:"peak_memory_usage"`
	AverageFileSize int64   `json:"average_file_size"`
	ThroughputMBps  float64 `json:"throughput_mbps"`
}

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

type ProgressReporter interface {
	StartPhase(phase ProcessingPhase, total int)
	UpdateProgress(current int, message string)
	FinishPhase(phase ProcessingPhase, success bool, message string)
	SetOverallProgress(current, total int)
	AddWarning(message string)
	AddError(err error)
	GetSummary() ProgressSummary
}

type ProgressSummary struct {
	StartTime       time.Time                     `json:"start_time"`
	EndTime         time.Time                     `json:"end_time"`
	Duration        time.Duration                 `json:"duration"`
	CurrentPhase    ProcessingPhase               `json:"current_phase"`
	OverallProgress float64                       `json:"overall_progress"`
	PhaseProgress   map[ProcessingPhase]float64   `json:"phase_progress"`
	PhaseDetails    map[ProcessingPhase]PhaseInfo `json:"phase_details"`
	Warnings        []string                      `json:"warnings"`
	Errors          []string                      `json:"errors"`
	IsComplete      bool                          `json:"is_complete"`
	Success         bool                          `json:"success"`
}

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

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