Struct Context

pub struct Context { /* private fields */ }

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

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