Crate uni_bulk 

High-throughput bulk ingestion engine for uni-db.

This crate provides the standalone write path that powers uni_db::Transaction::bulk_writer() and appender():

• BulkWriter / BulkWriterBuilder — buffered, index-deferred bulk loading of vertices and edges with constraint validation, automatic checkpointing, async or blocking index rebuild, and version-based abort/rollback.
• StreamingAppender / AppenderBuilder — an ergonomic row-by-row append API for a single label, layered over BulkWriter.

The engine takes its storage/schema/writer handles via BulkBackend, a plain dependency-injection bundle constructed by the uni-db driver. No trait indirection is used on the hot batch-write path.

The shutdown coordinator (uni_plugin_host::shutdown::ShutdownHandle) lives in uni-plugin-host; the async index-rebuild path subscribes to it via BulkBackend::shutdown.

Re-exports

pub use appender::AppenderBuilder;

pub use appender::StreamingAppender;

pub use bulk::BulkBackend;

pub use bulk::BulkConfig;

pub use bulk::BulkPhase;

pub use bulk::BulkProgress;

pub use bulk::BulkStats;

pub use bulk::BulkWriter;

pub use bulk::BulkWriterBuilder;

pub use bulk::EdgeData;

pub use bulk::IntoArrow;

pub use bulk::record_batch_to_property_maps;

Modules

appender

Streaming appender — row-by-row data loading for a single label.

bulk

Bulk loading API for high-throughput data ingestion.