removed runtime usage service

src/sagittarius/mod.rs

@@ -4,7 +4,6 @@ pub mod flow_service_client_impl;
 pub mod module_service_client_impl;
 pub mod retry;
 pub mod runtime_status_service_client_impl;
-pub mod runtime_usage_client_impl;
 pub mod test_execution_client_impl;
 
 pub(crate) const SAGITTARIUS_UNARY_RPC_TIMEOUT: Duration = Duration::from_secs(5);

src/server/dynamic_server.rs

@@ -3,15 +3,13 @@ use crate::{
     sagittarius::{
         module_service_client_impl::SagittariusModuleServiceClient,
         runtime_status_service_client_impl::SagittariusRuntimeStatusServiceClient,
-        runtime_usage_client_impl::SagittariusRuntimeUsageClient,
         test_execution_client_impl::SagittariusExecutionResponseSender,
     },
     server::{
         action_transfer_service_server_impl::AquilaActionTransferServiceServer,
         create_readiness_interceptor, module_service_server_impl::AquilaModuleServiceServer,
         runtime_execution_service_server_impl::AquilaExecutionServiceServer,
         runtime_status_service_server_impl::AquilaRuntimeStatusServiceServer,
-        runtime_usage_service_server_impl::AquilaRuntimeUsageServiceServer,
     },
 };
 use async_nats::jetstream::kv::Store;
@@ -23,7 +21,6 @@ use tucana::aquila::{
     action_transfer_service_server::ActionTransferServiceServer,
     execution_service_server::ExecutionServiceServer, module_service_server::ModuleServiceServer,
     runtime_status_service_server::RuntimeStatusServiceServer,
-    runtime_usage_service_server::RuntimeUsageServiceServer,
 };
 
 pub struct AquilaDynamicServer {
@@ -97,13 +94,6 @@ impl AquilaDynamicServer {
 
         info!("ModuleService started");
 
-        let runtime_usage_service = Arc::new(Mutex::new(SagittariusRuntimeUsageClient::new(
-            self.channel.clone(),
-            self.token.clone(),
-        )));
-
-        info!("RuntimeUsageService started");
-
         let runtime_status_service = Arc::new(Mutex::new(
             SagittariusRuntimeStatusServiceClient::new(self.channel.clone(), self.token.clone()),
         ));
@@ -118,11 +108,7 @@ impl AquilaDynamicServer {
             module_service.clone(),
             self.service_configuration.clone(),
         );
-        let runtime_usage_server = AquilaRuntimeUsageServiceServer::new(
-            runtime_usage_service.clone(),
-            self.service_configuration.clone(),
-        );
-        let runtime_status_server = AquilaRuntimeStatusServiceServer::new(
+       let runtime_status_server = AquilaRuntimeStatusServiceServer::new(
             runtime_status_service.clone(),
             self.service_configuration.clone(),
             Duration::from_secs(self.runtime_status_not_responding_after_secs.clone()),
@@ -163,10 +149,6 @@ impl AquilaDynamicServer {
                     module_server,
                     intercept.clone(),
                 ))
-                .add_service(RuntimeUsageServiceServer::with_interceptor(
-                    runtime_usage_server,
-                    intercept.clone(),
-                ))
                 .add_service(RuntimeStatusServiceServer::with_interceptor(
                     runtime_status_server,
                     intercept.clone(),
@@ -187,10 +169,6 @@ impl AquilaDynamicServer {
                     module_server,
                     intercept.clone(),
                 ))
-                .add_service(RuntimeUsageServiceServer::with_interceptor(
-                    runtime_usage_server,
-                    intercept.clone(),
-                ))
                 .add_service(RuntimeStatusServiceServer::with_interceptor(
                     runtime_status_server,
                     intercept.clone(),

src/server/mod.rs

@@ -3,7 +3,6 @@ mod interceptor;
 mod module_service_server_impl;
 mod runtime_execution_service_server_impl;
 mod runtime_status_service_server_impl;
-mod runtime_usage_service_server_impl;
 
 pub mod dynamic_server;
 pub mod static_server;