Crate graphstream 

graphstream – journal replication engine for graph databases.

Logical WAL shipping via .hadbj segments to S3. This crate provides the replication machinery that graphd uses: journal format, writer/reader, S3 uploader, and follower sync.

graphstream is to Kuzu/graphd what walrust is to SQLite – the replication engine, not the database server.

Re-exports

pub use journal::recover_journal_state;

pub use journal::spawn_journal_writer;

pub use journal::write_recovery_state;

pub use journal::JournalCommand;

pub use journal::JournalReader;

pub use journal::JournalReaderEntry;

pub use journal::JournalSender;

pub use journal::JournalState;

pub use journal::PendingEntry;

pub use sync::download_new_segments;

pub use types::graph_value_to_param_value;

pub use types::map_entries_to_param_values;

pub use types::param_value_to_graph_value;

pub use types::param_values_to_map_entries;

pub use types::ParamValue;

pub use cache::CacheConfig;

pub use cache::CacheStats;

pub use cache::CleanupStats;

pub use cache::SegmentCache;

pub use metrics::GraphstreamMetrics;

pub use uploader::run_background_compaction;

pub use uploader::spawn_journal_uploader;

pub use uploader::spawn_journal_uploader_with_cache;

pub use uploader::spawn_journal_uploader_with_retry;

pub use uploader::spawn_uploader;

pub use uploader::CompactionConfig;

pub use uploader::ObjectStoreStorage;

pub use uploader::SegmentStorage;

pub use uploader::SegmentUploadHandler;

pub use uploader::Uploader;

Modules

cache

Disk-based segment cache for tracking upload state.

format

Thin bridge to hadb-changeset’s journal format.

graphd

journal

Journal writer and reader for graphd’s write-ahead journal.

metrics

Prometheus-compatible metrics for graphstream.

sync

Follower sync: download new journal segments from object storage.

types

Typed parameter values for journal entries and query binding.

uploader

Concurrent uploader for sealed journal segments.

Structs

RetryConfig

Configuration for retry behavior.

RetryPolicy

Retry policy with exponential backoff.

UploaderStats

Upload statistics.

Enums

UploadMessage

Message sent to the uploader task.

Functions

current_timestamp_ms

Current timestamp in epoch milliseconds.