Struct RedisNotificationRepository

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

Fields

client: Arc<ConnectionManager>

key_prefix: String

Implementations

impl RedisNotificationRepository

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

Trait Implementations

impl Clone for RedisNotificationRepository

fn clone(&self) -> RedisNotificationRepository

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RedisNotificationRepository

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

Formats the value using the given formatter.

impl RedisRepository for RedisNotificationRepository

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<NotificationRepoModel, String> for RedisNotificationRepository

fn create<'life0, 'async_trait>( &'life0 self, entity: NotificationRepoModel, ) -> Pin<Box<dyn Future<Output = Result<NotificationRepoModel, 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<NotificationRepoModel, 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<NotificationRepoModel>, 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<NotificationRepoModel>, RepositoryError>> + Send + 'async_trait>>

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

fn update<'life0, 'async_trait>( &'life0 self, id: String, entity: NotificationRepoModel, ) -> Pin<Box<dyn Future<Output = Result<NotificationRepoModel, 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,

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 the repository contains any entries.

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 entries from storage. This completely clears all data, indexes, and metadata. Use with caution as this permanently deletes all data.