From 501faad8ab5cf959a86481258b35ed7d1e8ec48c Mon Sep 17 00:00:00 2001
From: dennis zhuang <killme2008@gmail.com>
Date: Wed, 22 Mar 2023 14:07:23 +0800
Subject: [PATCH] chore: rename params in flush api (#1213)

---
 src/servers/src/http/admin.rs | 24 +++++++++++-------------
 1 file changed, 11 insertions(+), 13 deletions(-)

diff --git a/src/servers/src/http/admin.rs b/src/servers/src/http/admin.rs
index d801b1703c..aa8c6abf6a 100644
--- a/src/servers/src/http/admin.rs
+++ b/src/servers/src/http/admin.rs
@@ -18,8 +18,7 @@ use api::v1::ddl_request::Expr;
 use api::v1::greptime_request::Request;
 use api::v1::{DdlRequest, FlushTableExpr};
 use axum::extract::{Query, RawBody, State};
-use axum::http::StatusCode as HttpStatusCode;
-use axum::Json;
+use axum::http::StatusCode;
 use session::context::QueryContext;
 use snafu::OptionExt;
 
@@ -32,21 +31,20 @@ pub async fn flush(
     State(grpc_handler): State<ServerGrpcQueryHandlerRef>,
     Query(params): Query<HashMap<String, String>>,
     RawBody(_): RawBody,
-) -> Result<(HttpStatusCode, Json<String>)> {
+) -> Result<(StatusCode, ())> {
     let catalog_name = params
-        .get("catalog_name")
+        .get("catalog")
         .cloned()
         .unwrap_or("greptime".to_string());
-    let schema_name =
-        params
-            .get("schema_name")
-            .cloned()
-            .context(error::InvalidFlushArgumentSnafu {
-                err_msg: "schema_name is not present",
-            })?;
+    let schema_name = params
+        .get("db")
+        .cloned()
+        .context(error::InvalidFlushArgumentSnafu {
+            err_msg: "db is not present",
+        })?;
 
     // if table name is not present, flush all tables inside schema
-    let table_name = params.get("table_name").cloned().unwrap_or_default();
+    let table_name = params.get("table").cloned().unwrap_or_default();
 
     let region_id: Option<u32> = params
         .get("region")
@@ -65,5 +63,5 @@ pub async fn flush(
     });
 
     grpc_handler.do_query(request, QueryContext::arc()).await?;
-    Ok((HttpStatusCode::OK, Json::from("hello, world".to_string())))
+    Ok((StatusCode::NO_CONTENT, ()))
 }