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

fix(redis_interface): remove mget function from redis interface (#4303)

Browse Source 
Co-authored-by: hyperswitch-bot[bot] <148525504+hyperswitch-bot[bot]@users.noreply.github.com>
This commit is contained in:
Apoorv Dixit
2024-04-05 17:38:29 +05:30
committed by GitHub
parent 2d394f98e9
commit 14035d2f83
1 changed files with 0 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -306,45 +306,6 @@ impl super::RedisConnectionPool {
.await
}
#[instrument(level = "DEBUG", skip(self))]
pub async fn get_multiple_keys<K, V>(
&self,
keys: K,
) -> CustomResult<Vec<Option<V>>, errors::RedisError>
where
V: FromRedis + Unpin + Send + 'static,
K: Into<MultipleKeys> + Send + Debug,
{
self.pool
.mget(keys)
.await
.change_context(errors::RedisError::GetFailed)
}
#[instrument(level = "DEBUG", skip(self))]
pub async fn get_and_deserialize_multiple_keys<K, V>(
&self,
keys: K,
type_name: &'static str,
) -> CustomResult<Vec<Option<V>>, errors::RedisError>
where
K: Into<MultipleKeys> + Send + Debug,
V: serde::de::DeserializeOwned,
{
let data = self.get_multiple_keys::<K, Vec<u8>>(keys).await?;
data.into_iter()
.map(|value_bytes| {
value_bytes
.map(|bytes| {
bytes
.parse_struct(type_name)
.change_context(errors::RedisError::JsonSerializationFailed)
})
.transpose()
})
.collect()
}
#[instrument(level = "DEBUG", skip(self))]
pub async fn serialize_and_set_multiple_hash_field_if_not_exist<V>(
&self,