Struct Context

pub struct Context { /* private fields */ }

Implementation of crate::Spawner, crate::Clock, crate::Network, and crate::Storage for the deterministic runtime.

Implementations

impl Context

pub fn recover(self) -> (Runner, Self, Arc<Auditor>)

Recover the inner state (deadline, metrics, auditor, rng, synced storage, etc.) from the current runtime and use it to initialize a new instance of the runtime. A recovered runtime does not inherit the current runtime’s pending tasks, unsynced storage, network connections, nor its shutdown signaler.

This is useful for performing a deterministic simulation that spans multiple runtime instantiations, like simulating unclean shutdown (which involves repeatedly halting the runtime at unexpected intervals).

It is only permitted to call this method after the runtime has finished (i.e. once start returns) and only permitted to do once (otherwise multiple recovered runtimes will share the same inner state). If either one of these conditions is violated, this method will panic.

Trait Implementations

impl Clock for Context

fn current(&self) -> SystemTime

Returns the current time.

fn sleep(&self, duration: Duration) -> impl Future<Output = ()> + Send + 'static

Sleep for the given duration.

fn sleep_until( &self, deadline: SystemTime, ) -> impl Future<Output = ()> + Send + 'static

Sleep until the given deadline.

impl Clock for Context

type Instant = SystemTime

A measurement of a monotonically increasing clock.

fn now(&self) -> Self::Instant

Returns a measurement of the clock.

impl Clone for Context

fn clone(&self) -> Context

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Network<Listener, Sink, Stream> for Context

async fn bind(&self, socket: SocketAddr) -> Result<Listener, Error>

Bind to the given socket address.

async fn dial(&self, socket: SocketAddr) -> Result<(Sink, Stream), Error>

Dial the given socket address.

impl ReasonablyRealtime for Context

fn reference_point(&self) -> Self::Instant

Returns a reference point at the start of an operation.

impl RngCore for Context

fn next_u32(&mut self) -> u32

Return the next random u32.

fn next_u64(&mut self) -> u64

Return the next random u64.

fn fill_bytes(&mut self, dest: &mut [u8])

Fill dest with random data.

fn try_fill_bytes(&mut self, dest: &mut [u8]) -> Result<(), Error>

Fill dest entirely with random data.

impl Spawner for Context

fn spawn<F, T>(&self, label: &str, f: F) -> Handle<T>

where F: Future<Output = T> + Send + 'static, T: Send + 'static,

Enqueues a task to be executed.

fn stop(&self, value: i32)

Signals the runtime to stop execution and that all outstanding tasks should perform any required cleanup and exit. This method is idempotent and can be called multiple times.

fn stopped(&self) -> Signal

Returns an instance of a Signal that resolves when stop is called by any task.

impl Storage<Blob> for Context

async fn open(&self, partition: &str, name: &[u8]) -> Result<Blob, Error>

Open an existing blob in a given partition or create a new one.

async fn remove( &self, partition: &str, name: Option<&[u8]>, ) -> Result<(), Error>

Remove a blob from a given partition.

async fn scan(&self, partition: &str) -> Result<Vec<Vec<u8>>, Error>

Return all blobs in a given partition.

impl CryptoRng for Context