Enum TransactionCounterRepositoryStorage

pub enum TransactionCounterRepositoryStorage {
    InMemory(InMemoryTransactionCounter),
    Redis(RedisTransactionCounter),
}

Enum wrapper for different transaction counter repository implementations

Variants

InMemory(InMemoryTransactionCounter)

Redis(RedisTransactionCounter)

Implementations

impl TransactionCounterRepositoryStorage

pub fn new_in_memory() -> Self

pub fn new_redis( connections: Arc<RedisConnections>, key_prefix: String, ) -> Result<Self, RepositoryError>

Trait Implementations

impl Clone for TransactionCounterRepositoryStorage

fn clone(&self) -> TransactionCounterRepositoryStorage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TransactionCounterRepositoryStorage

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

Formats the value using the given formatter.

impl TransactionCounterTrait for TransactionCounterRepositoryStorage

fn get<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, relayer_id: &'life1 str, address: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, RepositoryError>> + Send + 'async_trait>>

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

fn get_and_increment<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, relayer_id: &'life1 str, address: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<u64, RepositoryError>> + Send + 'async_trait>>

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

fn decrement<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, relayer_id: &'life1 str, address: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<u64, RepositoryError>> + Send + 'async_trait>>

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

fn set<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, relayer_id: &'life1 str, address: &'life2 str, value: u64, ) -> Pin<Box<dyn Future<Output = Result<(), RepositoryError>> + Send + 'async_trait>>

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

fn drop_all_entries<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), RepositoryError>> + Send + 'async_trait>>

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

Remove all stored counter entries from the underlying backend. Intended for startup reset flows when RESET_STORAGE_ON_START is enabled.