Skip to main content

molframe_core/execution/
mod.rs

1//! Bounded execution contracts for streaming and out-of-core work.
2//!
3//! Producers are pulled one batch at a time. Each pull carries explicit row and
4//! byte demand, while retained memory is charged to a shared budget through an
5//! RAII reservation. This keeps live workspace proportional to concurrent batch
6//! demand rather than total input size. Cancellation and storage policy travel
7//! in the same cheap-to-clone context.
8
9pub(crate) mod admission;
10mod batch;
11mod cancellation;
12mod context;
13mod memory;
14mod retained;
15pub(crate) mod spill;
16mod storage;
17pub use retained::Retained;
18
19pub use batch::BatchBufferPool;
20pub use batch::{Backpressure, Batch, BatchDemand, BatchLease, BatchSource};
21pub use cancellation::{CancellationToken, Cancelled};
22pub use context::{ContextError, ExecutionContext, ExecutionContextBuilder};
23pub use memory::{DEFAULT_MEMORY_BUDGET_BYTES, MemoryBudget, MemoryBudgetError, MemoryReservation};
24pub use spill::{SpillArtifact, SpillError, SpillFile, SpillReader};
25pub use storage::{ScratchPolicy, TempStoragePolicy};