diff options
author | rtkay123 <dev@kanjala.com> | 2025-08-15 21:05:36 +0200 |
---|---|---|
committer | rtkay123 <dev@kanjala.com> | 2025-08-15 21:05:36 +0200 |
commit | 552300d437ed3a3c3ecf20049b0f96eb2a9a13c1 (patch) | |
tree | fd54a21b63cdf3ab11b74972c980b42d9024e65e /crates/rule-executor/src/state.rs | |
parent | 1968002d656383069a386bd874c9f0cc83e3116e (diff) | |
download | warden-552300d437ed3a3c3ecf20049b0f96eb2a9a13c1.tar.bz2 warden-552300d437ed3a3c3ecf20049b0f96eb2a9a13c1.zip |
feat(exec): get config
Diffstat (limited to 'crates/rule-executor/src/state.rs')
-rw-r--r-- | crates/rule-executor/src/state.rs | 15 |
1 files changed, 8 insertions, 7 deletions
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<AppState>; #[derive(Clone)] pub struct AppState { pub services: Services, - pub local_cache: Arc<RwLock<Cache<RuleConfigurationRequest, RoutingConfiguration>>>, + pub local_cache: Arc<RwLock<Cache<RuleConfigurationRequest, RuleConfiguration>>>, pub config: LocalConfig, - pub query_routing_client: QueryRoutingClient<Intercepted>, + pub query_rule_client: QueryRuleConfigurationClient<Intercepted>, } 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, }) } } |