molframe-core 0.6.1

Core types, storage and analysis contracts for molframe
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

//! Bounded execution contracts for streaming and out-of-core work.
//!
//! Producers are pulled one batch at a time. Each pull carries explicit row and
//! byte demand, while retained memory is charged to a shared budget through an
//! RAII reservation. This keeps live workspace proportional to concurrent batch
//! demand rather than total input size. Cancellation and storage policy travel
//! in the same cheap-to-clone context.

pub(crate) mod admission;
mod batch;
mod cancellation;
mod context;
mod memory;
mod retained;
pub(crate) mod spill;
mod storage;
#[cfg(not(target_arch = "wasm32"))]
mod workspace;
pub use retained::Retained;

pub use batch::BatchBufferPool;
pub use batch::{Backpressure, Batch, BatchDemand, BatchLease, BatchSource};
pub use cancellation::{CancellationToken, Cancelled};
pub use context::{ContextError, ExecutionContext, ExecutionContextBuilder};
pub use memory::{
    DEFAULT_MEMORY_BUDGET_BYTES, MAX_AUTOMATIC_BUDGET_BYTES, MEMORY_BUDGET_ENV,
    MEMORY_BUDGET_REMEDY, MemoryBudget, MemoryBudgetError, MemoryReservation,
};
pub use spill::{SpillArtifact, SpillError, SpillFile, SpillReader};
pub use storage::{ScratchPolicy, TempStoragePolicy};
#[cfg(not(target_arch = "wasm32"))]
pub use workspace::TemporaryWorkspace;