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

refactor: cleaning, requests and split db files (#75)

Browse Source 
Co-authored-by: shashank_attarde <shashank.attarde@juspay.in>
Co-authored-by: Arun Raj M <jarnura47@gmail.com>
This commit is contained in:
kos-for-juspay
2022-12-13 08:58:48 +01:00
committed by GitHub
parent 9c2f296f25
commit 3acde2603b
30 changed files with 468 additions and 440 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
crates/router/src/db/queue.rs
View File

@ -1,10 +1,10 @@
use redis_interface::{errors::RedisError, RedisEntryId, SetNXReply};
use router_env::logger;
use super::MockDb;
use super::{MockDb, Store};
use crate::{
core::errors::{CustomResult, ProcessTrackerError},
types::storage::ProcessTracker,
types::storage,
};
#[async_trait::async_trait]
@ -14,7 +14,7 @@ pub trait QueueInterface {
stream_name: &str,
group_name: &str,
consumer_name: &str,
) -> CustomResult<Vec<ProcessTracker>, ProcessTrackerError>;
) -> CustomResult<Vec<storage::ProcessTracker>, ProcessTrackerError>;
async fn consumer_group_create(
&self,
@ -38,13 +38,13 @@ pub trait QueueInterface {
}
#[async_trait::async_trait]
impl QueueInterface for super::Store {
impl QueueInterface for Store {
async fn fetch_consumer_tasks(
&self,
stream_name: &str,
group_name: &str,
consumer_name: &str,
) -> CustomResult<Vec<ProcessTracker>, ProcessTrackerError> {
) -> CustomResult<Vec<storage::ProcessTracker>, ProcessTrackerError> {
crate::scheduler::consumer::fetch_consumer_tasks(
self,
&self.redis_conn.clone(),
@ -125,7 +125,7 @@ impl QueueInterface for MockDb {
_stream_name: &str,
_group_name: &str,
_consumer_name: &str,
) -> CustomResult<Vec<ProcessTracker>, ProcessTrackerError> {
) -> CustomResult<Vec<storage::ProcessTracker>, ProcessTrackerError> {
todo!()
}