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 auditor(&self) -> Arc<Auditor>

Get a reference to the Auditor.

pub fn storage_audit(&self) -> [u8; 32]

Compute a Sha256 digest of all storage contents.

pub fn storage_fault_config(&self) -> Arc<RwLock<FaultConfig>>

Access the storage fault configuration.

Changes to the returned FaultConfig take effect immediately for subsequent storage operations. This allows dynamically enabling or disabling fault injection during a test.

pub fn resolver_register( &self, host: impl Into<String>, addrs: Option<Vec<IpAddr>>, )

Register a DNS mapping for a hostname.

If addrs is None, the mapping is removed. If addrs is Some, the mapping is added or updated.

Trait Implementations

impl BufferPooler for Context

fn network_buffer_pool(&self) -> &BufferPool

Returns the network BufferPool.

fn storage_buffer_pool(&self) -> &BufferPool

Returns the storage BufferPool.

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.

fn timeout<F, T>( &self, duration: Duration, future: F, ) -> impl Future<Output = Result<T, Error>> + Send + '_

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

Await a future with a timeout, returning Error::Timeout if it expires.

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 Metrics for Context

fn register<N: Into<String>, H: Into<String>, M: Metric>( &self, name: N, help: H, metric: M, ) -> Registered<M>

Register a metric with the runtime.

fn encode(&self) -> String

Encode all metrics into a buffer.

impl Network for Context

type Listener = <Network<Network<Network>> as Network>::Listener

The type of Listener that’s returned when binding to a socket. Accepting a connection returns a Sink and Stream which are defined by the Listener and used to send and receive data over the connection.

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

Bind to the given socket address.

async fn dial( &self, socket: SocketAddr, ) -> Result<(SinkOf<Self>, StreamOf<Self>), 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 Resolver for Context

async fn resolve(&self, host: &str) -> Result<Vec<IpAddr>, Error>

Resolve a hostname to IP addresses.

impl Spawner for Context

fn dedicated(self) -> Self

Return a Spawner that runs the next task on a dedicated thread when the runtime supports it.

fn shared(self, blocking: bool) -> Self

Return a Spawner that schedules the next task onto the runtime’s shared executor.

fn spawn<F, Fut, T>(self, f: F) -> Handle<T>

where F: FnOnce(Self) -> Fut + Send + 'static, Fut: Future<Output = T> + Send + 'static, T: Send + 'static,

Spawn a task with the current context.

async fn stop(self, value: i32, timeout: Option<Duration>) -> Result<(), Error>

Signals the runtime to stop execution and waits for all outstanding tasks to perform any required cleanup and exit.

fn stopped(&self) -> Signal

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

impl Storage for Context

type Blob = <Storage<Storage<Storage<Storage>>> as Storage>::Blob

The readable/writeable storage buffer that can be opened by this Storage.

async fn open_versioned( &self, partition: &str, name: &[u8], versions: RangeInclusive<u16>, ) -> Result<(Self::Blob, u64, u16), Error>

Open an existing blob in a given partition or create a new one, returning the blob and its length.

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.

fn open( &self, partition: &str, name: &[u8], ) -> impl Future<Output = Result<(Self::Blob, u64), Error>> + Send

Storage::open_versioned with DEFAULT_BLOB_VERSION as the only value in the versions range. The blob version is omitted from the return value.

impl Strategizer for Context

Spawning threads would be nondeterministic, so the pool has no background workers. The executor thread registers itself as its sole member and all work executes inline.

Rayon’s current-thread registration is permanent and per-OS-thread, so only one pool can ever execute work on the executor thread. Every request (including from a later runner on the same thread) returns a strategy on that single-threaded pool with its planning parallelism set independently. This controls adaptive decisions and manual partitioning hints while Rayon executes on the sole registered thread. The returned strategy is therefore tied to the executor thread.

fn strategy(&self, parallelism: NonZeroUsize) -> Rayon

Returns a new Rayon strategy with the requested parallelism.

impl Supervisor for Context

fn child(&self, label: &'static str) -> Self

Create a named child context with a new supervision-tree node.

fn with_attribute(self, key: &'static str, value: impl Display) -> Self

Add a key-value attribute to this context’s identity.

fn name(&self) -> Name

Return the current label prefix and attributes.

impl TryCryptoRng for Context

impl TryRng for Context

type Error = Infallible

The type returned in the event of a RNG error.

fn try_next_u32(&mut self) -> Result<u32, Self::Error>

Return the next random u32.

fn try_next_u64(&mut self) -> Result<u64, Self::Error>

Return the next random u64.

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

Fill dst entirely with random data.