Struct ReplicatedNativeApp 

pub struct ReplicatedNativeApp { /* private fields */ }

One native App executed as a fixed set of Plan-declared single-owner Kernel lanes.

Implementations

impl ReplicatedNativeApp

pub fn start<F>( plan: ResolvedAppPlan, adapters: F, ) -> Result<Self, ReplicatedRunnerError>

where F: Fn(&ExecutionLaneId) -> ExecutionAdapterCatalog + Send + Sync + 'static,

Starts one unmodified Kernel replica per declared Execution Lane.

pub fn start_fallible<F>( plan: ResolvedAppPlan, adapters: F, ) -> Result<Self, ReplicatedRunnerError>

where F: Fn(&ExecutionLaneId) -> Result<ExecutionAdapterCatalog, String> + Send + Sync + 'static,

Starts every declared lane with fallible lane-local Adapter assembly.

pub fn start_fallible_with_timeout<F>( plan: ResolvedAppPlan, adapters: F, ready_timeout: Duration, ) -> Result<Self, ReplicatedRunnerError>

where F: Fn(&ExecutionLaneId) -> Result<ExecutionAdapterCatalog, String> + Send + Sync + 'static,

Starts every lane and fails closed unless the complete Lane Set is Ready in time.

pub fn start_with_transfers<F>( plan: ResolvedAppPlan, adapters: F, transfers: CrossLaneRequestCatalog, ) -> Result<Self, ReplicatedRunnerError>

where F: Fn(&ExecutionLaneId) -> ExecutionAdapterCatalog + Send + Sync + 'static,

Starts replicated lanes with generated request types allowed to cross them.

pub fn start_with_transfer_catalog<F>( plan: ResolvedAppPlan, adapters: F, transfers: CrossLaneTransferCatalog, ) -> Result<Self, ReplicatedRunnerError>

where F: Fn(&ExecutionLaneId) -> ExecutionAdapterCatalog + Send + Sync + 'static,

Starts replicated lanes with generated values allowed to cross them without serialization.

pub fn start_with_fallible_transfer_catalog<F>( plan: ResolvedAppPlan, adapters: F, transfers: CrossLaneTransferCatalog, ready_timeout: Option<Duration>, ) -> Result<Self, ReplicatedRunnerError>

where F: Fn(&ExecutionLaneId) -> Result<ExecutionAdapterCatalog, String> + Send + Sync + 'static,

Starts a complete Lane Set with fallible Adapters, transfers, and one Ready deadline.

pub fn lane_count(&self) -> usize

Returns the fixed number of Kernel replicas started from the Plan.

pub fn diagnostics_snapshot(&self) -> LaneDiagnosticsSnapshot

Returns structural evidence for placement decisions without exposing payloads.

pub fn is_failed(&self) -> bool

Returns whether any Kernel lane reached a terminal failure.

pub fn terminal_failure(&self) -> Option<ReplicatedRunnerError>

Returns the first App-terminal lane failure, when one has occurred.

pub async fn wait_for_terminal(&self) -> ReplicatedRunnerError

Waits until one lane makes the replicated App terminal.

pub fn route(&self) -> ReplicatedAppRoute

Projects a cloneable route which remains pinned by its Generation Lease.

impl ReplicatedNativeApp

pub async fn invoke<C: RequestCapability>( &self, caller_instance: &str, operation: &str, request: C::Request, ) -> Result<Result<C::Response, C::DomainError>, RuntimeFailure>

where C::Request: Send, C::Response: Send, C::DomainError: Send,

Invokes one generated request Capability on its Plan-placed provider lane.

pub async fn invoke_with_options<C: RequestCapability>( &self, caller_instance: &str, operation: &str, request: C::Request, options: LaneInvocationOptions, ) -> Result<Result<C::Response, C::DomainError>, RuntimeFailure>

where C::Request: Send, C::Response: Send, C::DomainError: Send,

Invokes one generated request with Driver-relative controls.

pub async fn shutdown( self, timeout: Duration, ) -> Result<(), ReplicatedRunnerError>

Stops every Kernel replica with the same bounded shutdown timeout.

Trait Implementations

impl Debug for ReplicatedNativeApp

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

Formats the value using the given formatter.