Struct InMemoryDatabase 

pub struct InMemoryDatabase<TR, TA, CA, C>
where
    TR: TransformRequest + Send + Sync,
    TA: TransformAttempt<TransformRequestIdentifier = TR::Identifier, CallArgsType = TR::Input, ReturnType = TR::Output> + Send + Sync,
    CA: ConsumeAttempt<TransformRequestIdentifier = TR::Identifier, TransformAttemptIdentifier = TA::Identifier, ConsumeVal = TR::Output> + Send + Sync,
    C: Config,
{ /* private fields */ }

Trait Implementations

impl<TR, TA, CA, C> Database for InMemoryDatabase<TR, TA, CA, C>

where TR: TransformRequest + Send + Sync, TA: TransformAttempt<TransformRequestIdentifier = TR::Identifier, CallArgsType = TR::Input, ReturnType = TR::Output> + Send + Sync, CA: ConsumeAttempt<TransformRequestIdentifier = TR::Identifier, TransformAttemptIdentifier = TA::Identifier, ConsumeVal = TR::Output> + Send + Sync, C: Config<KeyType = String, ValueType = Vec<u8>>, TR::Identifier: Hash,

type Config = C

type ConsumeAttempt = CA

type DatabaseError = InMemoryDatabaseError

type Input = <TR as TransformRequest>::Input

type Output = <TR as TransformRequest>::Output

type TransformAttempt = TA

type TransformRequest = TR

fn new<'async_trait>( _ctx: Arc<Mutex<Self::Config>>, ) -> Pin<Box<dyn Future<Output = Result<Self, Self::DatabaseError>> + Send + 'async_trait>>

where Self: Sized + 'async_trait,

fn get_dyn_configs<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Vec<(<Self::Config as Config>::KeyType, <Self::Config as Config>::ValueType)>, Self::DatabaseError>> + Send + 'async_trait>>

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

fn register_transform_request<'life0, 'life1, 'async_trait>( &'life0 mut self, request: &'life1 Self::TransformRequest, ) -> Pin<Box<dyn Future<Output = Result<(), Self::DatabaseError>> + Send + 'async_trait>>

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

fn register_transform_attempt<'life0, 'life1, 'async_trait>( &'life0 mut self, attempt: &'life1 Self::TransformAttempt, ) -> Pin<Box<dyn Future<Output = Result<(), Self::DatabaseError>> + Send + 'async_trait>>

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

fn update_transform_attempt<'life0, 'life1, 'async_trait>( &'life0 mut self, attempt: &'life1 WorkerManagerResult<Self::TransformAttempt>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::DatabaseError>> + Send + 'async_trait>>

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

fn register_consume_attempt<'life0, 'life1, 'async_trait>( &'life0 mut self, attempt: &'life1 Self::ConsumeAttempt, ) -> Pin<Box<dyn Future<Output = Result<(), Self::DatabaseError>> + Send + 'async_trait>>

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

fn update_consume_attempt<'life0, 'async_trait>( &'life0 mut self, attempt: ConsumeAttemptResult<Self::ConsumeAttempt>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::DatabaseError>> + Send + 'async_trait>>

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

fn archive_request_with_id<'life0, 'life1, 'async_trait>( &'life0 mut self, request: &'life1 <Self::TransformRequest as TransformRequest>::Identifier, ) -> Pin<Box<dyn Future<Output = Result<(), Self::DatabaseError>> + Send + 'async_trait>>

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

impl<TR, TA, CA, C> Debug for InMemoryDatabase<TR, TA, CA, C>

where TR: TransformRequest + Send + Sync + Debug, TA: TransformAttempt<TransformRequestIdentifier = TR::Identifier, CallArgsType = TR::Input, ReturnType = TR::Output> + Send + Sync + Debug, CA: ConsumeAttempt<TransformRequestIdentifier = TR::Identifier, TransformAttemptIdentifier = TA::Identifier, ConsumeVal = TR::Output> + Send + Sync + Debug, C: Config + Debug, TR::Identifier: Debug, TA::Identifier: Debug, CA::Identifier: Debug,

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

Formats the value using the given formatter.