Skip to main content

Options

Struct Options 

Source
pub struct Options { /* private fields */ }
Expand description

Managed payload storage and output limits. Neither bounds native allocations or queue bookkeeping.

Implementations§

Source§

impl Options

Source

pub fn new(storage: StorageBudget, max_output_bytes: u64) -> Self

Row buffers and compressed staging share this admission pool. Zero output allowance is a real limit; it is not an unlimited sentinel.

Source

pub fn with_disk_staging( self, file: File, replay_bytes: NonZeroUsize, ) -> Result<Self>

Stage finish-first output in an owned private scratch file at its end. Existing prefixes are preserved. The output limit also caps disk payload. Replay admits at most replay_bytes from the shared storage budget. Spool writes may block with native state alive. The caller owns path, permissions and deletion; aliases/external mutation are unsupported. No fallback, file creation or deletion occurs. Live selection ignores the scratch file and writes directly to the final destination.

Source

pub fn with_raw_disk_staging(self, file: File, max_bytes: u64) -> Result<Self>

Offer a distinct owned scratch file for raw replay, never the compressed output spool. Starts at the file end and preserves its prefix. The caller owns path, permissions and deletion and must not alias this with output. Raw disk bytes are capped separately; RAM digests use the storage budget. Replay is hash-verified, not an exact private immutable snapshot.

Source

pub fn with_batch_rows(self, rows: NonZeroU32) -> Self

Maximum rows per push for a Rows plan. Replay strips are native-owned and follow the native encoder’s requests; this does not bound their size.

Source

pub fn with_policy_set(self, preset: PolicySet) -> Self

👎Deprecated:

Pass PolicySet or BoundPolicy as the operation policy argument

Built-in policy used when the supplied callback returns UsePreset. During migration, these requirements and the policy argument both apply. A bound policy supplies preferences in place of these.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.