Updated change router to retain subscription after a pod restart (dra…

…si-project#94) * updated router and added state manager in infra * updated state manager to be internal to router * nit * updated state manager based on PR comments * lint * moved query_state to state manager and configured arugment type for save_state * clippy lint fix
agentofreality · Oct 24, 2024 · 7bd3db6 · 7bd3db6
1 parent f71134a
commit 7bd3db6
Show file tree

Hide file tree

Showing 5 changed files with 221 additions and 93 deletions.
diff --git a/infrastructure/comms-dapr/src/comms.rs b/infrastructure/comms-dapr/src/comms.rs
@@ -153,4 +153,4 @@ impl Invoker for DaprHttpInvoker {
             Err(e) => Err(Box::new(e)),
         }
     }
-}
+}
diff --git a/sources/shared/change-router/Cargo.lock b/sources/shared/change-router/Cargo.lock
diff --git a/sources/shared/change-router/Cargo.toml b/sources/shared/change-router/Cargo.toml
@@ -9,7 +9,7 @@ edition = "2021"
 async-trait = "0.1.80"
 axum = { version = "0.7.5", features = ["macros", "http1", "tokio"] }
 chrono = "0.4.33"
-dapr = "=0.15.1"
+dapr = "0.15.1"
 dapr-macros = {version = "=0.15.1", package = "dapr-macros"}
 drasi-comms-abstractions = { path = "../../../infrastructure/comms-abstractions" }
 drasi-comms-dapr = { path = "../../../infrastructure/comms-dapr" }
-Original file line number
+Diff line change
@@ Expand Up / @@ -153,4 +153,4 @@ impl Invoker for DaprHttpInvoker { @@
                 Err(e) => Err(Box::new(e)),
             }
         }
-    }
+    }