Struct MockPathInfoService 

pub struct MockPathInfoService {
    PathInfoService_expectations: MockPathInfoService_PathInfoService,
}

The base trait all PathInfo services need to implement.

Fields

PathInfoService_expectations: MockPathInfoService_PathInfoService

Implementations

impl MockPathInfoService

pub fn checkpoint(&mut self)

Validate that all current expectations for all methods have been satisfied, and discard them.

pub fn new() -> Self

Create a new mock object with no expectations.

This method will not be generated if the real struct already has a new method. However, it will be generated if the struct implements a trait with a new method. The trait’s new method can still be called like <MockX as TraitY>::new

impl MockPathInfoService

pub fn expect_get(&mut self) -> &mut Expectation

Create an Expectation for mocking the get method

pub fn expect_has(&mut self) -> &mut Expectation

Create an Expectation for mocking the has method

pub fn expect_put(&mut self) -> &mut Expectation

Create an Expectation for mocking the put method

pub fn expect_list(&mut self) -> &mut Expectation

Create an Expectation for mocking the list method

pub fn expect_nar_calculation_service(&mut self) -> &mut Expectation

Create an Expectation for mocking the nar_calculation_service method

Trait Implementations

impl Debug for MockPathInfoService

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for MockPathInfoService

fn default() -> Self

Returns the “default value” for a type.

impl PathInfoService for MockPathInfoService

The base trait all PathInfo services need to implement.

fn get<'life0, 'async_trait>( &'life0 self, digest: [u8; 20], ) -> Pin<Box<dyn Future<Output = Result<Option<PathInfo>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieve a PathInfo by the output digest.

fn has<'life0, 'async_trait>( &'life0 self, digest: [u8; 20], ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check if a PathInfo exists. Has a naïve default impl, but store implementations may decide to implement their own.

fn put<'life0, 'async_trait>( &'life0 self, path_info: PathInfo, ) -> Pin<Box<dyn Future<Output = Result<PathInfo, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Store a PathInfo.

fn list(&self) -> BoxStream<'static, Result<PathInfo, Error>>

Iterate over all PathInfo objects in the store. Implementations can decide to disallow listing.

This returns a pinned, boxed stream. The pinning allows for it to be polled easily, and the box allows different underlying stream implementations to be returned since Rust doesn’t support this as a generic in traits yet. This is the same thing that async_trait generates, but for streams instead of futures.

Even though this function is not async, underlying implementations are assumed to be nonblocking on IO, so they MUST use spawn_blocking when doing IO. Implementations can assume to be invoked in the context of a tokio runtime.

fn nar_calculation_service(&self) -> Option<Arc<dyn NarCalculationService>>

Returns a (more) suitable NarCalculationService. This can be used to offload NAR calculation to the remote side.