Struct SyncManager 

pub struct SyncManager { /* private fields */ }

Implementations

impl SyncManager

pub fn rebuild_progress( &self, _space_id: u64, _tag_name: &str, _field_name: &str, ) -> Option<RebuildProgress>

No rebuild engines are compiled in, so no progress can exist.

pub async fn recover_stale_rebuilds(&self) -> Result<usize, SyncError>

Fail non-terminal rebuild generations stranded by crashed attempts for every configured target, and collect fulltext rebuild scratch state. Idempotent; safe to run at startup before serving traffic. Missing targets count as zero instead of failing startup.

pub fn recover_stale_rebuilds_sync(&self) -> Result<usize, SyncError>

Sync wrapper around SyncManager::recover_stale_rebuilds for startup paths without an async context.

pub fn get_dead_letter_entries(&self) -> Vec<DeadLetterEntry>

pub fn get_unrecovered_entries(&self) -> Vec<DeadLetterEntry>

pub fn get_old_dead_letter_entries(&self, age: Duration) -> Vec<DeadLetterEntry>

pub fn remove_dead_letter_entry(&self, index: usize) -> Option<DeadLetterEntry>

pub fn get_dlq_size(&self) -> usize

pub fn get_unrecovered_dlq_size(&self) -> usize

impl SyncManager

pub fn retry_outbox_sync(&self) -> Result<usize, SyncError>

impl SyncManager

pub fn on_vertex_change_with_txn( &self, txn_id: TransactionId, space_id: u64, tag_name: &str, vertex_id: &Value, properties: &[(Arc<str>, Value)], change_type: ChangeType, ) -> Result<(), SyncError>

pub fn on_index_create( &self, txn_id: TransactionId, request: IndexCreateRequest, ) -> Result<(), SyncError>

pub fn on_index_drop( &self, txn_id: TransactionId, space_id: u64, index_name: &str, schema_name: &str, index_type: &str, fields: &[String], ) -> Result<(), SyncError>

pub fn on_space_drop( &self, txn_id: TransactionId, space_id: u64, ) -> Result<(), SyncError>

pub fn on_tag_drop( &self, txn_id: TransactionId, space_id: u64, tag_name: &str, ) -> Result<(), SyncError>

pub fn on_edge_insert( &self, txn_id: TransactionId, space_id: u64, edge: &Edge, ) -> Result<(), SyncError>

pub fn on_edge_delete( &self, txn_id: TransactionId, space_id: u64, src: &Value, dst: &Value, edge_type: &str, ranking: i64, ) -> Result<(), SyncError>

pub fn on_edge_update( &self, _txn_id: TransactionId, _space_id: u64, _edge: EdgeRef<'_>, _props: EdgeProps<'_>, ) -> Result<(), SyncError>

impl SyncManager

pub fn clear_transaction_intents(&self, txn_id: TransactionId)

pub fn attach_transaction_context( &self, txn_id: TransactionId, ) -> TransactionContextInfo

pub fn rollback_transaction_to_sequence_sync( &self, txn_id: TransactionId, sequence: u64, ) -> Result<(), SyncError>

pub async fn rollback_transaction( &self, txn_id: TransactionId, ) -> Result<(), SyncError>

pub fn rollback_transaction_sync( &self, txn_id: TransactionId, ) -> Result<(), SyncError>

pub fn pending_transaction_intents( &self, txn_id: TransactionId, ) -> Result<Vec<OutboxIntent>, SyncError>

pub fn pending_transaction_intent_sequence(&self, txn_id: TransactionId) -> u64

Return the last staged intent sequence for a transaction.

Savepoints retain intents whose sequence is less than or equal to the saved boundary, so an empty transaction maps to boundary zero.

pub fn materialize_committed_transaction( &self, txn_id: TransactionId, commit_lsn: CommitLsn, intents: &[OutboxIntent], ) -> Result<(), SyncError>

pub fn outbox_materialized_lsn(&self) -> Result<Option<CommitLsn>, SyncError>

Return the durable projection frontier used as the lower bound for committed-WAL replay after an outbox restore.

impl SyncManager

pub fn new_without_fulltext() -> Self

pub fn with_dead_letter_queue( self, dead_letter_queue: Arc<DeadLetterQueue>, ) -> Self

pub fn with_stats_manager(self, stats_manager: Arc<StatsManager>) -> Self

pub fn set_stats_manager(&mut self, stats_manager: Arc<StatsManager>)

pub async fn start(&self) -> Result<(), SyncError>

pub async fn stop(&self)

pub fn is_running(&self) -> bool

impl SyncManager

pub fn configure_outbox( &mut self, path: impl AsRef<Path>, ) -> Result<(), SyncError>

pub fn configure_outbox_consumer(&mut self, config: OutboxConsumerConfig)

pub fn configure_backpressure(&mut self, config: OutboxBackpressureConfig)

Override the backpressure limits (defaults: 10k per txn, 100k total).

pub fn staged_pending_len(&self) -> usize

Current in-memory staged intent count across all transactions.

pub fn outbox_pending(&self) -> usize

Expose the current durable + staged pending depth for storage-layer flow control. Returns 0 when no outbox is configured.

pub fn outbox_stats(&self) -> OutboxStats

pub fn sync_diagnostics(&self) -> Result<SyncDiagnostics, SyncError>

Return durable outbox delivery and index-generation diagnostics.

pub fn create_outbox_snapshot( &self, destination: impl AsRef<Path>, ) -> Result<OutboxSnapshot, SyncError>

Create a crash-safe immutable snapshot of the SQLite projection.

pub fn wait_for_minimum_lsn( &self, target: &TargetId, index_id: u64, generation: u64, minimum_lsn: CommitLsn, timeout_ms: u64, ) -> Result<bool, SyncError>

pub fn create_checkpoint_outbox_snapshot( &self, ) -> Result<OutboxSnapshot, SyncError>

pub fn verify_outbox_snapshot( snapshot: &OutboxSnapshot, ) -> Result<(), SyncError>

pub fn requeue_dead_letter(&self, event_id: i64) -> Result<bool, SyncError>

pub fn requeue_dead_letters_batch( &self, target: Option<&TargetId>, index_id: Option<u64>, generation: Option<u64>, limit: usize, ) -> Result<usize, SyncError>

pub fn list_dead_letters( &self, target: Option<&TargetId>, index_id: Option<u64>, generation: Option<u64>, limit: usize, offset: usize, ) -> Result<Vec<DeadLetterRow>, SyncError>

pub fn list_degraded_ranges( &self, target: Option<&TargetId>, index_id: Option<u64>, generation: Option<u64>, ) -> Result<Vec<DegradedRangeRow>, SyncError>

pub fn clear_degraded_range( &self, target: &TargetId, index_id: u64, generation: u64, start_lsn: CommitLsn, end_lsn: CommitLsn, ) -> Result<bool, SyncError>

pub fn retention_lsn(&self) -> Result<CommitLsn, SyncError>

pub fn update_retention_lsn( &self, retention_lsn: CommitLsn, ) -> Result<(), SyncError>

pub fn prune_applied_events( &self, retention_lsn: CommitLsn, ) -> Result<u64, SyncError>

pub fn archive_dead_letters( &self, retention_lsn: CommitLsn, ) -> Result<u64, SyncError>

pub fn prune_degraded_ranges(&self, max_age_ms: u64) -> Result<u64, SyncError>

pub fn run_retention_once( &self, grace_lsn_distance: u64, max_age_ms: u64, ) -> Result<(u64, u64, u64), SyncError>

Run one retention cycle: prune applied, archive dead letters, update retention watermark.

Trait Implementations

impl Clone for SyncManager

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SyncManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.