From 0598183f4fc8c6c5eba7cb88809b573a6967c582 Mon Sep 17 00:00:00 2001
From: junxiang Mu <1948535941@qq.com>
Date: Mon, 31 Mar 2025 06:34:56 +0000
Subject: [PATCH] rename func

Signed-off-by: junxiang Mu <1948535941@qq.com>
---
 rustfs/src/storage/ecfs.rs     | 4 ++--
 s3select/query/src/instance.rs | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/rustfs/src/storage/ecfs.rs b/rustfs/src/storage/ecfs.rs
index 228127329..1fc410cb9 100644
--- a/rustfs/src/storage/ecfs.rs
+++ b/rustfs/src/storage/ecfs.rs
@@ -53,7 +53,7 @@ use policy::policy::action::S3Action;
 use policy::policy::BucketPolicy;
 use policy::policy::BucketPolicyArgs;
 use policy::policy::Validator;
-use query::instance::make_cnosdbms;
+use query::instance::make_rustfsms;
 use s3s::dto::*;
 use s3s::s3_error;
 use s3s::S3Error;
@@ -1878,7 +1878,7 @@ impl S3 for FS {
         let input = req.input;
         info!("{:?}", input);
 
-        let db = make_cnosdbms(input.clone(), false).await.map_err(|e| {
+        let db = make_rustfsms(input.clone(), false).await.map_err(|e| {
             error!("make db failed, {}", e.to_string());
             s3_error!(InternalError)
         })?;
diff --git a/s3select/query/src/instance.rs b/s3select/query/src/instance.rs
index a0b645ced..03cc7b037 100644
--- a/s3select/query/src/instance.rs
+++ b/s3select/query/src/instance.rs
@@ -63,7 +63,7 @@ where
     }
 }
 
-pub async fn make_cnosdbms(input: SelectObjectContentInput, is_test: bool) -> QueryResult<impl DatabaseManagerSystem> {
+pub async fn make_rustfsms(input: SelectObjectContentInput, is_test: bool) -> QueryResult<impl DatabaseManagerSystem> {
     // init Function Manager, we can define some UDF if need
     let func_manager = SimpleFunctionMetadataManager::default();
     // TODO session config need load global system config
@@ -105,7 +105,7 @@ mod tests {
         SelectObjectContentRequest,
     };
 
-    use crate::instance::make_cnosdbms;
+    use crate::instance::make_rustfsms;
 
     #[tokio::test]
     #[ignore]
@@ -133,7 +133,7 @@ mod tests {
                 scan_range: None,
             },
         };
-        let db = make_cnosdbms(input.clone(), true).await.unwrap();
+        let db = make_rustfsms(input.clone(), true).await.unwrap();
         let query = Query::new(Context { input }, sql.to_string());
 
         let result = db.execute(&query).await.unwrap();