rust/hyperswitch
1
0
Fork 0
mirror of https://github.com/juspay/hyperswitch.git synced 2025-11-01 02:57:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

redis_interface: Added a few more wrapper functions (#82)

Browse Source
This commit is contained in:
Kartikeya Hegde
2022-12-07 18:34:30 +05:30
committed by GitHub
parent cd39dd4a99
commit 7313c06254
1 changed files with 24 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
crates/redis_interface/src/commands.rs
View File

@ -70,6 +70,18 @@ impl super::RedisConnectionPool {
.change_context(errors::RedisError::GetFailed) .change_context(errors::RedisError::GetFailed)
} }
#[instrument(level = "DEBUG", skip(self))]
pub async fn exists<V>(&self, key: &str) -> CustomResult<bool, errors::RedisError>
where
V: Into<MultipleKeys> + Unpin + Send + 'static,
{
self.pool
.exists(key)
.await
.into_report()
.change_context(errors::RedisError::GetFailed)
}
#[instrument(level = "DEBUG", skip(self))] #[instrument(level = "DEBUG", skip(self))]
pub async fn get_and_deserialize_key<T>( pub async fn get_and_deserialize_key<T>(
&self, &self,
@ -149,6 +161,18 @@ impl super::RedisConnectionPool {
.change_context(errors::RedisError::SetExpiryFailed) .change_context(errors::RedisError::SetExpiryFailed)
} }
#[instrument(level = "DEBUG", skip(self))]
pub async fn set_expire_at(
&self,
key: &str,
timestamp: i64,
) -> CustomResult<(), errors::RedisError> {
self.pool
.expire_at(key, timestamp)
.await
.into_report()
.change_context(errors::RedisError::SetExpiryFailed)
}
#[instrument(level = "DEBUG", skip(self))] #[instrument(level = "DEBUG", skip(self))]
pub async fn stream_append_entry<F>( pub async fn stream_append_entry<F>(
&self, &self,