From fdcbe5f1c7c467634c90a1fd1a00a784b92a4e80 Mon Sep 17 00:00:00 2001 From: "Lei, HUANG" <6406592+v0y4g3r@users.noreply.github.com> Date: Tue, 17 Jun 2025 11:40:59 +0800 Subject: [PATCH] chore: add connection id to Process (#245) * add connection id to Process Signed-off-by: Lei, HUANG * feat/add-connection-id-to-process-info: **Update `server.proto` for ProcessInfo Message** - Changed the data type of `id` from `uint64` to `uint32` in the `ProcessInfo` message. - Removed the `connection_id` field from the `ProcessInfo` message. Affected file: - `proto/greptime/v1/frontend/server.proto` Signed-off-by: Lei, HUANG * feat/add-connection-id-to-process-info: Update `process_id` type in `server.proto` - Changed the data type of `process_id` from `uint64` to `uint32` in `proto/greptime/v1/frontend/server.proto` to align with system requirements. Signed-off-by: Lei, HUANG --------- Signed-off-by: Lei, HUANG --- c++/greptime/v1/frontend/server.pb.cc | 74 ++++++++-------- c++/greptime/v1/frontend/server.pb.h | 58 ++++++------- .../java/io/greptime/v1/frontend/Server.java | 86 +++++++++---------- proto/greptime/v1/frontend/server.proto | 4 +- 4 files changed, 110 insertions(+), 112 deletions(-) diff --git a/c++/greptime/v1/frontend/server.pb.cc b/c++/greptime/v1/frontend/server.pb.cc index ec6c3b3..0d88d0b 100644 --- a/c++/greptime/v1/frontend/server.pb.cc +++ b/c++/greptime/v1/frontend/server.pb.cc @@ -53,7 +53,7 @@ PROTOBUF_CONSTEXPR KillProcessRequest::KillProcessRequest( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.server_addr_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} , /*decltype(_impl_.catalog_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} - , /*decltype(_impl_.process_id_)*/uint64_t{0u} + , /*decltype(_impl_.process_id_)*/0u , /*decltype(_impl_._cached_size_)*/{}} {} struct KillProcessRequestDefaultTypeInternal { PROTOBUF_CONSTEXPR KillProcessRequestDefaultTypeInternal() @@ -84,8 +84,8 @@ PROTOBUF_CONSTEXPR ProcessInfo::ProcessInfo( , /*decltype(_impl_.query_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} , /*decltype(_impl_.client_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} , /*decltype(_impl_.frontend_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} - , /*decltype(_impl_.id_)*/uint64_t{0u} , /*decltype(_impl_.start_timestamp_)*/int64_t{0} + , /*decltype(_impl_.id_)*/0u , /*decltype(_impl_._cached_size_)*/{}} {} struct ProcessInfoDefaultTypeInternal { PROTOBUF_CONSTEXPR ProcessInfoDefaultTypeInternal() @@ -171,9 +171,9 @@ const char descriptor_table_protodef_greptime_2fv1_2ffrontend_2fserver_2eproto[] "4\n\tprocesses\030\001 \003(\0132!.greptime.v1.fronten" "d.ProcessInfo\"N\n\022KillProcessRequest\022\023\n\013s" "erver_addr\030\001 \001(\t\022\017\n\007catalog\030\002 \001(\t\022\022\n\npro" - "cess_id\030\003 \001(\004\"&\n\023KillProcessResponse\022\017\n\007" + "cess_id\030\003 \001(\r\"&\n\023KillProcessResponse\022\017\n\007" "success\030\001 \001(\010\"\205\001\n\013ProcessInfo\022\n\n\002id\030\001 \001(" - "\004\022\017\n\007catalog\030\002 \001(\t\022\017\n\007schemas\030\003 \003(\t\022\r\n\005q" + "\r\022\017\n\007catalog\030\002 \001(\t\022\017\n\007schemas\030\003 \003(\t\022\r\n\005q" "uery\030\004 \001(\t\022\027\n\017start_timestamp\030\005 \001(\003\022\016\n\006c" "lient\030\006 \001(\t\022\020\n\010frontend\030\007 \001(\t2\322\001\n\010Fronte" "nd\022b\n\013ListProcess\022(.greptime.v1.frontend" @@ -641,7 +641,7 @@ inline void KillProcessRequest::SharedCtor( new (&_impl_) Impl_{ decltype(_impl_.server_addr_){} , decltype(_impl_.catalog_){} - , decltype(_impl_.process_id_){uint64_t{0u}} + , decltype(_impl_.process_id_){0u} , /*decltype(_impl_._cached_size_)*/{} }; _impl_.server_addr_.InitDefault(); @@ -681,7 +681,7 @@ void KillProcessRequest::Clear() { _impl_.server_addr_.ClearToEmpty(); _impl_.catalog_.ClearToEmpty(); - _impl_.process_id_ = uint64_t{0u}; + _impl_.process_id_ = 0u; _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } @@ -711,10 +711,10 @@ const char* KillProcessRequest::_InternalParse(const char* ptr, ::_pbi::ParseCon } else goto handle_unusual; continue; - // uint64 process_id = 3; + // uint32 process_id = 3; case 3: if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 24)) { - _impl_.process_id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); + _impl_.process_id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr); CHK_(ptr); } else goto handle_unusual; @@ -768,10 +768,10 @@ uint8_t* KillProcessRequest::_InternalSerialize( 2, this->_internal_catalog(), target); } - // uint64 process_id = 3; + // uint32 process_id = 3; if (this->_internal_process_id() != 0) { target = stream->EnsureSpace(target); - target = ::_pbi::WireFormatLite::WriteUInt64ToArray(3, this->_internal_process_id(), target); + target = ::_pbi::WireFormatLite::WriteUInt32ToArray(3, this->_internal_process_id(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { @@ -804,9 +804,9 @@ size_t KillProcessRequest::ByteSizeLong() const { this->_internal_catalog()); } - // uint64 process_id = 3; + // uint32 process_id = 3; if (this->_internal_process_id() != 0) { - total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_process_id()); + total_size += ::_pbi::WireFormatLite::UInt32SizePlusOne(this->_internal_process_id()); } return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); @@ -1071,8 +1071,8 @@ ProcessInfo::ProcessInfo(const ProcessInfo& from) , decltype(_impl_.query_){} , decltype(_impl_.client_){} , decltype(_impl_.frontend_){} - , decltype(_impl_.id_){} , decltype(_impl_.start_timestamp_){} + , decltype(_impl_.id_){} , /*decltype(_impl_._cached_size_)*/{}}; _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); @@ -1108,9 +1108,9 @@ ProcessInfo::ProcessInfo(const ProcessInfo& from) _this->_impl_.frontend_.Set(from._internal_frontend(), _this->GetArenaForAllocation()); } - ::memcpy(&_impl_.id_, &from._impl_.id_, - static_cast(reinterpret_cast(&_impl_.start_timestamp_) - - reinterpret_cast(&_impl_.id_)) + sizeof(_impl_.start_timestamp_)); + ::memcpy(&_impl_.start_timestamp_, &from._impl_.start_timestamp_, + static_cast(reinterpret_cast(&_impl_.id_) - + reinterpret_cast(&_impl_.start_timestamp_)) + sizeof(_impl_.id_)); // @@protoc_insertion_point(copy_constructor:greptime.v1.frontend.ProcessInfo) } @@ -1124,8 +1124,8 @@ inline void ProcessInfo::SharedCtor( , decltype(_impl_.query_){} , decltype(_impl_.client_){} , decltype(_impl_.frontend_){} - , decltype(_impl_.id_){uint64_t{0u}} , decltype(_impl_.start_timestamp_){int64_t{0}} + , decltype(_impl_.id_){0u} , /*decltype(_impl_._cached_size_)*/{} }; _impl_.catalog_.InitDefault(); @@ -1179,9 +1179,9 @@ void ProcessInfo::Clear() { _impl_.query_.ClearToEmpty(); _impl_.client_.ClearToEmpty(); _impl_.frontend_.ClearToEmpty(); - ::memset(&_impl_.id_, 0, static_cast( - reinterpret_cast(&_impl_.start_timestamp_) - - reinterpret_cast(&_impl_.id_)) + sizeof(_impl_.start_timestamp_)); + ::memset(&_impl_.start_timestamp_, 0, static_cast( + reinterpret_cast(&_impl_.id_) - + reinterpret_cast(&_impl_.start_timestamp_)) + sizeof(_impl_.id_)); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } @@ -1191,10 +1191,10 @@ const char* ProcessInfo::_InternalParse(const char* ptr, ::_pbi::ParseContext* c uint32_t tag; ptr = ::_pbi::ReadTag(ptr, &tag); switch (tag >> 3) { - // uint64 id = 1; + // uint32 id = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 8)) { - _impl_.id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); + _impl_.id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr); CHK_(ptr); } else goto handle_unusual; @@ -1291,10 +1291,10 @@ uint8_t* ProcessInfo::_InternalSerialize( uint32_t cached_has_bits = 0; (void) cached_has_bits; - // uint64 id = 1; + // uint32 id = 1; if (this->_internal_id() != 0) { target = stream->EnsureSpace(target); - target = ::_pbi::WireFormatLite::WriteUInt64ToArray(1, this->_internal_id(), target); + target = ::_pbi::WireFormatLite::WriteUInt32ToArray(1, this->_internal_id(), target); } // string catalog = 2; @@ -1405,16 +1405,16 @@ size_t ProcessInfo::ByteSizeLong() const { this->_internal_frontend()); } - // uint64 id = 1; - if (this->_internal_id() != 0) { - total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_id()); - } - // int64 start_timestamp = 5; if (this->_internal_start_timestamp() != 0) { total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_start_timestamp()); } + // uint32 id = 1; + if (this->_internal_id() != 0) { + total_size += ::_pbi::WireFormatLite::UInt32SizePlusOne(this->_internal_id()); + } + return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); } @@ -1446,12 +1446,12 @@ void ProcessInfo::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PR if (!from._internal_frontend().empty()) { _this->_internal_set_frontend(from._internal_frontend()); } - if (from._internal_id() != 0) { - _this->_internal_set_id(from._internal_id()); - } if (from._internal_start_timestamp() != 0) { _this->_internal_set_start_timestamp(from._internal_start_timestamp()); } + if (from._internal_id() != 0) { + _this->_internal_set_id(from._internal_id()); + } _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); } @@ -1489,11 +1489,11 @@ void ProcessInfo::InternalSwap(ProcessInfo* other) { &other->_impl_.frontend_, rhs_arena ); ::PROTOBUF_NAMESPACE_ID::internal::memswap< - PROTOBUF_FIELD_OFFSET(ProcessInfo, _impl_.start_timestamp_) - + sizeof(ProcessInfo::_impl_.start_timestamp_) - - PROTOBUF_FIELD_OFFSET(ProcessInfo, _impl_.id_)>( - reinterpret_cast(&_impl_.id_), - reinterpret_cast(&other->_impl_.id_)); + PROTOBUF_FIELD_OFFSET(ProcessInfo, _impl_.id_) + + sizeof(ProcessInfo::_impl_.id_) + - PROTOBUF_FIELD_OFFSET(ProcessInfo, _impl_.start_timestamp_)>( + reinterpret_cast(&_impl_.start_timestamp_), + reinterpret_cast(&other->_impl_.start_timestamp_)); } ::PROTOBUF_NAMESPACE_ID::Metadata ProcessInfo::GetMetadata() const { diff --git a/c++/greptime/v1/frontend/server.pb.h b/c++/greptime/v1/frontend/server.pb.h index a33c831..8b8042f 100644 --- a/c++/greptime/v1/frontend/server.pb.h +++ b/c++/greptime/v1/frontend/server.pb.h @@ -541,13 +541,13 @@ class KillProcessRequest final : std::string* _internal_mutable_catalog(); public: - // uint64 process_id = 3; + // uint32 process_id = 3; void clear_process_id(); - uint64_t process_id() const; - void set_process_id(uint64_t value); + uint32_t process_id() const; + void set_process_id(uint32_t value); private: - uint64_t _internal_process_id() const; - void _internal_set_process_id(uint64_t value); + uint32_t _internal_process_id() const; + void _internal_set_process_id(uint32_t value); public: // @@protoc_insertion_point(class_scope:greptime.v1.frontend.KillProcessRequest) @@ -560,7 +560,7 @@ class KillProcessRequest final : struct Impl_ { ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr server_addr_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr catalog_; - uint64_t process_id_; + uint32_t process_id_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; }; union { Impl_ _impl_; }; @@ -842,8 +842,8 @@ class ProcessInfo final : kQueryFieldNumber = 4, kClientFieldNumber = 6, kFrontendFieldNumber = 7, - kIdFieldNumber = 1, kStartTimestampFieldNumber = 5, + kIdFieldNumber = 1, }; // repeated string schemas = 3; int schemas_size() const; @@ -925,15 +925,6 @@ class ProcessInfo final : std::string* _internal_mutable_frontend(); public: - // uint64 id = 1; - void clear_id(); - uint64_t id() const; - void set_id(uint64_t value); - private: - uint64_t _internal_id() const; - void _internal_set_id(uint64_t value); - public: - // int64 start_timestamp = 5; void clear_start_timestamp(); int64_t start_timestamp() const; @@ -943,6 +934,15 @@ class ProcessInfo final : void _internal_set_start_timestamp(int64_t value); public: + // uint32 id = 1; + void clear_id(); + uint32_t id() const; + void set_id(uint32_t value); + private: + uint32_t _internal_id() const; + void _internal_set_id(uint32_t value); + public: + // @@protoc_insertion_point(class_scope:greptime.v1.frontend.ProcessInfo) private: class _Internal; @@ -956,8 +956,8 @@ class ProcessInfo final : ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr query_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr client_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr frontend_; - uint64_t id_; int64_t start_timestamp_; + uint32_t id_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; }; union { Impl_ _impl_; }; @@ -1172,22 +1172,22 @@ inline void KillProcessRequest::set_allocated_catalog(std::string* catalog) { // @@protoc_insertion_point(field_set_allocated:greptime.v1.frontend.KillProcessRequest.catalog) } -// uint64 process_id = 3; +// uint32 process_id = 3; inline void KillProcessRequest::clear_process_id() { - _impl_.process_id_ = uint64_t{0u}; + _impl_.process_id_ = 0u; } -inline uint64_t KillProcessRequest::_internal_process_id() const { +inline uint32_t KillProcessRequest::_internal_process_id() const { return _impl_.process_id_; } -inline uint64_t KillProcessRequest::process_id() const { +inline uint32_t KillProcessRequest::process_id() const { // @@protoc_insertion_point(field_get:greptime.v1.frontend.KillProcessRequest.process_id) return _internal_process_id(); } -inline void KillProcessRequest::_internal_set_process_id(uint64_t value) { +inline void KillProcessRequest::_internal_set_process_id(uint32_t value) { _impl_.process_id_ = value; } -inline void KillProcessRequest::set_process_id(uint64_t value) { +inline void KillProcessRequest::set_process_id(uint32_t value) { _internal_set_process_id(value); // @@protoc_insertion_point(field_set:greptime.v1.frontend.KillProcessRequest.process_id) } @@ -1220,22 +1220,22 @@ inline void KillProcessResponse::set_success(bool value) { // ProcessInfo -// uint64 id = 1; +// uint32 id = 1; inline void ProcessInfo::clear_id() { - _impl_.id_ = uint64_t{0u}; + _impl_.id_ = 0u; } -inline uint64_t ProcessInfo::_internal_id() const { +inline uint32_t ProcessInfo::_internal_id() const { return _impl_.id_; } -inline uint64_t ProcessInfo::id() const { +inline uint32_t ProcessInfo::id() const { // @@protoc_insertion_point(field_get:greptime.v1.frontend.ProcessInfo.id) return _internal_id(); } -inline void ProcessInfo::_internal_set_id(uint64_t value) { +inline void ProcessInfo::_internal_set_id(uint32_t value) { _impl_.id_ = value; } -inline void ProcessInfo::set_id(uint64_t value) { +inline void ProcessInfo::set_id(uint32_t value) { _internal_set_id(value); // @@protoc_insertion_point(field_set:greptime.v1.frontend.ProcessInfo.id) } diff --git a/java/src/main/java/io/greptime/v1/frontend/Server.java b/java/src/main/java/io/greptime/v1/frontend/Server.java index 7c5fedc..aa42cd8 100644 --- a/java/src/main/java/io/greptime/v1/frontend/Server.java +++ b/java/src/main/java/io/greptime/v1/frontend/Server.java @@ -1428,10 +1428,10 @@ public final class Server { * ID of process to kill. * * - * uint64 process_id = 3; + * uint32 process_id = 3; * @return The processId. */ - long getProcessId(); + int getProcessId(); } /** * Protobuf type {@code greptime.v1.frontend.KillProcessRequest} @@ -1494,7 +1494,7 @@ public final class Server { } case 24: { - processId_ = input.readUInt64(); + processId_ = input.readUInt32(); break; } default: { @@ -1624,17 +1624,17 @@ public final class Server { } public static final int PROCESS_ID_FIELD_NUMBER = 3; - private long processId_; + private int processId_; /** * 
      * ID of process to kill.
      *
* - * uint64 process_id = 3; + * uint32 process_id = 3; * @return The processId. */ @java.lang.Override - public long getProcessId() { + public int getProcessId() { return processId_; } @@ -1658,8 +1658,8 @@ public final class Server { if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(catalog_)) { com.google.protobuf.GeneratedMessageV3.writeString(output, 2, catalog_); } - if (processId_ != 0L) { - output.writeUInt64(3, processId_); + if (processId_ != 0) { + output.writeUInt32(3, processId_); } unknownFields.writeTo(output); } @@ -1676,9 +1676,9 @@ public final class Server { if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(catalog_)) { size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, catalog_); } - if (processId_ != 0L) { + if (processId_ != 0) { size += com.google.protobuf.CodedOutputStream - .computeUInt64Size(3, processId_); + .computeUInt32Size(3, processId_); } size += unknownFields.getSerializedSize(); memoizedSize = size; @@ -1717,8 +1717,7 @@ public final class Server { hash = (37 * hash) + CATALOG_FIELD_NUMBER; hash = (53 * hash) + getCatalog().hashCode(); hash = (37 * hash) + PROCESS_ID_FIELD_NUMBER; - hash = (53 * hash) + com.google.protobuf.Internal.hashLong( - getProcessId()); + hash = (53 * hash) + getProcessId(); hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -1856,7 +1855,7 @@ public final class Server { catalog_ = ""; - processId_ = 0L; + processId_ = 0; return this; } @@ -1943,7 +1942,7 @@ public final class Server { catalog_ = other.catalog_; onChanged(); } - if (other.getProcessId() != 0L) { + if (other.getProcessId() != 0) { setProcessId(other.getProcessId()); } this.mergeUnknownFields(other.unknownFields); @@ -2167,17 +2166,17 @@ public final class Server { return this; } - private long processId_ ; + private int processId_ ; /** * 
        * ID of process to kill.
        *
* - * uint64 process_id = 3; + * uint32 process_id = 3; * @return The processId. */ @java.lang.Override - public long getProcessId() { + public int getProcessId() { return processId_; } /** @@ -2185,11 +2184,11 @@ public final class Server { * ID of process to kill. * * - * uint64 process_id = 3; + * uint32 process_id = 3; * @param value The processId to set. * @return This builder for chaining. */ - public Builder setProcessId(long value) { + public Builder setProcessId(int value) { processId_ = value; onChanged(); @@ -2200,12 +2199,12 @@ public final class Server { * ID of process to kill. * * - * uint64 process_id = 3; + * uint32 process_id = 3; * @return This builder for chaining. */ public Builder clearProcessId() { - processId_ = 0L; + processId_ = 0; onChanged(); return this; } @@ -2782,10 +2781,10 @@ public final class Server { * ID. * * - * uint64 id = 1; + * uint32 id = 1; * @return The id. */ - long getId(); + int getId(); /** * 
@@ -2971,7 +2970,7 @@ public final class Server {
               break;
             case 8: {
 
-              id_ = input.readUInt64();
+              id_ = input.readUInt32();
               break;
             }
             case 18: {
@@ -3050,17 +3049,17 @@ public final class Server {
     }
 
     public static final int ID_FIELD_NUMBER = 1;
-    private long id_;
+    private int id_;
     /**
      * 
      * ID.
      * 

      *
-     * uint64 id = 1;
+     * uint32 id = 1;
      * @return The id.
      */
     @java.lang.Override
-    public long getId() {
+    public int getId() {
       return id_;
     }
 
@@ -3328,8 +3327,8 @@ public final class Server {
     @java.lang.Override
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
-      if (id_ != 0L) {
-        output.writeUInt64(1, id_);
+      if (id_ != 0) {
+        output.writeUInt32(1, id_);
       }
       if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(catalog_)) {
         com.google.protobuf.GeneratedMessageV3.writeString(output, 2, catalog_);
@@ -3358,9 +3357,9 @@ public final class Server {
       if (size != -1) return size;
 
       size = 0;
-      if (id_ != 0L) {
+      if (id_ != 0) {
         size += com.google.protobuf.CodedOutputStream
-          .computeUInt64Size(1, id_);
+          .computeUInt32Size(1, id_);
       }
       if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(catalog_)) {
         size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, catalog_);
@@ -3427,8 +3426,7 @@ public final class Server {
       int hash = 41;
       hash = (19 * hash) + getDescriptor().hashCode();
       hash = (37 * hash) + ID_FIELD_NUMBER;
-      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
-          getId());
+      hash = (53 * hash) + getId();
       hash = (37 * hash) + CATALOG_FIELD_NUMBER;
       hash = (53 * hash) + getCatalog().hashCode();
       if (getSchemasCount() > 0) {
@@ -3577,7 +3575,7 @@ public final class Server {
       @java.lang.Override
       public Builder clear() {
         super.clear();
-        id_ = 0L;
+        id_ = 0;
 
         catalog_ = "";
 
@@ -3677,7 +3675,7 @@ public final class Server {
 
       public Builder mergeFrom(io.greptime.v1.frontend.Server.ProcessInfo other) {
         if (other == io.greptime.v1.frontend.Server.ProcessInfo.getDefaultInstance()) return this;
-        if (other.getId() != 0L) {
+        if (other.getId() != 0) {
           setId(other.getId());
         }
         if (!other.getCatalog().isEmpty()) {
@@ -3739,17 +3737,17 @@ public final class Server {
       }
       private int bitField0_;
 
-      private long id_ ;
+      private int id_ ;
       /**
        * 
        * ID.
        * 

        *
-       * uint64 id = 1;
+       * uint32 id = 1;
        * @return The id.
        */
       @java.lang.Override
-      public long getId() {
+      public int getId() {
         return id_;
       }
       /**
@@ -3757,11 +3755,11 @@ public final class Server {
        * ID.
        *
* - * uint64 id = 1; + * uint32 id = 1; * @param value The id to set. * @return This builder for chaining. */ - public Builder setId(long value) { + public Builder setId(int value) { id_ = value; onChanged(); @@ -3772,12 +3770,12 @@ public final class Server { * ID. * * - * uint64 id = 1; + * uint32 id = 1; * @return This builder for chaining. */ public Builder clearId() { - id_ = 0L; + id_ = 0; onChanged(); return this; } @@ -4447,9 +4445,9 @@ public final class Server { "4\n\tprocesses\030\001 \003(\0132!.greptime.v1.fronten" + "d.ProcessInfo\"N\n\022KillProcessRequest\022\023\n\013s" + "erver_addr\030\001 \001(\t\022\017\n\007catalog\030\002 \001(\t\022\022\n\npro" + - "cess_id\030\003 \001(\004\"&\n\023KillProcessResponse\022\017\n\007" + + "cess_id\030\003 \001(\r\"&\n\023KillProcessResponse\022\017\n\007" + "success\030\001 \001(\010\"\205\001\n\013ProcessInfo\022\n\n\002id\030\001 \001(" + - "\004\022\017\n\007catalog\030\002 \001(\t\022\017\n\007schemas\030\003 \003(\t\022\r\n\005q" + + "\r\022\017\n\007catalog\030\002 \001(\t\022\017\n\007schemas\030\003 \003(\t\022\r\n\005q" + "uery\030\004 \001(\t\022\027\n\017start_timestamp\030\005 \001(\003\022\016\n\006c" + "lient\030\006 \001(\t\022\020\n\010frontend\030\007 \001(\t2\322\001\n\010Fronte" + "nd\022b\n\013ListProcess\022(.greptime.v1.frontend" + diff --git a/proto/greptime/v1/frontend/server.proto b/proto/greptime/v1/frontend/server.proto index 77a680e..8fa51d2 100644 --- a/proto/greptime/v1/frontend/server.proto +++ b/proto/greptime/v1/frontend/server.proto @@ -41,7 +41,7 @@ message KillProcessRequest { // Catalog of process to kill. string catalog = 2; // ID of process to kill. - uint64 process_id = 3; + uint32 process_id = 3; } message KillProcessResponse { @@ -51,7 +51,7 @@ message KillProcessResponse { message ProcessInfo { // ID. - uint64 id = 1; + uint32 id = 1; // Catalog of process. string catalog = 2; // Involved schemas.