From 552300d437ed3a3c3ecf20049b0f96eb2a9a13c1 Mon Sep 17 00:00:00 2001 From: rtkay123 Date: Fri, 15 Aug 2025 21:05:36 +0200 Subject: feat(exec): get config --- crates/rule-executor/src/state.rs | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) (limited to 'crates/rule-executor/src/state.rs') diff --git a/crates/rule-executor/src/state.rs b/crates/rule-executor/src/state.rs index ec59519..efad4ea 100644 --- a/crates/rule-executor/src/state.rs +++ b/crates/rule-executor/src/state.rs @@ -5,9 +5,9 @@ use moka::future::Cache; use tokio::sync::RwLock; use tonic::transport::Endpoint; use tracing::error; -use warden_core::configuration::{ - routing::{RoutingConfiguration, query_routing_client::QueryRoutingClient}, - rule::RuleConfigurationRequest, +use warden_core::configuration::rule::{ + RuleConfiguration, RuleConfigurationRequest, + query_rule_configuration_client::QueryRuleConfigurationClient, }; use warden_stack::Configuration; @@ -24,9 +24,9 @@ pub type AppHandle = Arc; #[derive(Clone)] pub struct AppState { pub services: Services, - pub local_cache: Arc>>, + pub local_cache: Arc>>, pub config: LocalConfig, - pub query_routing_client: QueryRoutingClient, + pub query_rule_client: QueryRuleConfigurationClient, } impl AppState { @@ -42,13 +42,14 @@ impl AppState { ) })?; - let query_routing_client = QueryRoutingClient::with_interceptor(channel, MyInterceptor); + let query_rule_client = + QueryRuleConfigurationClient::with_interceptor(channel, MyInterceptor); Ok(Self { services, config, local_cache: Arc::new(RwLock::new(Cache::builder().build())), - query_routing_client, + query_rule_client, }) } } -- cgit v1.2.3