Skip to main content

Crate fsqlite_core

Crate fsqlite_core 

Source
Expand description

Core bounded-parallelism primitives (§1.5, bd-22n.4).

This module provides a small bulkhead framework for internal background work. It is intentionally non-blocking: overflow is rejected with SQLITE_BUSY (FrankenError::Busy) instead of queue-and-wait semantics.

Modules§

attach
ATTACH/DETACH database schema registry (§12.11, bd-7pxb).
commit_marker
Commit Marker Stream Format (§3.5.4 + §3.5.4.1, bd-1hi.23).
commit_repair
Commit durability and asynchronous repair orchestration (§1.6, bd-22n.11).
compat_persist
Compat persistence: read/write real SQLite-format database files.
connection
SQL connection API with pager/WAL/B-tree storage wiring on the default path.
db_fec
.db-fec sidecar — erasure-coded page storage for on-the-fly repair (§3.4.6, bd-1hi.18).
decode_proofs
§3.5.8 Decode Proofs (Auditable Repair) + §3.5.9 Deterministic Encoding.
ecs_replication
ECS-native replication architecture (§3.4.7, bd-1hi.19).
epoch
Epoch clock, key derivation, and epoch transition barrier (§4.18, bd-3go.12).
explain
EXPLAIN and EXPLAIN QUERY PLAN execution (§12.12, bd-7pxb).
inter_object_coding
Inter-object coding groups for replication catch-up (§3.5.6, bd-1hi.26).
lrc
Local Reconstruction Codes (§1.4) for distributed repair.
native_index
Native index lookup, repair, and deterministic segment construction (§3.6.4-§3.6.7).
permeation_map
§3.5.7 RaptorQ permeation map audit (bd-1hi.27).
por
Proofs of Retrievability (PoR) — cryptographic storage audit (§11.11, bd-3bw.4).
raptorq_codec
Production SymbolCodec implementation backed by asupersync RaptorQ (bd-3sj9w).
raptorq_integration
§3.3 Asupersync RaptorQ Pipeline Integration (bd-1hi.5).
region
Structured concurrency region tree (§4.11, bd-3go.9).
remote_effects
Remote effects contract primitives (§4.19.1-§4.19.5, bd-numl).
repair_engine
§3.5 Unified RaptorQ Decode/Repair Engine with BLAKE3 Proofs (bd-n0g4q.3).
repair_symbols
§3.5.3 Deterministic Repair Symbol Generation.
replication_receiver
§3.4.2 Fountain-Coded Replication Receiver (bd-1hi.14).
replication_sender
§3.4.2 Fountain-Coded Replication Sender (bd-1hi.13).
snapshot_shipping
§3.4.3 Fountain-Coded Snapshot Shipping (bd-1hi.15).
source_block_partition
§3.1 RaptorQ Source Block Partitioning for Large Databases (bd-1hi.6).
symbol_log
Symbol Record Logs (append-only) for ECS objects (§3.5.4.2, bd-1hi.24).
symbol_size_policy
§3.5.10 Symbol Size Policy (Object-Type-Aware, Measured).
tiered_storage
Tiered storage controls for Native mode (§3.5.11, bd-1hi.29).
transaction
Transaction state machine (§12.10, bd-7pxb).
wal_adapter
Adapters bridging the WAL and pager crates at runtime.
wal_fec_adapter
WAL FEC adapter: wires the PageSymbolSink / PageSymbolSource traits to the WAL commit and read paths via the production AsupersyncCodec (bd-3sj9w).

Structs§

Bulkhead
Non-blocking bulkhead admission gate.
BulkheadConfig
Bounded parallelism configuration for a work class.
BulkheadPermit
RAII permit for a single admitted work item.
RegionBulkhead
Region-owned wrapper used for structured-concurrency integration.
WideChunkLayout
Chunking plan for SIMD-friendly wide-word loops.

Enums§

OverflowPolicy
Policy used when the bulkhead admission budget is exhausted.
ParallelismProfile
Runtime profile for conservative parallelism defaults.

Functions§

available_parallelism_or_one
Return std::thread::available_parallelism() with a safe floor of 1.
conservative_bg_cpu_max
Compute conservative default background CPU parallelism from P.
gf256_add_assign_chunked
GF(256) addition (+) using wide XOR chunk loops.
simd_friendly_checksum_pair
Compute xxhash3 + blake3 on a contiguous input buffer.
symbol_add_assign
RaptorQ symbol add (dst ^= src) using chunked XOR.
symbol_addmul_assign
RaptorQ fused multiply-add (dst ^= c * src) in GF(256).
symbol_mul_into
RaptorQ symbol scalar multiply (out = c * src) in GF(256).
xor_patch_wide_chunks
XOR patch application using u128 + u64 + tail loops.