Bound import memory with staged streaming

1 files changed, 7 insertions, 6 deletions

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);