Удален ненужный модуль
This commit is contained in:
		
							parent
							
								
									52729973a2
								
							
						
					
					
						commit
						46138c032a
					
				
					 3 changed files with 9 additions and 13 deletions
				
			
		| 
						 | 
					@ -92,7 +92,7 @@ public:
 | 
				
			||||||
		blob.zstd = _zstd;
 | 
							blob.zstd = _zstd;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
		// Разбить на фрагменты
 | 
							// Разбить на фрагменты
 | 
				
			||||||
		auto chunks = _cdc.split(data);
 | 
							Chunk[] chunks = _cdc.split(data);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
		// Запись фрагментов в БД
 | 
							// Запись фрагментов в БД
 | 
				
			||||||
		foreach (chunk; chunks)
 | 
							foreach (chunk; chunks)
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -1,9 +1,15 @@
 | 
				
			||||||
module cdcdb.cdc.core;
 | 
					module cdcdb.cdc.core;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
import cdcdb.cdc.types;
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
import std.digest.sha : SHA256, digest;
 | 
					import std.digest.sha : SHA256, digest;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					struct Chunk
 | 
				
			||||||
 | 
					{
 | 
				
			||||||
 | 
						size_t index; // 1..N
 | 
				
			||||||
 | 
						size_t offset; // смещение в исходном буфере
 | 
				
			||||||
 | 
						size_t size; // размер чанка
 | 
				
			||||||
 | 
						immutable(ubyte)[32] sha256; // hex(SHA-256) содержимого
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Change Data Capture (Захват изменения данных)
 | 
					// Change Data Capture (Захват изменения данных)
 | 
				
			||||||
final class CDC
 | 
					final class CDC
 | 
				
			||||||
{
 | 
					{
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -1,10 +0,0 @@
 | 
				
			||||||
module cdcdb.cdc.types;
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// Единица разбиения
 | 
					 | 
				
			||||||
struct Chunk
 | 
					 | 
				
			||||||
{
 | 
					 | 
				
			||||||
	size_t index; // 1..N
 | 
					 | 
				
			||||||
	size_t offset; // смещение в исходном буфере
 | 
					 | 
				
			||||||
	size_t size; // размер чанка
 | 
					 | 
				
			||||||
	immutable(ubyte)[32] sha256; // hex(SHA-256) содержимого
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue