Struct RedisStorage

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

Available on crate feature redis-storage only.

A dialogue storage based on Redis.

Implementations

impl<S> RedisStorage<S>

pub async fn open( url: &str, serializer: S, ) -> Result<Arc<Self>, RedisStorageError<Infallible>>

Examples found in repository

examples/db_remember.rs (line 42)

async fn main() {
    pretty_env_logger::init();
    log::info!("Starting DB remember bot...");

    let bot = Bot::from_env();

    let storage: MyStorage = if std::env::var("DB_REMEMBER_REDIS").is_ok() {
        RedisStorage::open("redis://127.0.0.1:6379", Bincode).await.unwrap().erase()
    } else {
        SqliteStorage::open("db.sqlite", Json).await.unwrap().erase()
    };

    let handler = Update::filter_message()
        .enter_dialogue::<Message, ErasedStorage<State>, State>()
        .branch(dptree::case![State::Start].endpoint(start))
        .branch(
            dptree::case![State::GotNumber(n)]
                .branch(dptree::entry().filter_command::<Command>().endpoint(got_number))
                .branch(dptree::endpoint(invalid_command)),
        );

    Dispatcher::builder(bot, handler)
        .dependencies(dptree::deps![storage])
        .enable_ctrlc_handler()
        .build()
        .dispatch()
        .await;
}

Trait Implementations

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

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

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

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

Removes a dialogue indexed by chat_id.

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<ErasedStorage<D>>

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

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