diff --git a/source/cdcdb/cdc/cas.d b/source/cdcdb/cdc/cas.d index 0a19508..84cae33 100644 --- a/source/cdcdb/cdc/cas.d +++ b/source/cdcdb/cdc/cas.d @@ -92,7 +92,7 @@ public: blob.zstd = _zstd; // Разбить на фрагменты - auto chunks = _cdc.split(data); + Chunk[] chunks = _cdc.split(data); // Запись фрагментов в БД foreach (chunk; chunks) diff --git a/source/cdcdb/cdc/core.d b/source/cdcdb/cdc/core.d index d95f13d..84ee7ce 100644 --- a/source/cdcdb/cdc/core.d +++ b/source/cdcdb/cdc/core.d @@ -1,9 +1,15 @@ module cdcdb.cdc.core; -import cdcdb.cdc.types; - 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 (Захват изменения данных) final class CDC { diff --git a/source/cdcdb/cdc/types.d b/source/cdcdb/cdc/types.d deleted file mode 100644 index cfede4c..0000000 --- a/source/cdcdb/cdc/types.d +++ /dev/null @@ -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) содержимого -}