Struct SqliteOutbox 

pub struct SqliteOutbox { /* private fields */ }

Implementations

impl SqliteOutbox

pub async fn open(path: impl AsRef<Path>) -> Result<Self, String>

pub fn pool(&self) -> &SqlitePool

pub fn path(&self) -> &Path

pub async fn create_snapshot( &self, destination: impl AsRef<Path>, ) -> Result<OutboxSnapshot, String>

Create an immutable SQLite backup at destination.

VACUUM INTO runs against a consistent SQLite snapshot and includes the WAL contents in the resulting file. The temporary file is synced before an atomic rename so a crash cannot publish a partial backup.

pub fn verify_snapshot(snapshot: &OutboxSnapshot) -> Result<(), String>

pub fn restore_snapshot( snapshot: &OutboxSnapshot, destination: impl AsRef<Path>, ) -> Result<(), String>

Restore a verified snapshot before opening the live database.

pub async fn register_target(&self, target: &TargetId) -> Result<(), String>

pub async fn create_index_generation( &self, target: &TargetId, index_id: u64, generation: u64, snapshot_lsn: CommitLsn, ) -> Result<(), String>

pub async fn transition_generation_to_backfilling( &self, target: &TargetId, index_id: u64, generation: u64, ) -> Result<(), String>

pub async fn transition_generation_to_catching_up( &self, target: &TargetId, index_id: u64, generation: u64, barrier_lsn: CommitLsn, ) -> Result<(), String>

pub async fn transition_generation_to_publishing( &self, target: &TargetId, index_id: u64, generation: u64, barrier_lsn: CommitLsn, ) -> Result<(), String>

pub async fn activate_generation( &self, target: &TargetId, index_id: u64, generation: u64, barrier_lsn: CommitLsn, ) -> Result<(), String>

pub async fn drain_generation( &self, target: &TargetId, index_id: u64, generation: u64, ) -> Result<(), String>

pub async fn drop_generation( &self, target: &TargetId, index_id: u64, generation: u64, ) -> Result<(), String>

pub async fn fail_generation( &self, target: &TargetId, index_id: u64, generation: u64, ) -> Result<(), String>

pub async fn get_generation_state( &self, target: &TargetId, index_id: u64, generation: u64, ) -> Result<Option<(String, Option<CommitLsn>)>, String>

pub async fn get_active_generation( &self, target: &TargetId, index_id: u64, ) -> Result<Option<u64>, String>

pub async fn list_index_generations( &self, target: &TargetId, index_id: u64, ) -> Result<Vec<(u64, String)>, String>

List all known generations (with states) for one index. Used by the rebuild driver to detect and fail generations left behind by crashes.

pub async fn fetch_rebuild_events( &self, target: &TargetId, index_id: u64, after_lsn: CommitLsn, upto_lsn: CommitLsn, limit: u64, ) -> Result<Vec<RebuildEvent>, String>

Fetch materialized events for catch-up replay in a commit-LSN range. Status-agnostic on purpose: retried, dead-lettered, or skipped events in the range are replayed idempotently so the rebuilt index converges even when the live delivery plane degraded mid-rebuild.

pub async fn materialize_commit( &self, commit_lsn: CommitLsn, intents: &[OutboxIntent], targets: &[TargetId], ) -> Result<(), String>

pub async fn claim_next( &self, target: &TargetId, owner: &str, now_ms: u64, lease_duration_ms: u64, ) -> Result<Option<ClaimedEvent>, String>

pub async fn acknowledge(&self, event: &ClaimedEvent) -> Result<bool, String>

pub async fn retry( &self, event: &ClaimedEvent, next_attempt_at_ms: u64, error: &str, ) -> Result<bool, String>

pub async fn dead_letter( &self, event: &ClaimedEvent, failed_at_ms: u64, error: &str, ) -> Result<bool, String>

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

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

Batch requeue dead letters filtered by target/index/generation. Returns number of events requeued.

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

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

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

pub async fn delivery_targets(&self) -> Result<Vec<TargetId>, String>

pub async fn stats(&self) -> Result<OutboxStats, String>

Return aggregate delivery statistics from the durable projection.

The in-memory transaction staging map is intentionally not used here: once a commit has crossed the WAL and SQLite materialization fences, SQLite is the source of truth for backlog, leases, retries, and dead-letter state.

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

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

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

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

Archive dead letters older than retention_lsn into dead_letters_archive and remove from events.

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

Prune degraded ranges older than max age.

pub async fn compute_safe_retention_lsn( &self, grace_lsn_distance: u64, ) -> Result<CommitLsn, String>

Compute a safe retention LSN based on min applied frontier. Safe = min(target frontiers, index frontiers) - grace, at least 0.

pub async fn retry_count(&self, event_id: i64) -> Result<u64, String>

pub async fn materialized_lsn(&self) -> Result<CommitLsn, String>

pub async fn target_frontier( &self, target: &TargetId, ) -> Result<CommitLsn, String>

pub async fn index_frontier( &self, target: &TargetId, index_id: u64, generation: u64, ) -> Result<CommitLsn, String>

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

pub async fn skip_event_degraded( &self, event: &ClaimedEvent, reason: &str, ) -> Result<bool, String>

pub async fn has_degraded_range( &self, target: &TargetId, index_id: u64, generation: u64, ) -> Result<bool, String>

pub async fn has_degraded_range_through( &self, target: &TargetId, index_id: u64, generation: u64, minimum_lsn: CommitLsn, ) -> Result<bool, String>

pub async fn dead_lettered_count( &self, target: &TargetId, ) -> Result<u64, String>

pub async fn diagnostics(&self) -> Result<SyncDiagnostics, String>

Return a single consistent view of outbox backlog, delivery frontiers, degraded ranges, and index-generation progress.

Trait Implementations

impl Clone for SqliteOutbox

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 SqliteOutbox

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

Formats the value using the given formatter.