From 1cfdb3668afc4e431c8da5bc4f988ad345ddee48 Mon Sep 17 00:00:00 2001 From: Rhys Lloyd Date: Tue, 22 Jul 2025 21:01:39 -0700 Subject: [PATCH] validator: connect_lazy --- validation/src/main.rs | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/validation/src/main.rs b/validation/src/main.rs index bf3f26f..980e2f5 100644 --- a/validation/src/main.rs +++ b/validation/src/main.rs @@ -57,13 +57,13 @@ async fn main()->Result<(),StartupError>{ // maps-service api let api_host_internal=std::env::var("API_HOST_INTERNAL").expect("API_HOST_INTERNAL env required"); - let (mapfixes,operations,scripts,script_policy,submissions)=tokio::try_join!( - crate::grpc::mapfixes::ValidatorMapfixesServiceClient::connect(api_host_internal.clone()), - crate::grpc::operations::ValidatorOperationsServiceClient::connect(api_host_internal.clone()), - crate::grpc::scripts::ValidatorScriptsServiceClient::connect(api_host_internal.clone()), - crate::grpc::script_policy::ValidatorScriptPolicyServiceClient::connect(api_host_internal.clone()), - crate::grpc::submissions::ValidatorSubmissionsServiceClient::connect(api_host_internal.clone()), - ).map_err(StartupError::API)?; + let endpoint=tonic::transport::Endpoint::new(api_host_internal).map_err(StartupError::API)?; + let channel=endpoint.connect_lazy(); + let mapfixes=crate::grpc::mapfixes::ValidatorMapfixesServiceClient::new(channel.clone()); + let operations=crate::grpc::operations::ValidatorOperationsServiceClient::new(channel.clone()); + let scripts=crate::grpc::scripts::ValidatorScriptsServiceClient::new(channel.clone()); + let script_policy=crate::grpc::script_policy::ValidatorScriptPolicyServiceClient::new(channel.clone()); + let submissions=crate::grpc::submissions::ValidatorSubmissionsServiceClient::new(channel); let message_handler=message_handler::MessageHandler::new(cloud_context,cookie_context,group_id,mapfixes,operations,scripts,script_policy,submissions); // nats