Struct Executor 

pub struct Executor { /* private fields */ }

Executor for remote operations guarded by a global bulkhead.

Implementations

impl Executor

pub fn from_pragma_remote_max_in_flight( remote_max_in_flight: usize, ) -> Result<Self>

Build executor from PRAGMA fsqlite.remote_max_in_flight.

0 means “auto” and resolves to the conservative balanced default.

Errors

Returns FrankenError::OutOfRange when remote_max_in_flight is non-zero but invalid.

pub fn with_max_in_flight(max_in_flight: usize) -> Result<Self>

Create with explicit in-flight limit.

Errors

Returns FrankenError::OutOfRange if max_in_flight == 0.

pub fn balanced_default() -> Self

pub const fn name(&self) -> &'static str

pub const fn max_in_flight(&self) -> usize

pub const fn max_queue(&self) -> usize

pub fn snapshot(&self) -> AdmissionSnapshot

pub fn execute<Caps, F>( &self, cx: &Cx<Caps>, remote_cap: Option<RemoteCap>, registry: &ComputationRegistry, computation: &NamedComputation, trace: &TraceContext, operation: F, ) -> Result<Vec<u8>>

where Caps: SubsetOf<All> + HasRemote, F: FnOnce() -> Result<Vec<u8>>,

Execute a named remote computation through the global remote bulkhead.

Errors

Returns:

• FrankenError::Internal when remote_cap is absent,
• FrankenError::Unsupported for unregistered computations,
• FrankenError::Busy when the remote bulkhead is saturated,
• or any error from operation.

Trait Implementations

impl Debug for Executor

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

Formats the value using the given formatter.