feat: 补充 Nacos operator switches API mock接口,

Author: heqingpan

src/openapi/naming/mod.rs

@@ -3,7 +3,9 @@ use crate::openapi::naming::catalog::query_opt_service_list;
 use crate::openapi::naming::instance::{
     beat_instance, del_instance, get_instance, get_instance_list, update_instance,
 };
-use crate::openapi::naming::operator::mock_operator_metrics;
+use crate::openapi::naming::operator::{
+    mock_get_switches, mock_operator_metrics, mock_put_switches,
+};
 use crate::openapi::naming::service::{
     query_service, query_service_list, query_subscribers_list, remove_service, update_service,
 };
@@ -59,6 +61,14 @@ pub fn naming_v1_route(config: &mut ServiceConfig) {
                     web::resource("/subscribers").route(web::get().to(query_subscribers_list)),
                 ),
         )
-        .service(scope("/nacos/v1/ns/operator").service(mock_operator_metrics))
+        .service(
+            scope("/nacos/v1/ns/operator")
+                .service(
+                    web::resource("switches")
+                        .route(web::get().to(mock_get_switches))
+                        .route(web::put().to(mock_put_switches)),
+                )
+                .service(mock_operator_metrics),
+        )
         .service(scope("/nacos/v1/ns/catalog").service(query_opt_service_list));
 }

src/openapi/naming/operator.rs

@@ -1,4 +1,4 @@
-use actix_web::{get, web, Responder, Scope};
+use actix_web::{get, web, HttpResponse, Responder, Scope};
 
 pub(super) fn service() -> Scope {
     web::scope("/operator").service(mock_operator_metrics)
@@ -8,3 +8,13 @@ pub(super) fn service() -> Scope {
 pub(crate) async fn mock_operator_metrics() -> impl Responder {
     "{\"status\":\"UP\"}"
 }
+
+pub(crate) async fn mock_get_switches() -> impl Responder {
+    let mock_body: &str ="{\"masters\":null,\"adWeightMap\":{},\"defaultPushCacheMillis\":10000,\"clientBeatInterval\":5000,\"defaultCacheMillis\":3000,\"distroThreshold\":0.7,\"healthCheckEnabled\":true,\"autoChangeHealthCheckEnabled\":true,\"distroEnabled\":true,\"enableStandalone\":true,\"pushEnabled\":true,\"checkTimes\":3,\"httpHealthParams\":{\"max\":5000,\"min\":500,\"factor\":0.85},\"tcpHealthParams\":{\"max\":5000,\"min\":1000,\"factor\":0.75},\"mysqlHealthParams\":{\"max\":3000,\"min\":2000,\"factor\":0.65},\"incrementalList\":[],\"serverStatusSynchronizationPeriodMillis\":2000,\"serviceStatusSynchronizationPeriodMillis\":5000,\"disableAddIP\":false,\"sendBeatOnly\":false,\"lightBeatEnabled\":true,\"limitedUrlMap\":{},\"distroServerExpiredMillis\":10000,\"pushGoVersion\":\"0.1.0\",\"pushJavaVersion\":\"0.1.0\",\"pushPythonVersion\":\"0.4.3\",\"pushCVersion\":\"1.0.12\",\"pushCSharpVersion\":\"0.9.0\",\"enableAuthentication\":false,\"overriddenServerStatus\":null,\"defaultInstanceEphemeral\":true,\"healthCheckWhiteList\":[],\"checksum\":null,\"name\":\"R-NACOS\"}";
+    HttpResponse::Ok()
+        .content_type("application/json")
+        .body(mock_body)
+}
+pub(crate) async fn mock_put_switches() -> impl Responder {
+    HttpResponse::Ok().body("ok")
+}