From 000885c1d5a23eb353c3f490e32363010ca804d3 Mon Sep 17 00:00:00 2001 From: rtkay123 Date: Sat, 16 Aug 2025 00:47:43 +0200 Subject: feat(config): identify resource to reload --- .../src/state/routing/mutate_routing.rs | 20 +++++++++++++++++--- 1 file changed, 17 insertions(+), 3 deletions(-) (limited to 'crates/configuration/src/state/routing/mutate_routing.rs') diff --git a/crates/configuration/src/state/routing/mutate_routing.rs b/crates/configuration/src/state/routing/mutate_routing.rs index 105cf18..9542ba7 100644 --- a/crates/configuration/src/state/routing/mutate_routing.rs +++ b/crates/configuration/src/state/routing/mutate_routing.rs @@ -4,7 +4,7 @@ use tracing::{Instrument, error, info_span, instrument, trace}; use tracing_opentelemetry::OpenTelemetrySpanExt; use uuid::Uuid; use warden_core::configuration::{ - ReloadEvent, + ConfigKind, ReloadEvent, routing::{ DeleteConfigurationRequest, RoutingConfiguration, UpdateRoutingRequest, mutate_routing_server::MutateRouting, @@ -100,7 +100,14 @@ impl MutateRouting for AppHandle { let (_del_result, _publish_result) = tokio::try_join!( invalidate_cache(self, CacheKey::Routing(&id)), - publish_reload(self, conf, ReloadEvent::Routing) + publish_reload( + self, + conf, + ReloadEvent { + kind: ConfigKind::Routing.into(), + ..Default::default() + } + ) )?; let res = updated.configuration.0; @@ -151,7 +158,14 @@ impl MutateRouting for AppHandle { let (_del_result, _publish_result) = tokio::try_join!( invalidate_cache(self, CacheKey::Routing(&id)), - publish_reload(self, conf, ReloadEvent::Routing) + publish_reload( + self, + conf, + ReloadEvent { + kind: ConfigKind::Routing.into(), + ..Default::default() + } + ) )?; let res = updated.configuration.0; -- cgit v1.2.3