aboutsummaryrefslogtreecommitdiffstats
path: root/crates/rule-executor/src/state.rs
diff options
context:
space:
mode:
authorrtkay123 <dev@kanjala.com>2025-08-15 21:05:36 +0200
committerrtkay123 <dev@kanjala.com>2025-08-15 21:05:36 +0200
commit552300d437ed3a3c3ecf20049b0f96eb2a9a13c1 (patch)
treefd54a21b63cdf3ab11b74972c980b42d9024e65e /crates/rule-executor/src/state.rs
parent1968002d656383069a386bd874c9f0cc83e3116e (diff)
downloadwarden-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.rs15
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,
})
}
}