chore: add Metrics in FlightMetadata (#134)

* chore: add metrics to metadata * chore: update metrics to message * chore: change string to bytes for backward compatibility * chore: rebase main
2024-01-16 12:02:54 +08:00
parent 2c1f17dce7
commit 65b008f018
6 changed files with 1578 additions and 189 deletions
@@ -6346,6 +6346,500 @@ java.lang.String defaultValue);

  }

+  public interface MetricsOrBuilder extends
+      // @@protoc_insertion_point(interface_extends:greptime.v1.Metrics)
+      com.google.protobuf.MessageOrBuilder {
+
+    /**
+     * <code>bytes metrics = 1;</code>
+     * @return The metrics.
+     */
+    com.google.protobuf.ByteString getMetrics();
+  }
+  /**
+   * Protobuf type {@code greptime.v1.Metrics}
+   */
+  public static final class Metrics extends
+      com.google.protobuf.GeneratedMessageV3 implements
+      // @@protoc_insertion_point(message_implements:greptime.v1.Metrics)
+      MetricsOrBuilder {
+  private static final long serialVersionUID = 0L;
+    // Use Metrics.newBuilder() to construct.
+    private Metrics(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
+      super(builder);
+    }
+    private Metrics() {
+      metrics_ = com.google.protobuf.ByteString.EMPTY;
+    }
+
+    @java.lang.Override
+    @SuppressWarnings({"unused"})
+    protected java.lang.Object newInstance(
+        UnusedPrivateParameter unused) {
+      return new Metrics();
+    }
+
+    @java.lang.Override
+    public final com.google.protobuf.UnknownFieldSet
+    getUnknownFields() {
+      return this.unknownFields;
+    }
+    private Metrics(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      this();
+      if (extensionRegistry == null) {
+        throw new java.lang.NullPointerException();
+      }
+      com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder();
+      try {
+        boolean done = false;
+        while (!done) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              done = true;
+              break;
+            case 10: {
+
+              metrics_ = input.readBytes();
+              break;
+            }
+            default: {
+              if (!parseUnknownField(
+                  input, unknownFields, extensionRegistry, tag)) {
+                done = true;
+              }
+              break;
+            }
+          }
+        }
+      } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+        throw e.setUnfinishedMessage(this);
+      } catch (com.google.protobuf.UninitializedMessageException e) {
+        throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
+      } catch (java.io.IOException e) {
+        throw new com.google.protobuf.InvalidProtocolBufferException(
+            e).setUnfinishedMessage(this);
+      } finally {
+        this.unknownFields = unknownFields.build();
+        makeExtensionsImmutable();
+      }
+    }
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return io.greptime.v1.Common.internal_static_greptime_v1_Metrics_descriptor;
+    }
+
+    @java.lang.Override
+    protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return io.greptime.v1.Common.internal_static_greptime_v1_Metrics_fieldAccessorTable
+          .ensureFieldAccessorsInitialized(
+              io.greptime.v1.Common.Metrics.class, io.greptime.v1.Common.Metrics.Builder.class);
+    }
+
+    public static final int METRICS_FIELD_NUMBER = 1;
+    private com.google.protobuf.ByteString metrics_;
+    /**
+     * <code>bytes metrics = 1;</code>
+     * @return The metrics.
+     */
+    @java.lang.Override
+    public com.google.protobuf.ByteString getMetrics() {
+      return metrics_;
+    }
+
+    private byte memoizedIsInitialized = -1;
+    @java.lang.Override
+    public final boolean isInitialized() {
+      byte isInitialized = memoizedIsInitialized;
+      if (isInitialized == 1) return true;
+      if (isInitialized == 0) return false;
+
+      memoizedIsInitialized = 1;
+      return true;
+    }
+
+    @java.lang.Override
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (!metrics_.isEmpty()) {
+        output.writeBytes(1, metrics_);
+      }
+      unknownFields.writeTo(output);
+    }
+
+    @java.lang.Override
+    public int getSerializedSize() {
+      int size = memoizedSize;
+      if (size != -1) return size;
+
+      size = 0;
+      if (!metrics_.isEmpty()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(1, metrics_);
+      }
+      size += unknownFields.getSerializedSize();
+      memoizedSize = size;
+      return size;
+    }
+
+    @java.lang.Override
+    public boolean equals(final java.lang.Object obj) {
+      if (obj == this) {
+       return true;
+      }
+      if (!(obj instanceof io.greptime.v1.Common.Metrics)) {
+        return super.equals(obj);
+      }
+      io.greptime.v1.Common.Metrics other = (io.greptime.v1.Common.Metrics) obj;
+
+      if (!getMetrics()
+          .equals(other.getMetrics())) return false;
+      if (!unknownFields.equals(other.unknownFields)) return false;
+      return true;
+    }
+
+    @java.lang.Override
+    public int hashCode() {
+      if (memoizedHashCode != 0) {
+        return memoizedHashCode;
+      }
+      int hash = 41;
+      hash = (19 * hash) + getDescriptor().hashCode();
+      hash = (37 * hash) + METRICS_FIELD_NUMBER;
+      hash = (53 * hash) + getMetrics().hashCode();
+      hash = (29 * hash) + unknownFields.hashCode();
+      memoizedHashCode = hash;
+      return hash;
+    }
+
+    public static io.greptime.v1.Common.Metrics parseFrom(
+        java.nio.ByteBuffer data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static io.greptime.v1.Common.Metrics parseFrom(
+        java.nio.ByteBuffer data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static io.greptime.v1.Common.Metrics parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static io.greptime.v1.Common.Metrics parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static io.greptime.v1.Common.Metrics parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static io.greptime.v1.Common.Metrics parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static io.greptime.v1.Common.Metrics parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input);
+    }
+    public static io.greptime.v1.Common.Metrics parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input, extensionRegistry);
+    }
+    public static io.greptime.v1.Common.Metrics parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseDelimitedWithIOException(PARSER, input);
+    }
+    public static io.greptime.v1.Common.Metrics parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+    }
+    public static io.greptime.v1.Common.Metrics parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input);
+    }
+    public static io.greptime.v1.Common.Metrics parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input, extensionRegistry);
+    }
+
+    @java.lang.Override
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder() {
+      return DEFAULT_INSTANCE.toBuilder();
+    }
+    public static Builder newBuilder(io.greptime.v1.Common.Metrics prototype) {
+      return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+    }
+    @java.lang.Override
+    public Builder toBuilder() {
+      return this == DEFAULT_INSTANCE
+          ? new Builder() : new Builder().mergeFrom(this);
+    }
+
+    @java.lang.Override
+    protected Builder newBuilderForType(
+        com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+      Builder builder = new Builder(parent);
+      return builder;
+    }
+    /**
+     * Protobuf type {@code greptime.v1.Metrics}
+     */
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
+        // @@protoc_insertion_point(builder_implements:greptime.v1.Metrics)
+        io.greptime.v1.Common.MetricsOrBuilder {
+      public static final com.google.protobuf.Descriptors.Descriptor
+          getDescriptor() {
+        return io.greptime.v1.Common.internal_static_greptime_v1_Metrics_descriptor;
+      }
+
+      @java.lang.Override
+      protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+          internalGetFieldAccessorTable() {
+        return io.greptime.v1.Common.internal_static_greptime_v1_Metrics_fieldAccessorTable
+            .ensureFieldAccessorsInitialized(
+                io.greptime.v1.Common.Metrics.class, io.greptime.v1.Common.Metrics.Builder.class);
+      }
+
+      // Construct using io.greptime.v1.Common.Metrics.newBuilder()
+      private Builder() {
+        maybeForceBuilderInitialization();
+      }
+
+      private Builder(
+          com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+        super(parent);
+        maybeForceBuilderInitialization();
+      }
+      private void maybeForceBuilderInitialization() {
+        if (com.google.protobuf.GeneratedMessageV3
+                .alwaysUseFieldBuilders) {
+        }
+      }
+      @java.lang.Override
+      public Builder clear() {
+        super.clear();
+        metrics_ = com.google.protobuf.ByteString.EMPTY;
+
+        return this;
+      }
+
+      @java.lang.Override
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return io.greptime.v1.Common.internal_static_greptime_v1_Metrics_descriptor;
+      }
+
+      @java.lang.Override
+      public io.greptime.v1.Common.Metrics getDefaultInstanceForType() {
+        return io.greptime.v1.Common.Metrics.getDefaultInstance();
+      }
+
+      @java.lang.Override
+      public io.greptime.v1.Common.Metrics build() {
+        io.greptime.v1.Common.Metrics result = buildPartial();
+        if (!result.isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return result;
+      }
+
+      @java.lang.Override
+      public io.greptime.v1.Common.Metrics buildPartial() {
+        io.greptime.v1.Common.Metrics result = new io.greptime.v1.Common.Metrics(this);
+        result.metrics_ = metrics_;
+        onBuilt();
+        return result;
+      }
+
+      @java.lang.Override
+      public Builder clone() {
+        return super.clone();
+      }
+      @java.lang.Override
+      public Builder setField(
+          com.google.protobuf.Descriptors.FieldDescriptor field,
+          java.lang.Object value) {
+        return super.setField(field, value);
+      }
+      @java.lang.Override
+      public Builder clearField(
+          com.google.protobuf.Descriptors.FieldDescriptor field) {
+        return super.clearField(field);
+      }
+      @java.lang.Override
+      public Builder clearOneof(
+          com.google.protobuf.Descriptors.OneofDescriptor oneof) {
+        return super.clearOneof(oneof);
+      }
+      @java.lang.Override
+      public Builder setRepeatedField(
+          com.google.protobuf.Descriptors.FieldDescriptor field,
+          int index, java.lang.Object value) {
+        return super.setRepeatedField(field, index, value);
+      }
+      @java.lang.Override
+      public Builder addRepeatedField(
+          com.google.protobuf.Descriptors.FieldDescriptor field,
+          java.lang.Object value) {
+        return super.addRepeatedField(field, value);
+      }
+      @java.lang.Override
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof io.greptime.v1.Common.Metrics) {
+          return mergeFrom((io.greptime.v1.Common.Metrics)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+
+      public Builder mergeFrom(io.greptime.v1.Common.Metrics other) {
+        if (other == io.greptime.v1.Common.Metrics.getDefaultInstance()) return this;
+        if (other.getMetrics() != com.google.protobuf.ByteString.EMPTY) {
+          setMetrics(other.getMetrics());
+        }
+        this.mergeUnknownFields(other.unknownFields);
+        onChanged();
+        return this;
+      }
+
+      @java.lang.Override
+      public final boolean isInitialized() {
+        return true;
+      }
+
+      @java.lang.Override
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        io.greptime.v1.Common.Metrics parsedMessage = null;
+        try {
+          parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+          parsedMessage = (io.greptime.v1.Common.Metrics) e.getUnfinishedMessage();
+          throw e.unwrapIOException();
+        } finally {
+          if (parsedMessage != null) {
+            mergeFrom(parsedMessage);
+          }
+        }
+        return this;
+      }
+
+      private com.google.protobuf.ByteString metrics_ = com.google.protobuf.ByteString.EMPTY;
+      /**
+       * <code>bytes metrics = 1;</code>
+       * @return The metrics.
+       */
+      @java.lang.Override
+      public com.google.protobuf.ByteString getMetrics() {
+        return metrics_;
+      }
+      /**
+       * <code>bytes metrics = 1;</code>
+       * @param value The metrics to set.
+       * @return This builder for chaining.
+       */
+      public Builder setMetrics(com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  
+        metrics_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <code>bytes metrics = 1;</code>
+       * @return This builder for chaining.
+       */
+      public Builder clearMetrics() {
+        
+        metrics_ = getDefaultInstance().getMetrics();
+        onChanged();
+        return this;
+      }
+      @java.lang.Override
+      public final Builder setUnknownFields(
+          final com.google.protobuf.UnknownFieldSet unknownFields) {
+        return super.setUnknownFields(unknownFields);
+      }
+
+      @java.lang.Override
+      public final Builder mergeUnknownFields(
+          final com.google.protobuf.UnknownFieldSet unknownFields) {
+        return super.mergeUnknownFields(unknownFields);
+      }
+
+
+      // @@protoc_insertion_point(builder_scope:greptime.v1.Metrics)
+    }
+
+    // @@protoc_insertion_point(class_scope:greptime.v1.Metrics)
+    private static final io.greptime.v1.Common.Metrics DEFAULT_INSTANCE;
+    static {
+      DEFAULT_INSTANCE = new io.greptime.v1.Common.Metrics();
+    }
+
+    public static io.greptime.v1.Common.Metrics getDefaultInstance() {
+      return DEFAULT_INSTANCE;
+    }
+
+    private static final com.google.protobuf.Parser<Metrics>
+        PARSER = new com.google.protobuf.AbstractParser<Metrics>() {
+      @java.lang.Override
+      public Metrics parsePartialFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        return new Metrics(input, extensionRegistry);
+      }
+    };
+
+    public static com.google.protobuf.Parser<Metrics> parser() {
+      return PARSER;
+    }
+
+    @java.lang.Override
+    public com.google.protobuf.Parser<Metrics> getParserForType() {
+      return PARSER;
+    }
+
+    @java.lang.Override
+    public io.greptime.v1.Common.Metrics getDefaultInstanceForType() {
+      return DEFAULT_INSTANCE;
+    }
+
+  }
+
  public interface FlightMetadataOrBuilder extends
      // @@protoc_insertion_point(interface_extends:greptime.v1.FlightMetadata)
      com.google.protobuf.MessageOrBuilder {
@@ -6364,6 +6858,21 @@ java.lang.String defaultValue);
     * <code>.greptime.v1.AffectedRows affected_rows = 1;</code>
     */
    io.greptime.v1.Common.AffectedRowsOrBuilder getAffectedRowsOrBuilder();
+
+    /**
+     * <code>.greptime.v1.Metrics metrics = 2;</code>
+     * @return Whether the metrics field is set.
+     */
+    boolean hasMetrics();
+    /**
+     * <code>.greptime.v1.Metrics metrics = 2;</code>
+     * @return The metrics.
+     */
+    io.greptime.v1.Common.Metrics getMetrics();
+    /**
+     * <code>.greptime.v1.Metrics metrics = 2;</code>
+     */
+    io.greptime.v1.Common.MetricsOrBuilder getMetricsOrBuilder();
  }
  /**
   * Protobuf type {@code greptime.v1.FlightMetadata}
@@ -6423,6 +6932,19 @@ java.lang.String defaultValue);

              break;
            }
+            case 18: {
+              io.greptime.v1.Common.Metrics.Builder subBuilder = null;
+              if (metrics_ != null) {
+                subBuilder = metrics_.toBuilder();
+              }
+              metrics_ = input.readMessage(io.greptime.v1.Common.Metrics.parser(), extensionRegistry);
+              if (subBuilder != null) {
+                subBuilder.mergeFrom(metrics_);
+                metrics_ = subBuilder.buildPartial();
+              }
+
+              break;
+            }
            default: {
              if (!parseUnknownField(
                  input, unknownFields, extensionRegistry, tag)) {
@@ -6483,6 +7005,32 @@ java.lang.String defaultValue);
      return getAffectedRows();
    }

+    public static final int METRICS_FIELD_NUMBER = 2;
+    private io.greptime.v1.Common.Metrics metrics_;
+    /**
+     * <code>.greptime.v1.Metrics metrics = 2;</code>
+     * @return Whether the metrics field is set.
+     */
+    @java.lang.Override
+    public boolean hasMetrics() {
+      return metrics_ != null;
+    }
+    /**
+     * <code>.greptime.v1.Metrics metrics = 2;</code>
+     * @return The metrics.
+     */
+    @java.lang.Override
+    public io.greptime.v1.Common.Metrics getMetrics() {
+      return metrics_ == null ? io.greptime.v1.Common.Metrics.getDefaultInstance() : metrics_;
+    }
+    /**
+     * <code>.greptime.v1.Metrics metrics = 2;</code>
+     */
+    @java.lang.Override
+    public io.greptime.v1.Common.MetricsOrBuilder getMetricsOrBuilder() {
+      return getMetrics();
+    }
+
    private byte memoizedIsInitialized = -1;
    @java.lang.Override
    public final boolean isInitialized() {
@@ -6500,6 +7048,9 @@ java.lang.String defaultValue);
      if (affectedRows_ != null) {
        output.writeMessage(1, getAffectedRows());
      }
+      if (metrics_ != null) {
+        output.writeMessage(2, getMetrics());
+      }
      unknownFields.writeTo(output);
    }

@@ -6513,6 +7064,10 @@ java.lang.String defaultValue);
        size += com.google.protobuf.CodedOutputStream
          .computeMessageSize(1, getAffectedRows());
      }
+      if (metrics_ != null) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeMessageSize(2, getMetrics());
+      }
      size += unknownFields.getSerializedSize();
      memoizedSize = size;
      return size;
@@ -6533,6 +7088,11 @@ java.lang.String defaultValue);
        if (!getAffectedRows()
            .equals(other.getAffectedRows())) return false;
      }
+      if (hasMetrics() != other.hasMetrics()) return false;
+      if (hasMetrics()) {
+        if (!getMetrics()
+            .equals(other.getMetrics())) return false;
+      }
      if (!unknownFields.equals(other.unknownFields)) return false;
      return true;
    }
@@ -6548,6 +7108,10 @@ java.lang.String defaultValue);
        hash = (37 * hash) + AFFECTED_ROWS_FIELD_NUMBER;
        hash = (53 * hash) + getAffectedRows().hashCode();
      }
+      if (hasMetrics()) {
+        hash = (37 * hash) + METRICS_FIELD_NUMBER;
+        hash = (53 * hash) + getMetrics().hashCode();
+      }
      hash = (29 * hash) + unknownFields.hashCode();
      memoizedHashCode = hash;
      return hash;
@@ -6687,6 +7251,12 @@ java.lang.String defaultValue);
          affectedRows_ = null;
          affectedRowsBuilder_ = null;
        }
+        if (metricsBuilder_ == null) {
+          metrics_ = null;
+        } else {
+          metrics_ = null;
+          metricsBuilder_ = null;
+        }
        return this;
      }

@@ -6718,6 +7288,11 @@ java.lang.String defaultValue);
        } else {
          result.affectedRows_ = affectedRowsBuilder_.build();
        }
+        if (metricsBuilder_ == null) {
+          result.metrics_ = metrics_;
+        } else {
+          result.metrics_ = metricsBuilder_.build();
+        }
        onBuilt();
        return result;
      }
@@ -6769,6 +7344,9 @@ java.lang.String defaultValue);
        if (other.hasAffectedRows()) {
          mergeAffectedRows(other.getAffectedRows());
        }
+        if (other.hasMetrics()) {
+          mergeMetrics(other.getMetrics());
+        }
        this.mergeUnknownFields(other.unknownFields);
        onChanged();
        return this;
@@ -6916,6 +7494,125 @@ java.lang.String defaultValue);
        }
        return affectedRowsBuilder_;
      }
+
+      private io.greptime.v1.Common.Metrics metrics_;
+      private com.google.protobuf.SingleFieldBuilderV3<
+          io.greptime.v1.Common.Metrics, io.greptime.v1.Common.Metrics.Builder, io.greptime.v1.Common.MetricsOrBuilder> metricsBuilder_;
+      /**
+       * <code>.greptime.v1.Metrics metrics = 2;</code>
+       * @return Whether the metrics field is set.
+       */
+      public boolean hasMetrics() {
+        return metricsBuilder_ != null || metrics_ != null;
+      }
+      /**
+       * <code>.greptime.v1.Metrics metrics = 2;</code>
+       * @return The metrics.
+       */
+      public io.greptime.v1.Common.Metrics getMetrics() {
+        if (metricsBuilder_ == null) {
+          return metrics_ == null ? io.greptime.v1.Common.Metrics.getDefaultInstance() : metrics_;
+        } else {
+          return metricsBuilder_.getMessage();
+        }
+      }
+      /**
+       * <code>.greptime.v1.Metrics metrics = 2;</code>
+       */
+      public Builder setMetrics(io.greptime.v1.Common.Metrics value) {
+        if (metricsBuilder_ == null) {
+          if (value == null) {
+            throw new NullPointerException();
+          }
+          metrics_ = value;
+          onChanged();
+        } else {
+          metricsBuilder_.setMessage(value);
+        }
+
+        return this;
+      }
+      /**
+       * <code>.greptime.v1.Metrics metrics = 2;</code>
+       */
+      public Builder setMetrics(
+          io.greptime.v1.Common.Metrics.Builder builderForValue) {
+        if (metricsBuilder_ == null) {
+          metrics_ = builderForValue.build();
+          onChanged();
+        } else {
+          metricsBuilder_.setMessage(builderForValue.build());
+        }
+
+        return this;
+      }
+      /**
+       * <code>.greptime.v1.Metrics metrics = 2;</code>
+       */
+      public Builder mergeMetrics(io.greptime.v1.Common.Metrics value) {
+        if (metricsBuilder_ == null) {
+          if (metrics_ != null) {
+            metrics_ =
+              io.greptime.v1.Common.Metrics.newBuilder(metrics_).mergeFrom(value).buildPartial();
+          } else {
+            metrics_ = value;
+          }
+          onChanged();
+        } else {
+          metricsBuilder_.mergeFrom(value);
+        }
+
+        return this;
+      }
+      /**
+       * <code>.greptime.v1.Metrics metrics = 2;</code>
+       */
+      public Builder clearMetrics() {
+        if (metricsBuilder_ == null) {
+          metrics_ = null;
+          onChanged();
+        } else {
+          metrics_ = null;
+          metricsBuilder_ = null;
+        }
+
+        return this;
+      }
+      /**
+       * <code>.greptime.v1.Metrics metrics = 2;</code>
+       */
+      public io.greptime.v1.Common.Metrics.Builder getMetricsBuilder() {
+        
+        onChanged();
+        return getMetricsFieldBuilder().getBuilder();
+      }
+      /**
+       * <code>.greptime.v1.Metrics metrics = 2;</code>
+       */
+      public io.greptime.v1.Common.MetricsOrBuilder getMetricsOrBuilder() {
+        if (metricsBuilder_ != null) {
+          return metricsBuilder_.getMessageOrBuilder();
+        } else {
+          return metrics_ == null ?
+              io.greptime.v1.Common.Metrics.getDefaultInstance() : metrics_;
+        }
+      }
+      /**
+       * <code>.greptime.v1.Metrics metrics = 2;</code>
+       */
+      private com.google.protobuf.SingleFieldBuilderV3<
+          io.greptime.v1.Common.Metrics, io.greptime.v1.Common.Metrics.Builder, io.greptime.v1.Common.MetricsOrBuilder> 
+          getMetricsFieldBuilder() {
+        if (metricsBuilder_ == null) {
+          metricsBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+              io.greptime.v1.Common.Metrics, io.greptime.v1.Common.Metrics.Builder, io.greptime.v1.Common.MetricsOrBuilder>(
+                  getMetrics(),
+                  getParentForChildren(),
+                  isClean());
+          metrics_ = null;
+        }
+        return metricsBuilder_;
+      }
      @java.lang.Override
      public final Builder setUnknownFields(
          final com.google.protobuf.UnknownFieldSet unknownFields) {
@@ -9499,6 +10196,11 @@ java.lang.String defaultValue);
  private static final 
    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_greptime_v1_AffectedRows_fieldAccessorTable;
+  private static final com.google.protobuf.Descriptors.Descriptor
+    internal_static_greptime_v1_Metrics_descriptor;
+  private static final 
+    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+      internal_static_greptime_v1_Metrics_fieldAccessorTable;
  private static final com.google.protobuf.Descriptors.Descriptor
    internal_static_greptime_v1_FlightMetadata_descriptor;
  private static final 
@@ -9548,33 +10250,35 @@ java.lang.String defaultValue);
      ".v1.TokenH\000B\r\n\013auth_scheme\"+\n\005Basic\022\020\n\010u" +
      "sername\030\001 \001(\t\022\020\n\010password\030\002 \001(\t\"\026\n\005Token" +
      "\022\r\n\005token\030\001 \001(\t\"\035\n\014AffectedRows\022\r\n\005value" +
-      "\030\001 \001(\r\"B\n\016FlightMetadata\0220\n\raffected_row" +
-      "s\030\001 \001(\0132\031.greptime.v1.AffectedRows\"I\n\024In" +
-      "tervalMonthDayNano\022\016\n\006months\030\001 \001(\005\022\014\n\004da" +
-      "ys\030\002 \001(\005\022\023\n\013nanoseconds\030\003 \001(\003\"$\n\nDecimal" +
-      "128\022\n\n\002hi\030\001 \001(\003\022\n\n\002lo\030\002 \001(\003\"`\n\027ColumnDat" +
-      "aTypeExtension\0229\n\014decimal_type\030\001 \001(\0132!.g" +
-      "reptime.v1.DecimalTypeExtensionH\000B\n\n\010typ" +
-      "e_ext\"8\n\024DecimalTypeExtension\022\021\n\tprecisi" +
-      "on\030\001 \001(\005\022\r\n\005scale\030\002 \001(\005*1\n\014SemanticType\022" +
-      "\007\n\003TAG\020\000\022\t\n\005FIELD\020\001\022\r\n\tTIMESTAMP\020\002*\270\004\n\016C" +
-      "olumnDataType\022\013\n\007BOOLEAN\020\000\022\010\n\004INT8\020\001\022\t\n\005" +
-      "INT16\020\002\022\t\n\005INT32\020\003\022\t\n\005INT64\020\004\022\t\n\005UINT8\020\005" +
-      "\022\n\n\006UINT16\020\006\022\n\n\006UINT32\020\007\022\n\n\006UINT64\020\010\022\013\n\007" +
-      "FLOAT32\020\t\022\013\n\007FLOAT64\020\n\022\n\n\006BINARY\020\013\022\n\n\006ST" +
-      "RING\020\014\022\010\n\004DATE\020\r\022\014\n\010DATETIME\020\016\022\024\n\020TIMEST" +
-      "AMP_SECOND\020\017\022\031\n\025TIMESTAMP_MILLISECOND\020\020\022" +
-      "\031\n\025TIMESTAMP_MICROSECOND\020\021\022\030\n\024TIMESTAMP_" +
-      "NANOSECOND\020\022\022\017\n\013TIME_SECOND\020\023\022\024\n\020TIME_MI" +
-      "LLISECOND\020\024\022\024\n\020TIME_MICROSECOND\020\025\022\023\n\017TIM" +
-      "E_NANOSECOND\020\026\022\027\n\023INTERVAL_YEAR_MONTH\020\027\022" +
-      "\025\n\021INTERVAL_DAY_TIME\020\030\022\033\n\027INTERVAL_MONTH" +
-      "_DAY_NANO\020\031\022\023\n\017DURATION_SECOND\020\032\022\030\n\024DURA" +
-      "TION_MILLISECOND\020\033\022\030\n\024DURATION_MICROSECO" +
-      "ND\020\034\022\027\n\023DURATION_NANOSECOND\020\035\022\016\n\nDECIMAL" +
-      "128\020\036BO\n\016io.greptime.v1B\006CommonZ5github." +
-      "com/GreptimeTeam/greptime-proto/go/grept" +
-      "ime/v1b\006proto3"
+      "\030\001 \001(\r\"\032\n\007Metrics\022\017\n\007metrics\030\001 \001(\014\"i\n\016Fl" +
+      "ightMetadata\0220\n\raffected_rows\030\001 \001(\0132\031.gr" +
+      "eptime.v1.AffectedRows\022%\n\007metrics\030\002 \001(\0132" +
+      "\024.greptime.v1.Metrics\"I\n\024IntervalMonthDa" +
+      "yNano\022\016\n\006months\030\001 \001(\005\022\014\n\004days\030\002 \001(\005\022\023\n\013n" +
+      "anoseconds\030\003 \001(\003\"$\n\nDecimal128\022\n\n\002hi\030\001 \001" +
+      "(\003\022\n\n\002lo\030\002 \001(\003\"`\n\027ColumnDataTypeExtensio" +
+      "n\0229\n\014decimal_type\030\001 \001(\0132!.greptime.v1.De" +
+      "cimalTypeExtensionH\000B\n\n\010type_ext\"8\n\024Deci" +
+      "malTypeExtension\022\021\n\tprecision\030\001 \001(\005\022\r\n\005s" +
+      "cale\030\002 \001(\005*1\n\014SemanticType\022\007\n\003TAG\020\000\022\t\n\005F" +
+      "IELD\020\001\022\r\n\tTIMESTAMP\020\002*\270\004\n\016ColumnDataType" +
+      "\022\013\n\007BOOLEAN\020\000\022\010\n\004INT8\020\001\022\t\n\005INT16\020\002\022\t\n\005IN" +
+      "T32\020\003\022\t\n\005INT64\020\004\022\t\n\005UINT8\020\005\022\n\n\006UINT16\020\006\022" +
+      "\n\n\006UINT32\020\007\022\n\n\006UINT64\020\010\022\013\n\007FLOAT32\020\t\022\013\n\007" +
+      "FLOAT64\020\n\022\n\n\006BINARY\020\013\022\n\n\006STRING\020\014\022\010\n\004DAT" +
+      "E\020\r\022\014\n\010DATETIME\020\016\022\024\n\020TIMESTAMP_SECOND\020\017\022" +
+      "\031\n\025TIMESTAMP_MILLISECOND\020\020\022\031\n\025TIMESTAMP_" +
+      "MICROSECOND\020\021\022\030\n\024TIMESTAMP_NANOSECOND\020\022\022" +
+      "\017\n\013TIME_SECOND\020\023\022\024\n\020TIME_MILLISECOND\020\024\022\024" +
+      "\n\020TIME_MICROSECOND\020\025\022\023\n\017TIME_NANOSECOND\020" +
+      "\026\022\027\n\023INTERVAL_YEAR_MONTH\020\027\022\025\n\021INTERVAL_D" +
+      "AY_TIME\020\030\022\033\n\027INTERVAL_MONTH_DAY_NANO\020\031\022\023" +
+      "\n\017DURATION_SECOND\020\032\022\030\n\024DURATION_MILLISEC" +
+      "OND\020\033\022\030\n\024DURATION_MICROSECOND\020\034\022\027\n\023DURAT" +
+      "ION_NANOSECOND\020\035\022\016\n\nDECIMAL128\020\036BO\n\016io.g" +
+      "reptime.v1B\006CommonZ5github.com/GreptimeT" +
+      "eam/greptime-proto/go/greptime/v1b\006proto" +
+      "3"
    };
    descriptor = com.google.protobuf.Descriptors.FileDescriptor
      .internalBuildGeneratedFileFrom(descriptorData,
@@ -9628,32 +10332,38 @@ java.lang.String defaultValue);
      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
        internal_static_greptime_v1_AffectedRows_descriptor,
        new java.lang.String[] { "Value", });
-    internal_static_greptime_v1_FlightMetadata_descriptor =
+    internal_static_greptime_v1_Metrics_descriptor =
      getDescriptor().getMessageTypes().get(7);
+    internal_static_greptime_v1_Metrics_fieldAccessorTable = new
+      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+        internal_static_greptime_v1_Metrics_descriptor,
+        new java.lang.String[] { "Metrics", });
+    internal_static_greptime_v1_FlightMetadata_descriptor =
+      getDescriptor().getMessageTypes().get(8);
    internal_static_greptime_v1_FlightMetadata_fieldAccessorTable = new
      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
        internal_static_greptime_v1_FlightMetadata_descriptor,
-        new java.lang.String[] { "AffectedRows", });
+        new java.lang.String[] { "AffectedRows", "Metrics", });
    internal_static_greptime_v1_IntervalMonthDayNano_descriptor =
-      getDescriptor().getMessageTypes().get(8);
+      getDescriptor().getMessageTypes().get(9);
    internal_static_greptime_v1_IntervalMonthDayNano_fieldAccessorTable = new
      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
        internal_static_greptime_v1_IntervalMonthDayNano_descriptor,
        new java.lang.String[] { "Months", "Days", "Nanoseconds", });
    internal_static_greptime_v1_Decimal128_descriptor =
-      getDescriptor().getMessageTypes().get(9);
+      getDescriptor().getMessageTypes().get(10);
    internal_static_greptime_v1_Decimal128_fieldAccessorTable = new
      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
        internal_static_greptime_v1_Decimal128_descriptor,
        new java.lang.String[] { "Hi", "Lo", });
    internal_static_greptime_v1_ColumnDataTypeExtension_descriptor =
-      getDescriptor().getMessageTypes().get(10);
+      getDescriptor().getMessageTypes().get(11);
    internal_static_greptime_v1_ColumnDataTypeExtension_fieldAccessorTable = new
      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
        internal_static_greptime_v1_ColumnDataTypeExtension_descriptor,
        new java.lang.String[] { "DecimalType", "TypeExt", });
    internal_static_greptime_v1_DecimalTypeExtension_descriptor =
-      getDescriptor().getMessageTypes().get(11);
+      getDescriptor().getMessageTypes().get(12);
    internal_static_greptime_v1_DecimalTypeExtension_fieldAccessorTable = new
      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
        internal_static_greptime_v1_DecimalTypeExtension_descriptor,