feat: upgrade protos and use batch insert api (#1)

Author: sunng87

Cargo.toml

@@ -12,7 +12,7 @@ dashmap = "5.4"
 enum_dispatch = "0.3"
 futures = "0.3"
 futures-util  = "0.3"
-greptime-proto = { git = "https://github.com/GreptimeTeam/greptime-proto.git", rev = "e8abf8241c908448dce595399e89c89a40d048bd" }
+greptime-proto = { git = "https://github.com/GreptimeTeam/greptime-proto.git", tag = "0.2.1" }
 parking_lot = "0.12"
 prost = "0.11"
 rand = "0.8"

src/database.rs

@@ -16,7 +16,7 @@ use crate::api::v1::auth_header::AuthScheme;
 use crate::api::v1::greptime_request::Request;
 use crate::api::v1::{
     greptime_response, AffectedRows, AuthHeader, DeleteRequest, GreptimeRequest, InsertRequest,
-    RequestHeader,
+    InsertRequests, RequestHeader,
 };
 
 use snafu::OptionExt;
@@ -64,8 +64,9 @@ impl Database {
         });
     }
 
-    pub async fn insert(&self, request: InsertRequest) -> Result<u32> {
-        self.handle(Request::Insert(request)).await
+    pub async fn insert(&self, requests: Vec<InsertRequest>) -> Result<u32> {
+        self.handle(Request::Inserts(InsertRequests { inserts: requests }))
+            .await
     }
 
     pub async fn delete(&self, request: DeleteRequest) -> Result<u32> {