fix: minor changes to region server (#88)

Signed-off-by: Ruihang Xia <waynestxia@gmail.com>

c++/greptime/v1/region/server.grpc.pb.cc

@@ -25,7 +25,6 @@ namespace region {
 
 static const char* Region_method_names[] = {
   "/greptime.v1.region.Region/Handle",
-  "/greptime.v1.region.Region/HandleRequests",
 };
 
 std::unique_ptr< Region::Stub> Region::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) {
@@ -36,7 +35,6 @@ std::unique_ptr< Region::Stub> Region::NewStub(const std::shared_ptr< ::grpc::Ch
 
 Region::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options)
   : channel_(channel), rpcmethod_Handle_(Region_method_names[0], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
-  , rpcmethod_HandleRequests_(Region_method_names[1], options.suffix_for_stats(),::grpc::internal::RpcMethod::CLIENT_STREAMING, channel)
   {}
 
 ::grpc::Status Region::Stub::Handle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::greptime::v1::region::RegionResponse* response) {
@@ -62,22 +60,6 @@ void Region::Stub::async::Handle(::grpc::ClientContext* context, const ::greptim
   return result;
 }
 
-::grpc::ClientWriter< ::greptime::v1::region::RegionRequest>* Region::Stub::HandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response) {
-  return ::grpc::internal::ClientWriterFactory< ::greptime::v1::region::RegionRequest>::Create(channel_.get(), rpcmethod_HandleRequests_, context, response);
-}
-
-void Region::Stub::async::HandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::ClientWriteReactor< ::greptime::v1::region::RegionRequest>* reactor) {
-  ::grpc::internal::ClientCallbackWriterFactory< ::greptime::v1::region::RegionRequest>::Create(stub_->channel_.get(), stub_->rpcmethod_HandleRequests_, context, response, reactor);
-}
-
-::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>* Region::Stub::AsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq, void* tag) {
-  return ::grpc::internal::ClientAsyncWriterFactory< ::greptime::v1::region::RegionRequest>::Create(channel_.get(), cq, rpcmethod_HandleRequests_, context, response, true, tag);
-}
-
-::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>* Region::Stub::PrepareAsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq) {
-  return ::grpc::internal::ClientAsyncWriterFactory< ::greptime::v1::region::RegionRequest>::Create(channel_.get(), cq, rpcmethod_HandleRequests_, context, response, false, nullptr);
-}
-
 Region::Service::Service() {
   AddMethod(new ::grpc::internal::RpcServiceMethod(
       Region_method_names[0],
@@ -89,16 +71,6 @@ Region::Service::Service() {
              ::greptime::v1::region::RegionResponse* resp) {
                return service->Handle(ctx, req, resp);
              }, this)));
-  AddMethod(new ::grpc::internal::RpcServiceMethod(
-      Region_method_names[1],
-      ::grpc::internal::RpcMethod::CLIENT_STREAMING,
-      new ::grpc::internal::ClientStreamingHandler< Region::Service, ::greptime::v1::region::RegionRequest, ::greptime::v1::region::RegionResponse>(
-          [](Region::Service* service,
-             ::grpc::ServerContext* ctx,
-             ::grpc::ServerReader<::greptime::v1::region::RegionRequest>* reader,
-             ::greptime::v1::region::RegionResponse* resp) {
-               return service->HandleRequests(ctx, reader, resp);
-             }, this)));
 }
 
 Region::Service::~Service() {
@@ -111,13 +83,6 @@ Region::Service::~Service() {
   return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
 }
 
-::grpc::Status Region::Service::HandleRequests(::grpc::ServerContext* context, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* reader, ::greptime::v1::region::RegionResponse* response) {
-  (void) context;
-  (void) reader;
-  (void) response;
-  return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-}
-
 
 }  // namespace greptime
 }  // namespace v1

c++/greptime/v1/region/server.grpc.pb.h

@@ -59,21 +59,11 @@ class Region final {
     std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::greptime::v1::region::RegionResponse>> PrepareAsyncHandle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) {
       return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::greptime::v1::region::RegionResponse>>(PrepareAsyncHandleRaw(context, request, cq));
     }
-    std::unique_ptr< ::grpc::ClientWriterInterface< ::greptime::v1::region::RegionRequest>> HandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response) {
-      return std::unique_ptr< ::grpc::ClientWriterInterface< ::greptime::v1::region::RegionRequest>>(HandleRequestsRaw(context, response));
-    }
-    std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>> AsyncHandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq, void* tag) {
-      return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>>(AsyncHandleRequestsRaw(context, response, cq, tag));
-    }
-    std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>> PrepareAsyncHandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq) {
-      return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>>(PrepareAsyncHandleRequestsRaw(context, response, cq));
-    }
     class async_interface {
      public:
       virtual ~async_interface() {}
       virtual void Handle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest* request, ::greptime::v1::region::RegionResponse* response, std::function<void(::grpc::Status)>) = 0;
       virtual void Handle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest* request, ::greptime::v1::region::RegionResponse* response, ::grpc::ClientUnaryReactor* reactor) = 0;
-      virtual void HandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::ClientWriteReactor< ::greptime::v1::region::RegionRequest>* reactor) = 0;
     };
     typedef class async_interface experimental_async_interface;
     virtual class async_interface* async() { return nullptr; }
@@ -81,9 +71,6 @@ class Region final {
    private:
     virtual ::grpc::ClientAsyncResponseReaderInterface< ::greptime::v1::region::RegionResponse>* AsyncHandleRaw(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) = 0;
     virtual ::grpc::ClientAsyncResponseReaderInterface< ::greptime::v1::region::RegionResponse>* PrepareAsyncHandleRaw(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) = 0;
-    virtual ::grpc::ClientWriterInterface< ::greptime::v1::region::RegionRequest>* HandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response) = 0;
-    virtual ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>* AsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq, void* tag) = 0;
-    virtual ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>* PrepareAsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq) = 0;
   };
   class Stub final : public StubInterface {
    public:
@@ -95,21 +82,11 @@ class Region final {
     std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::greptime::v1::region::RegionResponse>> PrepareAsyncHandle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) {
       return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::greptime::v1::region::RegionResponse>>(PrepareAsyncHandleRaw(context, request, cq));
     }
-    std::unique_ptr< ::grpc::ClientWriter< ::greptime::v1::region::RegionRequest>> HandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response) {
-      return std::unique_ptr< ::grpc::ClientWriter< ::greptime::v1::region::RegionRequest>>(HandleRequestsRaw(context, response));
-    }
-    std::unique_ptr< ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>> AsyncHandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq, void* tag) {
-      return std::unique_ptr< ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>>(AsyncHandleRequestsRaw(context, response, cq, tag));
-    }
-    std::unique_ptr< ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>> PrepareAsyncHandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq) {
-      return std::unique_ptr< ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>>(PrepareAsyncHandleRequestsRaw(context, response, cq));
-    }
     class async final :
       public StubInterface::async_interface {
      public:
       void Handle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest* request, ::greptime::v1::region::RegionResponse* response, std::function<void(::grpc::Status)>) override;
       void Handle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest* request, ::greptime::v1::region::RegionResponse* response, ::grpc::ClientUnaryReactor* reactor) override;
-      void HandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::ClientWriteReactor< ::greptime::v1::region::RegionRequest>* reactor) override;
      private:
       friend class Stub;
       explicit async(Stub* stub): stub_(stub) { }
@@ -123,11 +100,7 @@ class Region final {
     class async async_stub_{this};
     ::grpc::ClientAsyncResponseReader< ::greptime::v1::region::RegionResponse>* AsyncHandleRaw(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) override;
     ::grpc::ClientAsyncResponseReader< ::greptime::v1::region::RegionResponse>* PrepareAsyncHandleRaw(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) override;
-    ::grpc::ClientWriter< ::greptime::v1::region::RegionRequest>* HandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response) override;
-    ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>* AsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq, void* tag) override;
-    ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>* PrepareAsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq) override;
     const ::grpc::internal::RpcMethod rpcmethod_Handle_;
-    const ::grpc::internal::RpcMethod rpcmethod_HandleRequests_;
   };
   static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
 
@@ -136,7 +109,6 @@ class Region final {
     Service();
     virtual ~Service();
     virtual ::grpc::Status Handle(::grpc::ServerContext* context, const ::greptime::v1::region::RegionRequest* request, ::greptime::v1::region::RegionResponse* response);
-    virtual ::grpc::Status HandleRequests(::grpc::ServerContext* context, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* reader, ::greptime::v1::region::RegionResponse* response);
   };
   template <class BaseClass>
   class WithAsyncMethod_Handle : public BaseClass {
@@ -158,27 +130,7 @@ class Region final {
       ::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
     }
   };
-  template <class BaseClass>
+  typedef WithAsyncMethod_Handle<Service > AsyncService;
-  class WithAsyncMethod_HandleRequests : public BaseClass {
-   private:
-    void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
-   public:
-    WithAsyncMethod_HandleRequests() {
-      ::grpc::Service::MarkMethodAsync(1);
-    }
-    ~WithAsyncMethod_HandleRequests() override {
-      BaseClassMustBeDerivedFromService(this);
-    }
-    // disable synchronous version of this method
-    ::grpc::Status HandleRequests(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* /*reader*/, ::greptime::v1::region::RegionResponse* /*response*/) override {
-      abort();
-      return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-    }
-    void RequestHandleRequests(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::greptime::v1::region::RegionResponse, ::greptime::v1::region::RegionRequest>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
-      ::grpc::Service::RequestAsyncClientStreaming(1, context, reader, new_call_cq, notification_cq, tag);
-    }
-  };
-  typedef WithAsyncMethod_Handle<WithAsyncMethod_HandleRequests<Service > > AsyncService;
   template <class BaseClass>
   class WithCallbackMethod_Handle : public BaseClass {
    private:
@@ -206,29 +158,7 @@ class Region final {
     virtual ::grpc::ServerUnaryReactor* Handle(
       ::grpc::CallbackServerContext* /*context*/, const ::greptime::v1::region::RegionRequest* /*request*/, ::greptime::v1::region::RegionResponse* /*response*/)  { return nullptr; }
   };
-  template <class BaseClass>
+  typedef WithCallbackMethod_Handle<Service > CallbackService;
-  class WithCallbackMethod_HandleRequests : public BaseClass {
-   private:
-    void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
-   public:
-    WithCallbackMethod_HandleRequests() {
-      ::grpc::Service::MarkMethodCallback(1,
-          new ::grpc::internal::CallbackClientStreamingHandler< ::greptime::v1::region::RegionRequest, ::greptime::v1::region::RegionResponse>(
-            [this](
-                   ::grpc::CallbackServerContext* context, ::greptime::v1::region::RegionResponse* response) { return this->HandleRequests(context, response); }));
-    }
-    ~WithCallbackMethod_HandleRequests() override {
-      BaseClassMustBeDerivedFromService(this);
-    }
-    // disable synchronous version of this method
-    ::grpc::Status HandleRequests(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* /*reader*/, ::greptime::v1::region::RegionResponse* /*response*/) override {
-      abort();
-      return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-    }
-    virtual ::grpc::ServerReadReactor< ::greptime::v1::region::RegionRequest>* HandleRequests(
-      ::grpc::CallbackServerContext* /*context*/, ::greptime::v1::region::RegionResponse* /*response*/)  { return nullptr; }
-  };
-  typedef WithCallbackMethod_Handle<WithCallbackMethod_HandleRequests<Service > > CallbackService;
   typedef CallbackService ExperimentalCallbackService;
   template <class BaseClass>
   class WithGenericMethod_Handle : public BaseClass {
@@ -248,23 +178,6 @@ class Region final {
     }
   };
   template <class BaseClass>
-  class WithGenericMethod_HandleRequests : public BaseClass {
-   private:
-    void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
-   public:
-    WithGenericMethod_HandleRequests() {
-      ::grpc::Service::MarkMethodGeneric(1);
-    }
-    ~WithGenericMethod_HandleRequests() override {
-      BaseClassMustBeDerivedFromService(this);
-    }
-    // disable synchronous version of this method
-    ::grpc::Status HandleRequests(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* /*reader*/, ::greptime::v1::region::RegionResponse* /*response*/) override {
-      abort();
-      return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-    }
-  };
-  template <class BaseClass>
   class WithRawMethod_Handle : public BaseClass {
    private:
     void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
@@ -285,26 +198,6 @@ class Region final {
     }
   };
   template <class BaseClass>
-  class WithRawMethod_HandleRequests : public BaseClass {
-   private:
-    void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
-   public:
-    WithRawMethod_HandleRequests() {
-      ::grpc::Service::MarkMethodRaw(1);
-    }
-    ~WithRawMethod_HandleRequests() override {
-      BaseClassMustBeDerivedFromService(this);
-    }
-    // disable synchronous version of this method
-    ::grpc::Status HandleRequests(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* /*reader*/, ::greptime::v1::region::RegionResponse* /*response*/) override {
-      abort();
-      return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-    }
-    void RequestHandleRequests(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
-      ::grpc::Service::RequestAsyncClientStreaming(1, context, reader, new_call_cq, notification_cq, tag);
-    }
-  };
-  template <class BaseClass>
   class WithRawCallbackMethod_Handle : public BaseClass {
    private:
     void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
@@ -327,28 +220,6 @@ class Region final {
       ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/)  { return nullptr; }
   };
   template <class BaseClass>
-  class WithRawCallbackMethod_HandleRequests : public BaseClass {
-   private:
-    void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
-   public:
-    WithRawCallbackMethod_HandleRequests() {
-      ::grpc::Service::MarkMethodRawCallback(1,
-          new ::grpc::internal::CallbackClientStreamingHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>(
-            [this](
-                   ::grpc::CallbackServerContext* context, ::grpc::ByteBuffer* response) { return this->HandleRequests(context, response); }));
-    }
-    ~WithRawCallbackMethod_HandleRequests() override {
-      BaseClassMustBeDerivedFromService(this);
-    }
-    // disable synchronous version of this method
-    ::grpc::Status HandleRequests(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* /*reader*/, ::greptime::v1::region::RegionResponse* /*response*/) override {
-      abort();
-      return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-    }
-    virtual ::grpc::ServerReadReactor< ::grpc::ByteBuffer>* HandleRequests(
-      ::grpc::CallbackServerContext* /*context*/, ::grpc::ByteBuffer* /*response*/)  { return nullptr; }
-  };
-  template <class BaseClass>
   class WithStreamedUnaryMethod_Handle : public BaseClass {
    private:
     void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}

c++/greptime/v1/region/server.pb.cc

@@ -80,7 +80,7 @@ struct DeleteRequestsDefaultTypeInternal {
 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DeleteRequestsDefaultTypeInternal _DeleteRequests_default_instance_;
 PROTOBUF_CONSTEXPR InsertRequest::InsertRequest(
     ::_pbi::ConstantInitialized): _impl_{
-    /*decltype(_impl_.rows_)*/{}
+    /*decltype(_impl_.rows_)*/nullptr
   , /*decltype(_impl_.region_id_)*/uint64_t{0u}
   , /*decltype(_impl_._cached_size_)*/{}} {}
 struct InsertRequestDefaultTypeInternal {
@@ -94,7 +94,7 @@ struct InsertRequestDefaultTypeInternal {
 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 InsertRequestDefaultTypeInternal _InsertRequest_default_instance_;
 PROTOBUF_CONSTEXPR DeleteRequest::DeleteRequest(
     ::_pbi::ConstantInitialized): _impl_{
-    /*decltype(_impl_.rows_)*/{}
+    /*decltype(_impl_.rows_)*/nullptr
   , /*decltype(_impl_.region_id_)*/uint64_t{0u}
   , /*decltype(_impl_._cached_size_)*/{}} {}
 struct DeleteRequestDefaultTypeInternal {
@@ -485,40 +485,38 @@ const char descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto[] P
   "s\030\002 \001(\004\"E\n\016InsertRequests\0223\n\010requests\030\001 "
   "\003(\0132!.greptime.v1.region.InsertRequest\"E"
   "\n\016DeleteRequests\0223\n\010requests\030\001 \003(\0132!.gre"
-  "ptime.v1.region.DeleteRequest\"B\n\rInsertR"
+  "ptime.v1.region.DeleteRequest\"C\n\rInsertR"
-  "equest\022\021\n\tregion_id\030\001 \001(\004\022\036\n\004rows\030\002 \003(\0132"
+  "equest\022\021\n\tregion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132"
-  "\020.greptime.v1.Row\"B\n\rDeleteRequest\022\021\n\tre"
+  "\021.greptime.v1.Rows\"C\n\rDeleteRequest\022\021\n\tr"
-  "gion_id\030\001 \001(\004\022\036\n\004rows\030\002 \003(\0132\020.greptime.v"
+  "egion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132\021.greptime."
-  "1.Row\"/\n\014QueryRequest\022\021\n\tregion_id\030\001 \001(\004"
+  "v1.Rows\"/\n\014QueryRequest\022\021\n\tregion_id\030\001 \001"
-  "\022\014\n\004plan\030\002 \001(\014\"\236\002\n\rCreateRequest\022\021\n\tregi"
+  "(\004\022\014\n\004plan\030\002 \001(\014\"\236\002\n\rCreateRequest\022\021\n\tre"
-  "on_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\0222\n\013column_de"
+  "gion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\0222\n\013column_"
-  "fs\030\003 \003(\0132\035.greptime.v1.region.ColumnDef\022"
+  "defs\030\003 \003(\0132\035.greptime.v1.region.ColumnDe"
-  "\023\n\013primary_key\030\004 \003(\r\022\034\n\024create_if_not_ex"
+  "f\022\023\n\013primary_key\030\004 \003(\r\022\034\n\024create_if_not_"
-  "ists\030\005 \001(\010\022\022\n\nregion_dir\030\006 \001(\t\022\?\n\007option"
+  "exists\030\005 \001(\010\022\022\n\nregion_dir\030\006 \001(\t\022\?\n\007opti"
-  "s\030\007 \003(\0132..greptime.v1.region.CreateReque"
+  "ons\030\007 \003(\0132..greptime.v1.region.CreateReq"
-  "st.OptionsEntry\032.\n\014OptionsEntry\022\013\n\003key\030\001"
+  "uest.OptionsEntry\032.\n\014OptionsEntry\022\013\n\003key"
-  " \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\" \n\013DropRequest\022\021"
+  "\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\" \n\013DropRequest"
-  "\n\tregion_id\030\001 \001(\004\"\263\001\n\013OpenRequest\022\021\n\treg"
+  "\022\021\n\tregion_id\030\001 \001(\004\"\263\001\n\013OpenRequest\022\021\n\tr"
-  "ion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022\022\n\nregion_d"
+  "egion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022\022\n\nregion"
-  "ir\030\003 \001(\t\022=\n\007options\030\004 \003(\0132,.greptime.v1."
+  "_dir\030\003 \001(\t\022=\n\007options\030\004 \003(\0132,.greptime.v"
-  "region.OpenRequest.OptionsEntry\032.\n\014Optio"
+  "1.region.OpenRequest.OptionsEntry\032.\n\014Opt"
-  "nsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\""
+  "ionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028"
-  "!\n\014CloseRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014Al"
+  "\001\"!\n\014CloseRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014"
-  "terRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014FlushRe"
+  "AlterRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014Flush"
-  "quest\022\021\n\tregion_id\030\001 \001(\004\"#\n\016CompactReque"
+  "Request\022\021\n\tregion_id\030\001 \001(\004\"#\n\016CompactReq"
-  "st\022\021\n\tregion_id\030\001 \001(\004\"\276\001\n\tColumnDef\022\014\n\004n"
+  "uest\022\021\n\tregion_id\030\001 \001(\004\"\276\001\n\tColumnDef\022\014\n"
-  "ame\030\001 \001(\t\022\021\n\tcolumn_id\030\002 \001(\r\022-\n\010datatype"
+  "\004name\030\001 \001(\t\022\021\n\tcolumn_id\030\002 \001(\r\022-\n\010dataty"
-  "\030\003 \001(\0162\033.greptime.v1.ColumnDataType\022\023\n\013i"
+  "pe\030\003 \001(\0162\033.greptime.v1.ColumnDataType\022\023\n"
-  "s_nullable\030\004 \001(\010\022\032\n\022default_constraint\030\005"
+  "\013is_nullable\030\004 \001(\010\022\032\n\022default_constraint"
-  " \001(\014\0220\n\rsemantic_type\030\006 \001(\0162\031.greptime.v"
+  "\030\005 \001(\014\0220\n\rsemantic_type\030\006 \001(\0162\031.greptime"
-  "1.SemanticType2\264\001\n\006Region\022O\n\006Handle\022!.gr"
+  ".v1.SemanticType2Y\n\006Region\022O\n\006Handle\022!.g"
-  "eptime.v1.region.RegionRequest\032\".greptim"
+  "reptime.v1.region.RegionRequest\032\".grepti"
-  "e.v1.region.RegionResponse\022Y\n\016HandleRequ"
+  "me.v1.region.RegionResponseB]\n\025io.grepti"
-  "ests\022!.greptime.v1.region.RegionRequest\032"
+  "me.v1.regionB\006ServerZ<github.com/Greptim"
-  "\".greptime.v1.region.RegionResponse(\001B]\n"
+  "eTeam/greptime-proto/go/greptime/v1/regi"
-  "\025io.greptime.v1.regionB\006ServerZ<github.c"
+  "onb\006proto3"
-  "om/GreptimeTeam/greptime-proto/go/grepti"
-  "me/v1/regionb\006proto3"
   ;
 static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_deps[2] = {
   &::descriptor_table_greptime_2fv1_2fcommon_2eproto,
@@ -526,7 +524,7 @@ static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2freg
 };
 static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once;
 const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto = {
-    false, false, 2180, descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto,
+    false, false, 2090, descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto,
     "greptime/v1/region/server.proto",
     &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_deps, 2, 17,
     schemas, file_default_instances, TableStruct_greptime_2fv1_2fregion_2fserver_2eproto::offsets,
@@ -1906,10 +1904,18 @@ void DeleteRequests::InternalSwap(DeleteRequests* other) {
 
 class InsertRequest::_Internal {
  public:
+  static const ::greptime::v1::Rows& rows(const InsertRequest* msg);
 };
 
+const ::greptime::v1::Rows&
+InsertRequest::_Internal::rows(const InsertRequest* msg) {
+  return *msg->_impl_.rows_;
+}
 void InsertRequest::clear_rows() {
-  _impl_.rows_.Clear();
+  if (GetArenaForAllocation() == nullptr && _impl_.rows_ != nullptr) {
+    delete _impl_.rows_;
+  }
+  _impl_.rows_ = nullptr;
 }
 InsertRequest::InsertRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
                          bool is_message_owned)
@@ -1921,11 +1927,14 @@ InsertRequest::InsertRequest(const InsertRequest& from)
   : ::PROTOBUF_NAMESPACE_ID::Message() {
   InsertRequest* const _this = this; (void)_this;
   new (&_impl_) Impl_{
-      decltype(_impl_.rows_){from._impl_.rows_}
+      decltype(_impl_.rows_){nullptr}
     , decltype(_impl_.region_id_){}
     , /*decltype(_impl_._cached_size_)*/{}};
 
   _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+  if (from._internal_has_rows()) {
+    _this->_impl_.rows_ = new ::greptime::v1::Rows(*from._impl_.rows_);
+  }
   _this->_impl_.region_id_ = from._impl_.region_id_;
   // @@protoc_insertion_point(copy_constructor:greptime.v1.region.InsertRequest)
 }
@@ -1935,7 +1944,7 @@ inline void InsertRequest::SharedCtor(
   (void)arena;
   (void)is_message_owned;
   new (&_impl_) Impl_{
-      decltype(_impl_.rows_){arena}
+      decltype(_impl_.rows_){nullptr}
     , decltype(_impl_.region_id_){uint64_t{0u}}
     , /*decltype(_impl_._cached_size_)*/{}
   };
@@ -1952,7 +1961,7 @@ InsertRequest::~InsertRequest() {
 
 inline void InsertRequest::SharedDtor() {
   GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
-  _impl_.rows_.~RepeatedPtrField();
+  if (this != internal_default_instance()) delete _impl_.rows_;
 }
 
 void InsertRequest::SetCachedSize(int size) const {
@@ -1965,7 +1974,10 @@ void InsertRequest::Clear() {
   // Prevent compiler warnings about cached_has_bits being unused
   (void) cached_has_bits;
 
-  _impl_.rows_.Clear();
+  if (GetArenaForAllocation() == nullptr && _impl_.rows_ != nullptr) {
+    delete _impl_.rows_;
+  }
+  _impl_.rows_ = nullptr;
   _impl_.region_id_ = uint64_t{0u};
   _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
 }
@@ -1984,16 +1996,11 @@ const char* InsertRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext*
         } else
           goto handle_unusual;
         continue;
-      // repeated .greptime.v1.Row rows = 2;
+      // .greptime.v1.Rows rows = 2;
       case 2:
         if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 18)) {
-          ptr -= 1;
+          ptr = ctx->ParseMessage(_internal_mutable_rows(), ptr);
-          do {
+          CHK_(ptr);
-            ptr += 1;
-            ptr = ctx->ParseMessage(_internal_add_rows(), ptr);
-            CHK_(ptr);
-            if (!ctx->DataAvailable(ptr)) break;
-          } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<18>(ptr));
         } else
           goto handle_unusual;
         continue;
@@ -2032,12 +2039,11 @@ uint8_t* InsertRequest::_InternalSerialize(
     target = ::_pbi::WireFormatLite::WriteUInt64ToArray(1, this->_internal_region_id(), target);
   }
 
-  // repeated .greptime.v1.Row rows = 2;
+  // .greptime.v1.Rows rows = 2;
-  for (unsigned i = 0,
+  if (this->_internal_has_rows()) {
-      n = static_cast<unsigned>(this->_internal_rows_size()); i < n; i++) {
-    const auto& repfield = this->_internal_rows(i);
     target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
-        InternalWriteMessage(2, repfield, repfield.GetCachedSize(), target, stream);
+      InternalWriteMessage(2, _Internal::rows(this),
+        _Internal::rows(this).GetCachedSize(), target, stream);
   }
 
   if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
@@ -2056,11 +2062,11 @@ size_t InsertRequest::ByteSizeLong() const {
   // Prevent compiler warnings about cached_has_bits being unused
   (void) cached_has_bits;
 
-  // repeated .greptime.v1.Row rows = 2;
+  // .greptime.v1.Rows rows = 2;
-  total_size += 1UL * this->_internal_rows_size();
+  if (this->_internal_has_rows()) {
-  for (const auto& msg : this->_impl_.rows_) {
+    total_size += 1 +
-    total_size +=
+      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
-      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(msg);
+        *_impl_.rows_);
   }
 
   // uint64 region_id = 1;
@@ -2086,7 +2092,10 @@ void InsertRequest::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::
   uint32_t cached_has_bits = 0;
   (void) cached_has_bits;
 
-  _this->_impl_.rows_.MergeFrom(from._impl_.rows_);
+  if (from._internal_has_rows()) {
+    _this->_internal_mutable_rows()->::greptime::v1::Rows::MergeFrom(
+        from._internal_rows());
+  }
   if (from._internal_region_id() != 0) {
     _this->_internal_set_region_id(from._internal_region_id());
   }
@@ -2107,8 +2116,12 @@ bool InsertRequest::IsInitialized() const {
 void InsertRequest::InternalSwap(InsertRequest* other) {
   using std::swap;
   _internal_metadata_.InternalSwap(&other->_internal_metadata_);
-  _impl_.rows_.InternalSwap(&other->_impl_.rows_);
+  ::PROTOBUF_NAMESPACE_ID::internal::memswap<
-  swap(_impl_.region_id_, other->_impl_.region_id_);
+      PROTOBUF_FIELD_OFFSET(InsertRequest, _impl_.region_id_)
+      + sizeof(InsertRequest::_impl_.region_id_)
+      - PROTOBUF_FIELD_OFFSET(InsertRequest, _impl_.rows_)>(
+          reinterpret_cast<char*>(&_impl_.rows_),
+          reinterpret_cast<char*>(&other->_impl_.rows_));
 }
 
 ::PROTOBUF_NAMESPACE_ID::Metadata InsertRequest::GetMetadata() const {
@@ -2121,10 +2134,18 @@ void InsertRequest::InternalSwap(InsertRequest* other) {
 
 class DeleteRequest::_Internal {
  public:
+  static const ::greptime::v1::Rows& rows(const DeleteRequest* msg);
 };
 
+const ::greptime::v1::Rows&
+DeleteRequest::_Internal::rows(const DeleteRequest* msg) {
+  return *msg->_impl_.rows_;
+}
 void DeleteRequest::clear_rows() {
-  _impl_.rows_.Clear();
+  if (GetArenaForAllocation() == nullptr && _impl_.rows_ != nullptr) {
+    delete _impl_.rows_;
+  }
+  _impl_.rows_ = nullptr;
 }
 DeleteRequest::DeleteRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
                          bool is_message_owned)
@@ -2136,11 +2157,14 @@ DeleteRequest::DeleteRequest(const DeleteRequest& from)
   : ::PROTOBUF_NAMESPACE_ID::Message() {
   DeleteRequest* const _this = this; (void)_this;
   new (&_impl_) Impl_{
-      decltype(_impl_.rows_){from._impl_.rows_}
+      decltype(_impl_.rows_){nullptr}
     , decltype(_impl_.region_id_){}
     , /*decltype(_impl_._cached_size_)*/{}};
 
   _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+  if (from._internal_has_rows()) {
+    _this->_impl_.rows_ = new ::greptime::v1::Rows(*from._impl_.rows_);
+  }
   _this->_impl_.region_id_ = from._impl_.region_id_;
   // @@protoc_insertion_point(copy_constructor:greptime.v1.region.DeleteRequest)
 }
@@ -2150,7 +2174,7 @@ inline void DeleteRequest::SharedCtor(
   (void)arena;
   (void)is_message_owned;
   new (&_impl_) Impl_{
-      decltype(_impl_.rows_){arena}
+      decltype(_impl_.rows_){nullptr}
     , decltype(_impl_.region_id_){uint64_t{0u}}
     , /*decltype(_impl_._cached_size_)*/{}
   };
@@ -2167,7 +2191,7 @@ DeleteRequest::~DeleteRequest() {
 
 inline void DeleteRequest::SharedDtor() {
   GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
-  _impl_.rows_.~RepeatedPtrField();
+  if (this != internal_default_instance()) delete _impl_.rows_;
 }
 
 void DeleteRequest::SetCachedSize(int size) const {
@@ -2180,7 +2204,10 @@ void DeleteRequest::Clear() {
   // Prevent compiler warnings about cached_has_bits being unused
   (void) cached_has_bits;
 
-  _impl_.rows_.Clear();
+  if (GetArenaForAllocation() == nullptr && _impl_.rows_ != nullptr) {
+    delete _impl_.rows_;
+  }
+  _impl_.rows_ = nullptr;
   _impl_.region_id_ = uint64_t{0u};
   _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
 }
@@ -2199,16 +2226,11 @@ const char* DeleteRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext*
         } else
           goto handle_unusual;
         continue;
-      // repeated .greptime.v1.Row rows = 2;
+      // .greptime.v1.Rows rows = 2;
       case 2:
         if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 18)) {
-          ptr -= 1;
+          ptr = ctx->ParseMessage(_internal_mutable_rows(), ptr);
-          do {
+          CHK_(ptr);
-            ptr += 1;
-            ptr = ctx->ParseMessage(_internal_add_rows(), ptr);
-            CHK_(ptr);
-            if (!ctx->DataAvailable(ptr)) break;
-          } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<18>(ptr));
         } else
           goto handle_unusual;
         continue;
@@ -2247,12 +2269,11 @@ uint8_t* DeleteRequest::_InternalSerialize(
     target = ::_pbi::WireFormatLite::WriteUInt64ToArray(1, this->_internal_region_id(), target);
   }
 
-  // repeated .greptime.v1.Row rows = 2;
+  // .greptime.v1.Rows rows = 2;
-  for (unsigned i = 0,
+  if (this->_internal_has_rows()) {
-      n = static_cast<unsigned>(this->_internal_rows_size()); i < n; i++) {
-    const auto& repfield = this->_internal_rows(i);
     target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
-        InternalWriteMessage(2, repfield, repfield.GetCachedSize(), target, stream);
+      InternalWriteMessage(2, _Internal::rows(this),
+        _Internal::rows(this).GetCachedSize(), target, stream);
   }
 
   if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
@@ -2271,11 +2292,11 @@ size_t DeleteRequest::ByteSizeLong() const {
   // Prevent compiler warnings about cached_has_bits being unused
   (void) cached_has_bits;
 
-  // repeated .greptime.v1.Row rows = 2;
+  // .greptime.v1.Rows rows = 2;
-  total_size += 1UL * this->_internal_rows_size();
+  if (this->_internal_has_rows()) {
-  for (const auto& msg : this->_impl_.rows_) {
+    total_size += 1 +
-    total_size +=
+      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
-      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(msg);
+        *_impl_.rows_);
   }
 
   // uint64 region_id = 1;
@@ -2301,7 +2322,10 @@ void DeleteRequest::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::
   uint32_t cached_has_bits = 0;
   (void) cached_has_bits;
 
-  _this->_impl_.rows_.MergeFrom(from._impl_.rows_);
+  if (from._internal_has_rows()) {
+    _this->_internal_mutable_rows()->::greptime::v1::Rows::MergeFrom(
+        from._internal_rows());
+  }
   if (from._internal_region_id() != 0) {
     _this->_internal_set_region_id(from._internal_region_id());
   }
@@ -2322,8 +2346,12 @@ bool DeleteRequest::IsInitialized() const {
 void DeleteRequest::InternalSwap(DeleteRequest* other) {
   using std::swap;
   _internal_metadata_.InternalSwap(&other->_internal_metadata_);
-  _impl_.rows_.InternalSwap(&other->_impl_.rows_);
+  ::PROTOBUF_NAMESPACE_ID::internal::memswap<
-  swap(_impl_.region_id_, other->_impl_.region_id_);
+      PROTOBUF_FIELD_OFFSET(DeleteRequest, _impl_.region_id_)
+      + sizeof(DeleteRequest::_impl_.region_id_)
+      - PROTOBUF_FIELD_OFFSET(DeleteRequest, _impl_.rows_)>(
+          reinterpret_cast<char*>(&_impl_.rows_),
+          reinterpret_cast<char*>(&other->_impl_.rows_));
 }
 
 ::PROTOBUF_NAMESPACE_ID::Metadata DeleteRequest::GetMetadata() const {

c++/greptime/v1/region/server.pb.h

@@ -1107,23 +1107,23 @@ class InsertRequest final :
     kRowsFieldNumber = 2,
     kRegionIdFieldNumber = 1,
   };
-  // repeated .greptime.v1.Row rows = 2;
+  // .greptime.v1.Rows rows = 2;
-  int rows_size() const;
+  bool has_rows() const;
   private:
-  int _internal_rows_size() const;
+  bool _internal_has_rows() const;
   public:
   void clear_rows();
-  ::greptime::v1::Row* mutable_rows(int index);
+  const ::greptime::v1::Rows& rows() const;
-  ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >*
+  PROTOBUF_NODISCARD ::greptime::v1::Rows* release_rows();
-      mutable_rows();
+  ::greptime::v1::Rows* mutable_rows();
+  void set_allocated_rows(::greptime::v1::Rows* rows);
   private:
-  const ::greptime::v1::Row& _internal_rows(int index) const;
+  const ::greptime::v1::Rows& _internal_rows() const;
-  ::greptime::v1::Row* _internal_add_rows();
+  ::greptime::v1::Rows* _internal_mutable_rows();
   public:
-  const ::greptime::v1::Row& rows(int index) const;
+  void unsafe_arena_set_allocated_rows(
-  ::greptime::v1::Row* add_rows();
+      ::greptime::v1::Rows* rows);
-  const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >&
+  ::greptime::v1::Rows* unsafe_arena_release_rows();
-      rows() const;
 
   // uint64 region_id = 1;
   void clear_region_id();
@@ -1142,7 +1142,7 @@ class InsertRequest final :
   typedef void InternalArenaConstructable_;
   typedef void DestructorSkippable_;
   struct Impl_ {
-    ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row > rows_;
+    ::greptime::v1::Rows* rows_;
     uint64_t region_id_;
     mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
   };
@@ -1275,23 +1275,23 @@ class DeleteRequest final :
     kRowsFieldNumber = 2,
     kRegionIdFieldNumber = 1,
   };
-  // repeated .greptime.v1.Row rows = 2;
+  // .greptime.v1.Rows rows = 2;
-  int rows_size() const;
+  bool has_rows() const;
   private:
-  int _internal_rows_size() const;
+  bool _internal_has_rows() const;
   public:
   void clear_rows();
-  ::greptime::v1::Row* mutable_rows(int index);
+  const ::greptime::v1::Rows& rows() const;
-  ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >*
+  PROTOBUF_NODISCARD ::greptime::v1::Rows* release_rows();
-      mutable_rows();
+  ::greptime::v1::Rows* mutable_rows();
+  void set_allocated_rows(::greptime::v1::Rows* rows);
   private:
-  const ::greptime::v1::Row& _internal_rows(int index) const;
+  const ::greptime::v1::Rows& _internal_rows() const;
-  ::greptime::v1::Row* _internal_add_rows();
+  ::greptime::v1::Rows* _internal_mutable_rows();
   public:
-  const ::greptime::v1::Row& rows(int index) const;
+  void unsafe_arena_set_allocated_rows(
-  ::greptime::v1::Row* add_rows();
+      ::greptime::v1::Rows* rows);
-  const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >&
+  ::greptime::v1::Rows* unsafe_arena_release_rows();
-      rows() const;
 
   // uint64 region_id = 1;
   void clear_region_id();
@@ -1310,7 +1310,7 @@ class DeleteRequest final :
   typedef void InternalArenaConstructable_;
   typedef void DestructorSkippable_;
   struct Impl_ {
-    ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row > rows_;
+    ::greptime::v1::Rows* rows_;
     uint64_t region_id_;
     mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
   };
@@ -3950,42 +3950,90 @@ inline void InsertRequest::set_region_id(uint64_t value) {
   // @@protoc_insertion_point(field_set:greptime.v1.region.InsertRequest.region_id)
 }
 
-// repeated .greptime.v1.Row rows = 2;
+// .greptime.v1.Rows rows = 2;
-inline int InsertRequest::_internal_rows_size() const {
+inline bool InsertRequest::_internal_has_rows() const {
-  return _impl_.rows_.size();
+  return this != internal_default_instance() && _impl_.rows_ != nullptr;
 }
-inline int InsertRequest::rows_size() const {
+inline bool InsertRequest::has_rows() const {
-  return _internal_rows_size();
+  return _internal_has_rows();
 }
-inline ::greptime::v1::Row* InsertRequest::mutable_rows(int index) {
+inline const ::greptime::v1::Rows& InsertRequest::_internal_rows() const {
-  // @@protoc_insertion_point(field_mutable:greptime.v1.region.InsertRequest.rows)
+  const ::greptime::v1::Rows* p = _impl_.rows_;
-  return _impl_.rows_.Mutable(index);
+  return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::Rows&>(
+      ::greptime::v1::_Rows_default_instance_);
 }
-inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >*
+inline const ::greptime::v1::Rows& InsertRequest::rows() const {
-InsertRequest::mutable_rows() {
-  // @@protoc_insertion_point(field_mutable_list:greptime.v1.region.InsertRequest.rows)
-  return &_impl_.rows_;
-}
-inline const ::greptime::v1::Row& InsertRequest::_internal_rows(int index) const {
-  return _impl_.rows_.Get(index);
-}
-inline const ::greptime::v1::Row& InsertRequest::rows(int index) const {
   // @@protoc_insertion_point(field_get:greptime.v1.region.InsertRequest.rows)
-  return _internal_rows(index);
+  return _internal_rows();
 }
-inline ::greptime::v1::Row* InsertRequest::_internal_add_rows() {
+inline void InsertRequest::unsafe_arena_set_allocated_rows(
-  return _impl_.rows_.Add();
+    ::greptime::v1::Rows* rows) {
+  if (GetArenaForAllocation() == nullptr) {
+    delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.rows_);
+  }
+  _impl_.rows_ = rows;
+  if (rows) {
+    
+  } else {
+    
+  }
+  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.region.InsertRequest.rows)
 }
-inline ::greptime::v1::Row* InsertRequest::add_rows() {
+inline ::greptime::v1::Rows* InsertRequest::release_rows() {
-  ::greptime::v1::Row* _add = _internal_add_rows();
+  
-  // @@protoc_insertion_point(field_add:greptime.v1.region.InsertRequest.rows)
+  ::greptime::v1::Rows* temp = _impl_.rows_;
-  return _add;
+  _impl_.rows_ = nullptr;
+#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
+  auto* old =  reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
+  temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
+  if (GetArenaForAllocation() == nullptr) { delete old; }
+#else  // PROTOBUF_FORCE_COPY_IN_RELEASE
+  if (GetArenaForAllocation() != nullptr) {
+    temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
+  }
+#endif  // !PROTOBUF_FORCE_COPY_IN_RELEASE
+  return temp;
 }
-inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >&
+inline ::greptime::v1::Rows* InsertRequest::unsafe_arena_release_rows() {
-InsertRequest::rows() const {
+  // @@protoc_insertion_point(field_release:greptime.v1.region.InsertRequest.rows)
-  // @@protoc_insertion_point(field_list:greptime.v1.region.InsertRequest.rows)
+  
+  ::greptime::v1::Rows* temp = _impl_.rows_;
+  _impl_.rows_ = nullptr;
+  return temp;
+}
+inline ::greptime::v1::Rows* InsertRequest::_internal_mutable_rows() {
+  
+  if (_impl_.rows_ == nullptr) {
+    auto* p = CreateMaybeMessage<::greptime::v1::Rows>(GetArenaForAllocation());
+    _impl_.rows_ = p;
+  }
   return _impl_.rows_;
 }
+inline ::greptime::v1::Rows* InsertRequest::mutable_rows() {
+  ::greptime::v1::Rows* _msg = _internal_mutable_rows();
+  // @@protoc_insertion_point(field_mutable:greptime.v1.region.InsertRequest.rows)
+  return _msg;
+}
+inline void InsertRequest::set_allocated_rows(::greptime::v1::Rows* rows) {
+  ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
+  if (message_arena == nullptr) {
+    delete reinterpret_cast< ::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.rows_);
+  }
+  if (rows) {
+    ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
+        ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(
+                reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(rows));
+    if (message_arena != submessage_arena) {
+      rows = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
+          message_arena, rows, submessage_arena);
+    }
+    
+  } else {
+    
+  }
+  _impl_.rows_ = rows;
+  // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.InsertRequest.rows)
+}
 
 // -------------------------------------------------------------------
 
@@ -4011,42 +4059,90 @@ inline void DeleteRequest::set_region_id(uint64_t value) {
   // @@protoc_insertion_point(field_set:greptime.v1.region.DeleteRequest.region_id)
 }
 
-// repeated .greptime.v1.Row rows = 2;
+// .greptime.v1.Rows rows = 2;
-inline int DeleteRequest::_internal_rows_size() const {
+inline bool DeleteRequest::_internal_has_rows() const {
-  return _impl_.rows_.size();
+  return this != internal_default_instance() && _impl_.rows_ != nullptr;
 }
-inline int DeleteRequest::rows_size() const {
+inline bool DeleteRequest::has_rows() const {
-  return _internal_rows_size();
+  return _internal_has_rows();
 }
-inline ::greptime::v1::Row* DeleteRequest::mutable_rows(int index) {
+inline const ::greptime::v1::Rows& DeleteRequest::_internal_rows() const {
-  // @@protoc_insertion_point(field_mutable:greptime.v1.region.DeleteRequest.rows)
+  const ::greptime::v1::Rows* p = _impl_.rows_;
-  return _impl_.rows_.Mutable(index);
+  return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::Rows&>(
+      ::greptime::v1::_Rows_default_instance_);
 }
-inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >*
+inline const ::greptime::v1::Rows& DeleteRequest::rows() const {
-DeleteRequest::mutable_rows() {
-  // @@protoc_insertion_point(field_mutable_list:greptime.v1.region.DeleteRequest.rows)
-  return &_impl_.rows_;
-}
-inline const ::greptime::v1::Row& DeleteRequest::_internal_rows(int index) const {
-  return _impl_.rows_.Get(index);
-}
-inline const ::greptime::v1::Row& DeleteRequest::rows(int index) const {
   // @@protoc_insertion_point(field_get:greptime.v1.region.DeleteRequest.rows)
-  return _internal_rows(index);
+  return _internal_rows();
 }
-inline ::greptime::v1::Row* DeleteRequest::_internal_add_rows() {
+inline void DeleteRequest::unsafe_arena_set_allocated_rows(
-  return _impl_.rows_.Add();
+    ::greptime::v1::Rows* rows) {
+  if (GetArenaForAllocation() == nullptr) {
+    delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.rows_);
+  }
+  _impl_.rows_ = rows;
+  if (rows) {
+    
+  } else {
+    
+  }
+  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.region.DeleteRequest.rows)
 }
-inline ::greptime::v1::Row* DeleteRequest::add_rows() {
+inline ::greptime::v1::Rows* DeleteRequest::release_rows() {
-  ::greptime::v1::Row* _add = _internal_add_rows();
+  
-  // @@protoc_insertion_point(field_add:greptime.v1.region.DeleteRequest.rows)
+  ::greptime::v1::Rows* temp = _impl_.rows_;
-  return _add;
+  _impl_.rows_ = nullptr;
+#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
+  auto* old =  reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
+  temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
+  if (GetArenaForAllocation() == nullptr) { delete old; }
+#else  // PROTOBUF_FORCE_COPY_IN_RELEASE
+  if (GetArenaForAllocation() != nullptr) {
+    temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
+  }
+#endif  // !PROTOBUF_FORCE_COPY_IN_RELEASE
+  return temp;
 }
-inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >&
+inline ::greptime::v1::Rows* DeleteRequest::unsafe_arena_release_rows() {
-DeleteRequest::rows() const {
+  // @@protoc_insertion_point(field_release:greptime.v1.region.DeleteRequest.rows)
-  // @@protoc_insertion_point(field_list:greptime.v1.region.DeleteRequest.rows)
+  
+  ::greptime::v1::Rows* temp = _impl_.rows_;
+  _impl_.rows_ = nullptr;
+  return temp;
+}
+inline ::greptime::v1::Rows* DeleteRequest::_internal_mutable_rows() {
+  
+  if (_impl_.rows_ == nullptr) {
+    auto* p = CreateMaybeMessage<::greptime::v1::Rows>(GetArenaForAllocation());
+    _impl_.rows_ = p;
+  }
   return _impl_.rows_;
 }
+inline ::greptime::v1::Rows* DeleteRequest::mutable_rows() {
+  ::greptime::v1::Rows* _msg = _internal_mutable_rows();
+  // @@protoc_insertion_point(field_mutable:greptime.v1.region.DeleteRequest.rows)
+  return _msg;
+}
+inline void DeleteRequest::set_allocated_rows(::greptime::v1::Rows* rows) {
+  ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
+  if (message_arena == nullptr) {
+    delete reinterpret_cast< ::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.rows_);
+  }
+  if (rows) {
+    ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
+        ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(
+                reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(rows));
+    if (message_arena != submessage_arena) {
+      rows = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
+          message_arena, rows, submessage_arena);
+    }
+    
+  } else {
+    
+  }
+  _impl_.rows_ = rows;
+  // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.DeleteRequest.rows)
+}
 
 // -------------------------------------------------------------------
 

proto/greptime/v1/region/server.proto

@@ -23,11 +23,7 @@ option go_package = "github.com/GreptimeTeam/greptime-proto/go/greptime/v1/regio
 import "greptime/v1/common.proto";
 import "greptime/v1/row.proto";
 
-service Region {
+service Region { rpc Handle(RegionRequest) returns (RegionResponse); }
-  rpc Handle(RegionRequest) returns (RegionResponse);
-
-  rpc HandleRequests(stream RegionRequest) returns (RegionResponse);
-}
 
 message RegionRequest {
   RequestHeader header = 1;
@@ -56,12 +52,12 @@ message DeleteRequests { repeated DeleteRequest requests = 1; }
 
 message InsertRequest {
   uint64 region_id = 1;
-  repeated Row rows = 2;
+  Rows rows = 2;
 }
 
 message DeleteRequest {
   uint64 region_id = 1;
-  repeated Row rows = 2;
+  Rows rows = 2;
 }
 
 message QueryRequest {