Struct blobfs::mock::Mock

source ·
pub struct Mock { /* private fields */ }
Expand description

A testing server implementation of /blob.

Mock does not handle requests until instructed to do so.

Implementations§

source§

impl Mock

source

pub async fn expect_open_blob(&mut self, merkle: Hash) -> Blob

Consume the next directory request, verifying it is intended to read the blob identified by merkle. Returns a Blob representing the open blob file.

§Panics

Panics on error or assertion violation (unexpected requests or a mismatched open call)

source

pub async fn expect_create_blob(&mut self, merkle: Hash) -> Blob

Consume the next directory request, verifying it is intended to create the blob identified by merkle. Returns a Blob representing the open blob file.

§Panics

Panics on error or assertion violation (unexpected requests or a mismatched open call)

source

pub async fn expect_readdir(&mut self, entries: impl Iterator<Item = Hash>)

Consume directory requests, verifying they are requests to read directory entries. Respond with dirents constructed from the given entries.

§Panics

Panics on error or assertion violation (unexpected requests or not all entries are read)

source

pub async fn expect_readable_missing_checks( &mut self, readable: &[Hash], missing: &[Hash], )

Consume N directory requests, verifying they are intended to determine whether the blobs specified readable and missing are readable or not, responding to the check based on which collection the hash is in.

§Panics

Panics on error or assertion violation (unexpected requests, request for unspecified blob)

source

pub async fn expect_filter_to_missing_blobs_with_readable_missing_ids( &mut self, readable: &[Hash], missing: &[Hash], )

Expects and handles a call to [Client::filter_to_missing_blobs]. Verifies the call intends to determine whether the blobs specified in readable and missing are readable or not, responding to the check based on which collection the hash is in.

§Panics

Panics on error or assertion violation (unexpected requests, request for unspecified blob)

source

pub async fn expect_done(self)

Asserts that the request stream closes without any further requests.

§Panics

Panics on error

Auto Trait Implementations§

§

impl Freeze for Mock

§

impl !RefUnwindSafe for Mock

§

impl Send for Mock

§

impl Sync for Mock

§

impl Unpin for Mock

§

impl !UnwindSafe for Mock

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> Encode<Ambiguous1> for T

source§

unsafe fn encode( self, _encoder: &mut Encoder<'_>, _offset: usize, _depth: Depth, ) -> Result<(), Error>

Encodes the object into the encoder’s buffers. Any handles stored in the object are swapped for Handle::INVALID. Read more
source§

impl<T> Encode<Ambiguous2> for T

source§

unsafe fn encode( self, _encoder: &mut Encoder<'_>, _offset: usize, _depth: Depth, ) -> Result<(), Error>

Encodes the object into the encoder’s buffers. Any handles stored in the object are swapped for Handle::INVALID. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoAny for T
where T: 'static + Send + Sync,

source§

fn into_any(self: Arc<T>) -> Arc<dyn Any + Sync + Send>

Cast the given object into a dyn std::any::Any.
§

impl<T> Pointable for T

§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more