Struct DelayedSyncContext 

pub struct DelayedSyncContext<E> {
    pub inner: E,
    pub pending: PendingSyncs,
}

Context wrapper whose blobs defer Blob::start_sync and can gate blocking syncs in tests.

Fields

inner: E

pending: PendingSyncs

Trait Implementations

impl<E: BufferPooler> BufferPooler for DelayedSyncContext<E>

fn network_buffer_pool(&self) -> &BufferPool

Returns the network BufferPool.

fn storage_buffer_pool(&self) -> &BufferPool

Returns the storage BufferPool.

impl<E: Clock> Clock for DelayedSyncContext<E>

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<E: Clock> Clock for DelayedSyncContext<E>

type Instant = SystemTime

A measurement of a monotonically increasing clock.

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

Returns a measurement of the clock.

impl<E: Clone> Clone for DelayedSyncContext<E>

fn clone(&self) -> DelayedSyncContext<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Metrics> Metrics for DelayedSyncContext<E>

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<E: Clock> ReasonablyRealtime for DelayedSyncContext<E>

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

Returns a reference point at the start of an operation.

impl<E: Spawner> Spawner for DelayedSyncContext<E>

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

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

fn dedicated(self) -> Self

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

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<E: Storage> Storage for DelayedSyncContext<E>

type Blob = DelayedSyncBlob<<E 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<E: Supervisor> Supervisor for DelayedSyncContext<E>

fn name(&self) -> Name

Return the current label prefix and attributes.

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.

impl<E: TryCryptoRng> TryCryptoRng for DelayedSyncContext<E>

impl<E: TryRng> TryRng for DelayedSyncContext<E>

type Error = <E as TryRng>::Error

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.