merge

type Conflict struct {
	Key            string   // Ключ строки
	ExistingRow    []string // Существующая строка
	ConflictingRow []string // Конфликтующая строка
	Resolution     string   // Как был разрешён: "kept_existing", "used_new"
}

type MergeOptions struct {
	// Strategy - стратегия объединения
	Strategy MergeStrategy

	// KeyFields - поля для идентификации строк (по умолчанию primary key)
	KeyFields []string

	// ConflictResolver - функция для разрешения конфликтов (опционально)
	// Возвращает true если оставляем newRow, false если оставляем existingRow
	ConflictResolver func(existingRow, newRow []string, schema packet.Schema) bool
}

type MergeResult struct {
	Packet    *packet.DataPacket // Результирующий пакет
	Stats     MergeStats         // Статистика
	Conflicts []Conflict         // Обнаруженные конфликты
}

type MergeStats struct {
	TotalPackets   int // Количество объединённых пакетов
	TotalRowsIn    int // Всего строк на входе
	TotalRowsOut   int // Строк в результате
	Duplicates     int // Дубликаты (удалено при дедупликации)
	ConflictsCount int // Конфликты (разрешено)
}

type MergeStrategy int

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