Struct RedisNetworkRepository

pub struct RedisNetworkRepository {
    pub client: Arc<ConnectionManager>,
    pub key_prefix: String,
}

Fields

client: Arc<ConnectionManager>

key_prefix: String

Implementations

impl RedisNetworkRepository

pub fn new( connection_manager: Arc<ConnectionManager>, key_prefix: String, ) -> Result<Self, RepositoryError>

Trait Implementations

impl Clone for RedisNetworkRepository

fn clone(&self) -> RedisNetworkRepository

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RedisNetworkRepository

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

Formats the value using the given formatter.

impl NetworkRepository for RedisNetworkRepository

fn get_by_name<'life0, 'life1, 'async_trait>( &'life0 self, network_type: NetworkType, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<NetworkRepoModel>, RepositoryError>> + Send + 'async_trait>>

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

Get a network by network type and name

fn get_by_chain_id<'life0, 'async_trait>( &'life0 self, network_type: NetworkType, chain_id: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<NetworkRepoModel>, RepositoryError>> + Send + 'async_trait>>

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

Get a network by network type and chain ID

impl RedisRepository for RedisNetworkRepository

fn serialize_entity<T, F>( &self, entity: &T, id_extractor: F, entity_type: &str, ) -> Result<String, RepositoryError>

where T: Serialize, F: Fn(&T) -> &str,

fn deserialize_entity<T>( &self, json: &str, entity_id: &str, entity_type: &str, ) -> Result<T, RepositoryError>

where T: for<'de> Deserialize<'de>,

Deserialize entity with detailed error context Default implementation that works for any Deserialize type

fn map_redis_error(&self, error: RedisError, context: &str) -> RepositoryError

Convert Redis errors to appropriate RepositoryError types

impl Repository<NetworkRepoModel, String> for RedisNetworkRepository

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

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

Check if Redis storage contains any network entries. This is used to determine if Redis storage is being used for networks.

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,

Drop all network-related entries from Redis storage. This includes all network data, indexes, and the network list. Use with caution as this will permanently delete all network data.

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

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

fn get_by_id<'life0, 'async_trait>( &'life0 self, id: String, ) -> Pin<Box<dyn Future<Output = Result<NetworkRepoModel, RepositoryError>> + Send + 'async_trait>>

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

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

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

fn list_paginated<'life0, 'async_trait>( &'life0 self, query: PaginationQuery, ) -> Pin<Box<dyn Future<Output = Result<PaginatedResult<NetworkRepoModel>, RepositoryError>> + Send + 'async_trait>>

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

fn update<'life0, 'async_trait>( &'life0 self, id: String, entity: NetworkRepoModel, ) -> Pin<Box<dyn Future<Output = Result<NetworkRepoModel, RepositoryError>> + Send + 'async_trait>>

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

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

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

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

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