Struct RocksDbStorage

pub struct RocksDbStorage<S> { /* private fields */ }

A persistent dialogue storage based on RocksDb.

Implementations

impl<S> RocksDbStorage<S>

pub async fn open( path: &str, serializer: S, options: Option<Options>, ) -> Result<Arc<Self>, RocksDbStorageError<Infallible>>

Creates a new RocksDbStorage with the given path, serializer, and options.

Trait Implementations

impl<S, D> Storage<D> for RocksDbStorage<S>

where S: Send + Sync + Serializer<D> + 'static, D: Send + Serialize + DeserializeOwned + 'static, <S as Serializer<D>>::Error: Debug + Display,

fn remove_dialogue( self: Arc<Self>, ChatId: ChatId, ) -> BoxFuture<'static, Result<(), Self::Error>>

Returns RocksDbStorageError::DialogueNotFound if a dialogue does not exist.

type Error = RocksDbStorageError<<S as Serializer<D>>::Error>

fn update_dialogue( self: Arc<Self>, ChatId: ChatId, dialogue: D, ) -> BoxFuture<'static, Result<(), Self::Error>>

Updates a dialogue indexed by chat_id with dialogue.

fn get_dialogue( self: Arc<Self>, ChatId: ChatId, ) -> BoxFuture<'static, Result<Option<D>, Self::Error>>

Returns the dialogue indexed by chat_id.

fn erase( self: Arc<Self>, ) -> Arc<dyn Storage<D, Error = Box<dyn Error + Sync + Send>> + Sync + Send>

where Self: Sized + Send + Sync + 'static, Self::Error: Error + Send + Sync + 'static,

Erases Self::Error to std::error::Error.