From 61fa05ec0c4510f1cd437b5d672cd6fd7b996353 Mon Sep 17 00:00:00 2001 From: tanaka takashi Date: Sat, 4 Jul 2026 18:58:06 +0900 Subject: Bound import memory with staged streaming --- src/storage/store.h | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) (limited to 'src/storage/store.h') diff --git a/src/storage/store.h b/src/storage/store.h index 9efb02a..78c8cbe 100644 --- a/src/storage/store.h +++ b/src/storage/store.h @@ -26,6 +26,7 @@ typedef struct tiny_store_entry } tiny_store_entry_t; typedef struct tiny_store tiny_store_t; +typedef struct tiny_import_transaction tiny_import_transaction_t; typedef struct tiny_rebuild_report { @@ -94,12 +95,12 @@ typedef struct tiny_import_record } tiny_import_record_t; tiny_store_status_t tiny_store_rebuild(tiny_store_t *store, tiny_rebuild_report_t *report); -tiny_store_status_t tiny_store_import(tiny_store_t *store, - const tiny_import_record_t *records, - size_t record_count, - tiny_import_policy_t policy, - size_t *imported_count, - size_t *rejected_count); +tiny_store_status_t tiny_store_import_begin(tiny_import_transaction_t **transaction, + const char *directory); +tiny_store_status_t tiny_store_import_append(tiny_import_transaction_t *transaction, + const tiny_import_record_t *record); +tiny_store_status_t tiny_store_import_commit(tiny_import_transaction_t *transaction); +void tiny_store_import_abort(tiny_import_transaction_t *transaction); void tiny_store_health(const tiny_store_t *store, tiny_store_health_t *health); size_t tiny_store_entry_count(const tiny_store_t *store); -- cgit v1.2.3