aboutsummaryrefslogtreecommitdiffstats
path: root/crates/rule-executor/src/processor
diff options
context:
space:
mode:
authorrtkay123 <dev@kanjala.com>2025-08-16 10:08:51 +0200
committerrtkay123 <dev@kanjala.com>2025-08-16 10:08:51 +0200
commiteb59714648bbba66e77955c8bda1c99caf1cede6 (patch)
tree5c194cd5e132c172e4cb510cc35bb46594f86f02 /crates/rule-executor/src/processor
parent698633baa2505ffb60cb5bba588f8b360c767edd (diff)
downloadwarden-eb59714648bbba66e77955c8bda1c99caf1cede6.tar.bz2
warden-eb59714648bbba66e77955c8bda1c99caf1cede6.zip
feat(config): typologies
Diffstat (limited to 'crates/rule-executor/src/processor')
-rw-r--r--crates/rule-executor/src/processor/reload.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/crates/rule-executor/src/processor/reload.rs b/crates/rule-executor/src/processor/reload.rs
index 385c7ab..93d730a 100644
--- a/crates/rule-executor/src/processor/reload.rs
+++ b/crates/rule-executor/src/processor/reload.rs
@@ -37,10 +37,6 @@ pub async fn reload(state: AppHandle) -> anyhow::Result<()> {
&& let Ok(kind) = ConfigKind::try_from(res.kind)
{
match kind {
- ConfigKind::Routing => {
- trace!(kind = ?kind, "detected reload event, nothing to do here, acknowledging");
- let _ = message.ack().await.inspect_err(|e| error!("{e}"));
- }
ConfigKind::Rule => {
let local_cache = state.local_cache.write().await;
let id = res.id();
@@ -58,6 +54,10 @@ pub async fn reload(state: AppHandle) -> anyhow::Result<()> {
local_cache.invalidate(&key).await;
let _ = message.ack().await.inspect_err(|e| error!("{e}"));
}
+ _ => {
+ trace!(kind = ?kind, "detected reload event, nothing to do here, acknowledging");
+ let _ = message.ack().await.inspect_err(|e| error!("{e}"));
+ }
}
}
}