Struct Runtime 

pub struct Runtime { /* private fields */ }

Implementations

impl Runtime

pub fn builder( run_id: RunId, protocol_limits: ProtocolLimits, runtime_limits: RuntimeLimits, ) -> Result<RuntimeBuilder, RuntimeError>

pub fn client(&self) -> RuntimeClient

pub fn local_id(&self) -> LocalityId

pub fn localities(&self) -> &[LocalityId]

pub fn state(&self) -> RuntimeState

pub fn spawn_on<A: Action>( &self, place: Place, action: A, ) -> Result<RemoteFuture<A::Output>, RuntimeError>

pub fn spawn_on_with<A: Action>( &self, place: Place, action: A, options: SpawnOptions, ) -> Result<RemoteFuture<A::Output>, RuntimeError>

pub fn create_at<T: DistributedObject>( &self, place: Place, state: T, ) -> Result<CreateFuture<T>, RuntimeError>

Creates a pinned object at an exact logical place.

Errors

Returns a typed registry, placement, codec, resource, transport, or shutdown error before retaining an unowned object.

pub fn create_rooted_at<T: DistributedObject>( &self, place: Place, state: T, ) -> Result<RootedCreateFuture<T>, RuntimeError>

Creates an exact pinned object and one runtime-owned root.

Errors

Returns a typed registry, placement, codec, resource, transport, or shutdown error before retaining an unowned root.

pub fn spawn_colocated<T: DistributedObject, A: Action>( &self, remote: &Remote<T>, action: A, ) -> Result<ColocatedFuture<A::Output>, RuntimeError>

Spawns an independent action at an object’s pinned location.

Errors

Returns a typed resolver, placement-ticket, queue, transport, codec, or shutdown error.

pub fn clear_object_resolver(&self)

pub fn migrate<T: MobileObject>( &self, remote: &Remote<T>, destination: Place, ) -> Result<MigrationFuture<T>, RuntimeError>

Starts explicit migration to an exact logical place.

Errors

Returns typed placement, mobility, snapshot, resource, transport, rollback, post-commit, or shutdown errors.

pub fn progress( &mut self, max_events: usize, ) -> Result<RuntimeProgress, RuntimeError>

pub fn block_on<F, T, E>(&mut self, future: F) -> Result<T, E>

where F: Future<Output = Result<T, E>>, E: From<RuntimeError>,

pub fn stats(&self) -> RuntimeStats

pub fn shutdown(&mut self) -> Result<ShutdownReport, RuntimeError>

impl Runtime

pub fn scope<R>( &mut self, function: impl for<'scope> FnOnce(&'scope RuntimeScope<'_>) -> Result<R, RuntimeError>, ) -> Result<R, RuntimeError>

Trait Implementations

impl Debug for Runtime

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

Formats the value using the given formatter.

impl Drop for Runtime

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.