Merge branch 'main' into dev/xinli/select-list-stage

Author: Xuanwo

Cargo.lock

@@ -43,9 +43,6 @@ mysql> SELECT * FROM system.configs;
 | query   | management_mode                        | false                          |             |
 | query   | jwt_key_file                           |                                |             |
 | query   | jwt_key_files                          |                                |             |
-| query   | async_insert_max_data_size             | 10000                          |             |
-| query   | async_insert_busy_timeout              | 200                            |             |
-| query   | async_insert_stale_timeout             | 0                              |             |
 | query   | users                                  |                                |             |
 | query   | share_endpoint_address                 |                                |             |
 | query   | share_endpoint_auth_token_file         |                                |             |

docs/doc/13-sql-reference/20-system-tables/system-configs.md

@@ -18,19 +18,27 @@ use poem::EndpointExt;
 use poem::Route;
 use poem::Server;
 use sharing_endpoint::configs::Config;
-use sharing_endpoint::handlers::presign_files;
+use sharing_endpoint::handlers::share_table_meta;
+use sharing_endpoint::handlers::share_table_presign_files;
 use sharing_endpoint::middlewares::SharingAuth;
 use sharing_endpoint::services::SharingServices;
+
 #[tokio::main]
 async fn main() -> Result<(), std::io::Error> {
     let config = Config::load().expect("cfgs");
     SharingServices::init(config.clone())
         .await
         .expect("failed to init sharing service");
     let app = Route::new()
+        // handler for share table presign
         .at(
             "/tenant/:tenant_id/:share_name/table/:table_name/presign",
-            poem::post(presign_files),
+            poem::post(share_table_presign_files),
+        )
+        // handler for accessing share table meta
+        .at(
+            "/tenant/:tenant_id/:share_name/meta",
+            poem::post(share_table_meta),
         )
         .with(SharingAuth);
 

docs/doc/90-contributing/01-rfcs/20220602-async-insert.md

@@ -22,6 +22,7 @@ codespan-reporting = { git = "https://github.com/brendanzab/codespan", rev = "c8
 
 anyhow = { workspace = true }
 bincode = { version = "2.0.0-rc.1", features = ["serde", "std", "alloc"] }
+http = "0.2"
 opendal = { workspace = true }
 paste = "1.0.9"
 prost = { workspace = true }

src/binaries/opensharing/main.rs

@@ -137,6 +137,7 @@ build_exceptions! {
     DropColumnEmptyError(1109),
     // create table or alter table add column with internal column name
     TableWithInternalColumnName(1110),
+    EmptyShareEndpointConfig(1111),
 
     // Data Related Errors
 

src/common/exception/Cargo.toml

@@ -175,6 +175,12 @@ impl From<opendal::Error> for ErrorCode {
     }
 }
 
+impl From<http::Error> for ErrorCode {
+    fn from(error: http::Error) -> Self {
+        ErrorCode::from_std_error(error)
+    }
+}
+
 impl From<std::io::Error> for ErrorCode {
     fn from(error: std::io::Error) -> Self {
         use std::io::ErrorKind;

src/common/exception/src/exception_code.rs

@@ -62,4 +62,5 @@ pub use util::txn_cond_seq;
 pub use util::txn_op_del;
 pub use util::txn_op_put;
 pub use util::txn_op_put_with_expire;
+pub use util::DEFAULT_MGET_SIZE;
 pub use util::TXN_MAX_RETRY_TIMES;