content: /*
   * Copyright (C) 2016-2023 ActionTech.
   * License: http://www.gnu.org/licenses/gpl.html GPL version 2 or higher.
   */
  
  package com.actiontech.dble.alarm;
  
  import static io.grpc.MethodDescriptor.generateFullMethodName;
  import static io.grpc.stub.ClientCalls.asyncUnaryCall;
  import static io.grpc.stub.ClientCalls.blockingUnaryCall;
  import static io.grpc.stub.ClientCalls.futureUnaryCall;
  import static io.grpc.stub.ServerCalls.asyncUnaryCall;
  import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
  
  /**
   *
   */
  @javax.annotation.Generated(
          value = "by gRPC proto compiler (version 1.4.0)",
          comments = "Source: ucore.proto")
  public final class UcoreGrpc {
  
      private UcoreGrpc() {
      }
  
      public static final String SERVICE_NAME = "ucore.Ucore";
  
      // Static method descriptors that strictly reflect the proto.
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.PutKvInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_PUT_KV =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.PutKvInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "PutKv"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.PutKvInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.GetKvInput,
              com.actiontech.dble.alarm.UcoreInterface.GetKvOutput> METHOD_GET_KV =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.GetKvInput, com.actiontech.dble.alarm.UcoreInterface.GetKvOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "GetKv"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetKvInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetKvOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.DeleteKvInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_DELETE_KV =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.DeleteKvInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "DeleteKv"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.DeleteKvInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.DeleteKvsInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_DELETE_KVS =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.DeleteKvsInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "DeleteKvs"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.DeleteKvsInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.DeleteKvTreeInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_DELETE_KV_TREE =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.DeleteKvTreeInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "DeleteKvTree"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.DeleteKvTreeInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvInput,
              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvOutput> METHOD_SUBSCRIBE_KV =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvInput, com.actiontech.dble.alarm.UcoreInterface.SubscribeKvOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "SubscribeKv"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixInput,
              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixOutput> METHOD_SUBSCRIBE_KV_PREFIX =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixInput, com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "SubscribeKvPrefix"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsInput,
              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsOutput> METHOD_SUBSCRIBE_KV_PREFIXS =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsInput, com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "SubscribeKvPrefixs"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesInput,
              com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesOutput> METHOD_SUBSCRIBE_NODES =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesInput, com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "SubscribeNodes"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput,
              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput> METHOD_GET_KV_TREE =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput, com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "GetKvTree"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput,
              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput> METHOD_GET_KV_TREE_RAW =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput, com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "GetKvTreeRaw"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.ListKvKeysInput,
              com.actiontech.dble.alarm.UcoreInterface.ListKvKeysOutput> METHOD_LIST_KV_KEYS =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.ListKvKeysInput, com.actiontech.dble.alarm.UcoreInterface.ListKvKeysOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "ListKvKeys"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.ListKvKeysInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.ListKvKeysOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.PutKvsInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_PUT_KVS =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.PutKvsInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "PutKvs"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.PutKvsInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.ServiceHeartbeatInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_SERVICE_HEARTBEAT =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.ServiceHeartbeatInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "ServiceHeartbeat"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.ServiceHeartbeatInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.RegisterServiceInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_REGISTER_SERVICE =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.RegisterServiceInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "RegisterService"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.RegisterServiceInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartInput,
              com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartOutput> METHOD_UPDATE_CONFIG_START =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartInput, com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "UpdateConfigStart"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.UpdateConfigCommitInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_UPDATE_CONFIG_COMMIT =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.UpdateConfigCommitInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "UpdateConfigCommit"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.UpdateConfigCommitInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.UpdateConfigRollbackInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_UPDATE_CONFIG_ROLLBACK =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.UpdateConfigRollbackInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "UpdateConfigRollback"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.UpdateConfigRollbackInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.AlertInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_ALERT =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.AlertInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "Alert"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.AlertInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.AlertInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_ALERT_RESOLVE =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.AlertInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "AlertResolve"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.AlertInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.AlertResolveByFingerprintInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_ALERT_RESOLVE_BY_FINGERPRINT =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.AlertResolveByFingerprintInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "AlertResolveByFingerprint"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.AlertResolveByFingerprintInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumInput,
              com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumOutput> METHOD_GET_UNRESOLVED_ALERTS_NUM =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumInput, com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "GetUnresolvedAlertsNum"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.SendAlertTestMessageInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_SEND_ALERT_TEST_MESSAGE =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.SendAlertTestMessageInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "SendAlertTestMessage"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.SendAlertTestMessageInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.Empty,
              com.actiontech.dble.alarm.UcoreInterface.GetUsageOutput> METHOD_GET_USAGE =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.Empty, com.actiontech.dble.alarm.UcoreInterface.GetUsageOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "GetUsage"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetUsageOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateInput,
              com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateOutput> METHOD_REQUEST_SERVER_CERTIFICATE =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateInput, com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "RequestServerCertificate"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.Empty,
              com.actiontech.dble.alarm.UcoreInterface.GetCaCertificateOutput> METHOD_GET_CA_CERTIFICATE =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.Empty, com.actiontech.dble.alarm.UcoreInterface.GetCaCertificateOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "GetCaCertificate"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetCaCertificateOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.Empty,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_IS_UCORE_INIT =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.Empty, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "IsUcoreInit"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosInput,
              com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosOutput> METHOD_COLLECT_CLUSTER_INFOS =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosInput, com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "CollectClusterInfos"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.Empty,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_UCORE_HEALTH_CHECK =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.Empty, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "UcoreHealthCheck"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawInput,
              com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawOutput> METHOD_LIST_KV_NEXT_LEVEL_RAW =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawInput, com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "ListKvNextLevelRaw"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawInput,
              com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawOutput> METHOD_LIST_KV_BY_PATH_RAW =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawInput, com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "ListKvByPathRaw"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.ReportUguardExerciseResultInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_REPORT_UGUARD_EXERCISE_RESULT =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.ReportUguardExerciseResultInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "ReportUguardExerciseResult"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.ReportUguardExerciseResultInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.Empty,
              com.actiontech.dble.alarm.UcoreInterface.UcoreLearderOutput> METHOD_UCORE_LEARDER =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.Empty, com.actiontech.dble.alarm.UcoreInterface.UcoreLearderOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "UcoreLearder"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.UcoreLearderOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.Empty,
              com.actiontech.dble.alarm.UcoreInterface.GetUcoreStatsOutput> METHOD_GET_UCORE_STATS =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.Empty, com.actiontech.dble.alarm.UcoreInterface.GetUcoreStatsOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "GetUcoreStats"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetUcoreStatsOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.ForceLeaveUcoreInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_FORCE_LEAVE_UCORE =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.ForceLeaveUcoreInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "ForceLeaveUcore"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.ForceLeaveUcoreInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitInput,
              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitOutput> METHOD_GET_KV_TREE_WITH_LIMIT =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitInput, com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "GetKvTreeWithLimit"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeInput,
              com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeOutput> METHOD_GET_KVS_TREE =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeInput, com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "GetKvsTree"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.LockOnSessionInput,
              com.actiontech.dble.alarm.UcoreInterface.LockOnSessionOutput> METHOD_LOCK_ON_SESSION =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.LockOnSessionInput, com.actiontech.dble.alarm.UcoreInterface.LockOnSessionOutput>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "LockOnSession"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.LockOnSessionInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.LockOnSessionOutput.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.RenewSessionInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_RENEW_SESSION =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.RenewSessionInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "RenewSession"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.RenewSessionInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
      @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
      public static final io.grpc.MethodDescriptor<com.actiontech.dble.alarm.UcoreInterface.UnlockOnSessionInput,
              com.actiontech.dble.alarm.UcoreInterface.Empty> METHOD_UNLOCK_ON_SESSION =
              io.grpc.MethodDescriptor.<com.actiontech.dble.alarm.UcoreInterface.UnlockOnSessionInput, com.actiontech.dble.alarm.UcoreInterface.Empty>newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(
                              "ucore.Ucore", "UnlockOnSession"))
                      .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.UnlockOnSessionInput.getDefaultInstance()))
                      .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
                              com.actiontech.dble.alarm.UcoreInterface.Empty.getDefaultInstance()))
                      .build();
  
      /**
       * Creates a new async stub that supports all call types for the service
       */
      public static UcoreStub newStub(io.grpc.Channel channel) {
          return new UcoreStub(channel);
      }
  
      /**
       * Creates a new blocking-style stub that supports unary and streaming output calls on the service
       */
      public static UcoreBlockingStub newBlockingStub(
              io.grpc.Channel channel) {
          return new UcoreBlockingStub(channel);
      }
  
      /**
       * Creates a new ListenableFuture-style stub that supports unary calls on the service
       */
      public static UcoreFutureStub newFutureStub(
              io.grpc.Channel channel) {
          return new UcoreFutureStub(channel);
      }
  
      /**
       *
       */
      public static abstract class UcoreImplBase implements io.grpc.BindableService {
  
          /**
           * <pre>
           * PutKv guarantee atomic.
           * </pre>
           */
          public void putKv(com.actiontech.dble.alarm.UcoreInterface.PutKvInput request,
                            io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_PUT_KV, responseObserver);
          }
  
          /**
           * <pre>
           * GetKv guarantee atomic.
           * </pre>
           */
          public void getKv(com.actiontech.dble.alarm.UcoreInterface.GetKvInput request,
                            io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_GET_KV, responseObserver);
          }
  
          /**
           * <pre>
           * DeleteKv guarantee atomic.
           * </pre>
           */
          public void deleteKv(com.actiontech.dble.alarm.UcoreInterface.DeleteKvInput request,
                               io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_DELETE_KV, responseObserver);
          }
  
          /**
           * <pre>
           * DeleteKvs guarantee atomic.
           * </pre>
           */
          public void deleteKvs(com.actiontech.dble.alarm.UcoreInterface.DeleteKvsInput request,
                                io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_DELETE_KVS, responseObserver);
          }
  
          /**
           * <pre>
           * DeleteKvTree guarantee atomic.
           * </pre>
           */
          public void deleteKvTree(com.actiontech.dble.alarm.UcoreInterface.DeleteKvTreeInput request,
                                   io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_DELETE_KV_TREE, responseObserver);
          }
  
          /**
           * <pre>
           * SubscribeKv returns when k-v changes or timeout.
           * </pre>
           */
          public void subscribeKv(com.actiontech.dble.alarm.UcoreInterface.SubscribeKvInput request,
                                  io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_SUBSCRIBE_KV, responseObserver);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefix returns when k-v with prefix changes or timeout.
           * </pre>
           */
          public void subscribeKvPrefix(com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixInput request,
                                        io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_SUBSCRIBE_KV_PREFIX, responseObserver);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefixs subscribe multi k-v prefixs, returns targets changes or timeout.
           * </pre>
           */
          public void subscribeKvPrefixs(com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsInput request,
                                         io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_SUBSCRIBE_KV_PREFIXS, responseObserver);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefixs returns when consul nodes changes or timeout.
           * </pre>
           */
          public void subscribeNodes(com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesInput request,
                                     io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_SUBSCRIBE_NODES, responseObserver);
          }
  
          /**
           * <pre>
           * GetKvTree guarantee atomic.
           * </pre>
           */
          public void getKvTree(com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput request,
                                io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_GET_KV_TREE, responseObserver);
          }
  
          /**
           * <pre>
           * GetKvTreeRaw guarantee atomic.
           * </pre>
           */
          public void getKvTreeRaw(com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput request,
                                   io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_GET_KV_TREE_RAW, responseObserver);
          }
  
          /**
           * <pre>
           * ListKvKeys guarantee atomic.
           * </pre>
           */
          public void listKvKeys(com.actiontech.dble.alarm.UcoreInterface.ListKvKeysInput request,
                                 io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.ListKvKeysOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_LIST_KV_KEYS, responseObserver);
          }
  
          /**
           * <pre>
           * PutKvs guarantee atomic.
           * </pre>
           */
          public void putKvs(com.actiontech.dble.alarm.UcoreInterface.PutKvsInput request,
                             io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_PUT_KVS, responseObserver);
          }
  
          /**
           * <pre>
           * ServiceHeartbeat, ucore-guarded service should report heartbeat via `ServiceHeartbeat`.
           * </pre>
           */
          public void serviceHeartbeat(com.actiontech.dble.alarm.UcoreInterface.ServiceHeartbeatInput request,
                                       io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_SERVICE_HEARTBEAT, responseObserver);
          }
  
          /**
           * <pre>
           * RegisterService mark service as ucore-guarded service.
           * </pre>
           */
          public void registerService(com.actiontech.dble.alarm.UcoreInterface.RegisterServiceInput request,
                                      io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_REGISTER_SERVICE, responseObserver);
          }
  
          /**
           * <pre>
           * UpdateConfigStart is of 3-phase commit.
           * </pre>
           */
          public void updateConfigStart(com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartInput request,
                                        io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_UPDATE_CONFIG_START, responseObserver);
          }
  
          /**
           * <pre>
           * UpdateConfigCommit is of 3-phase commit.
           * </pre>
           */
          public void updateConfigCommit(com.actiontech.dble.alarm.UcoreInterface.UpdateConfigCommitInput request,
                                         io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_UPDATE_CONFIG_COMMIT, responseObserver);
          }
  
          /**
           * <pre>
           * UpdateConfigRollback is of 3-phase commit.
           * </pre>
           */
          public void updateConfigRollback(com.actiontech.dble.alarm.UcoreInterface.UpdateConfigRollbackInput request,
                                           io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_UPDATE_CONFIG_ROLLBACK, responseObserver);
          }
  
          /**
           * <pre>
           * Alert record an alert message in consul, alertmanager should send notification after some time.
           * </pre>
           */
          public void alert(com.actiontech.dble.alarm.UcoreInterface.AlertInput request,
                            io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_ALERT, responseObserver);
          }
  
          /**
           * <pre>
           * AlertResolve mark some alerts as resolved.
           * </pre>
           */
          public void alertResolve(com.actiontech.dble.alarm.UcoreInterface.AlertInput request,
                                   io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_ALERT_RESOLVE, responseObserver);
          }
  
          /**
           * <pre>
           * AlertResolveByFingerprint mark the alert as resolved.
           * </pre>
           */
          public void alertResolveByFingerprint(com.actiontech.dble.alarm.UcoreInterface.AlertResolveByFingerprintInput request,
                                                io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_ALERT_RESOLVE_BY_FINGERPRINT, responseObserver);
          }
  
          /**
           *
           */
          public void getUnresolvedAlertsNum(com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumInput request,
                                             io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_GET_UNRESOLVED_ALERTS_NUM, responseObserver);
          }
  
          /**
           *
           */
          public void sendAlertTestMessage(com.actiontech.dble.alarm.UcoreInterface.SendAlertTestMessageInput request,
                                           io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_SEND_ALERT_TEST_MESSAGE, responseObserver);
          }
  
          /**
           * <pre>
           * GetUsage returns ucore rpc call usages.
           * </pre>
           */
          public void getUsage(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                               io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetUsageOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_GET_USAGE, responseObserver);
          }
  
          /**
           *
           */
          public void requestServerCertificate(com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateInput request,
                                               io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_REQUEST_SERVER_CERTIFICATE, responseObserver);
          }
  
          /**
           *
           */
          public void getCaCertificate(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                                       io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetCaCertificateOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_GET_CA_CERTIFICATE, responseObserver);
          }
  
          /**
           * <pre>
           * IsUcoreInit returns if consul is started.
           * </pre>
           */
          public void isUcoreInit(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                                  io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_IS_UCORE_INIT, responseObserver);
          }
  
          /**
           * <pre>
           * Collect local nodes infos
           * </pre>
           */
          public void collectClusterInfos(com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosInput request,
                                          io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_COLLECT_CLUSTER_INFOS, responseObserver);
          }
  
          /**
           * <pre>
           * UcoreHealthCheck check health of ucore and if its leader
           * </pre>
           */
          public void ucoreHealthCheck(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                                       io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_UCORE_HEALTH_CHECK, responseObserver);
          }
  
          /**
           * <pre>
           * ListKvNextLevelRaw not guarantee atomic.
           * </pre>
           */
          public void listKvNextLevelRaw(com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawInput request,
                                         io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_LIST_KV_NEXT_LEVEL_RAW, responseObserver);
          }
  
          /**
           * <pre>
           * ListKvByPathRaw not guarantee atomic.
           * </pre>
           */
          public void listKvByPathRaw(com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawInput request,
                                      io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_LIST_KV_BY_PATH_RAW, responseObserver);
          }
  
          /**
           *
           */
          public void reportUguardExerciseResult(com.actiontech.dble.alarm.UcoreInterface.ReportUguardExerciseResultInput request,
                                                 io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_REPORT_UGUARD_EXERCISE_RESULT, responseObserver);
          }
  
          /**
           *
           */
          public void ucoreLearder(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                                   io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.UcoreLearderOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_UCORE_LEARDER, responseObserver);
          }
  
          /**
           * <pre>
           * GetUcoreStats get ucore cluster status
           * </pre>
           */
          public void getUcoreStats(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                                    io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetUcoreStatsOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_GET_UCORE_STATS, responseObserver);
          }
  
          /**
           *
           */
          public void forceLeaveUcore(com.actiontech.dble.alarm.UcoreInterface.ForceLeaveUcoreInput request,
                                      io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_FORCE_LEAVE_UCORE, responseObserver);
          }
  
          /**
           *
           */
          public void getKvTreeWithLimit(com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitInput request,
                                         io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_GET_KV_TREE_WITH_LIMIT, responseObserver);
          }
  
          /**
           *
           */
          public void getKvsTree(com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeInput request,
                                 io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_GET_KVS_TREE, responseObserver);
          }
  
          /**
           *
           */
          public void lockOnSession(com.actiontech.dble.alarm.UcoreInterface.LockOnSessionInput request,
                                    io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.LockOnSessionOutput> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_LOCK_ON_SESSION, responseObserver);
          }
  
          /**
           *
           */
          public void renewSession(com.actiontech.dble.alarm.UcoreInterface.RenewSessionInput request,
                                   io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_RENEW_SESSION, responseObserver);
          }
  
          /**
           *
           */
          public void unlockOnSession(com.actiontech.dble.alarm.UcoreInterface.UnlockOnSessionInput request,
                                      io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnimplementedUnaryCall(METHOD_UNLOCK_ON_SESSION, responseObserver);
          }
  
          @java.lang.Override
          public final io.grpc.ServerServiceDefinition bindService() {
              return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
                      .addMethod(
                              METHOD_PUT_KV,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.PutKvInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_PUT_KV)))
                      .addMethod(
                              METHOD_GET_KV,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.GetKvInput,
                                              com.actiontech.dble.alarm.UcoreInterface.GetKvOutput>(
                                              this, METHODID_GET_KV)))
                      .addMethod(
                              METHOD_DELETE_KV,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.DeleteKvInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_DELETE_KV)))
                      .addMethod(
                              METHOD_DELETE_KVS,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.DeleteKvsInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_DELETE_KVS)))
                      .addMethod(
                              METHOD_DELETE_KV_TREE,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.DeleteKvTreeInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_DELETE_KV_TREE)))
                      .addMethod(
                              METHOD_SUBSCRIBE_KV,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvInput,
                                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvOutput>(
                                              this, METHODID_SUBSCRIBE_KV)))
                      .addMethod(
                              METHOD_SUBSCRIBE_KV_PREFIX,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixInput,
                                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixOutput>(
                                              this, METHODID_SUBSCRIBE_KV_PREFIX)))
                      .addMethod(
                              METHOD_SUBSCRIBE_KV_PREFIXS,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsInput,
                                              com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsOutput>(
                                              this, METHODID_SUBSCRIBE_KV_PREFIXS)))
                      .addMethod(
                              METHOD_SUBSCRIBE_NODES,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesInput,
                                              com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesOutput>(
                                              this, METHODID_SUBSCRIBE_NODES)))
                      .addMethod(
                              METHOD_GET_KV_TREE,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput,
                                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput>(
                                              this, METHODID_GET_KV_TREE)))
                      .addMethod(
                              METHOD_GET_KV_TREE_RAW,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput,
                                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput>(
                                              this, METHODID_GET_KV_TREE_RAW)))
                      .addMethod(
                              METHOD_LIST_KV_KEYS,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.ListKvKeysInput,
                                              com.actiontech.dble.alarm.UcoreInterface.ListKvKeysOutput>(
                                              this, METHODID_LIST_KV_KEYS)))
                      .addMethod(
                              METHOD_PUT_KVS,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.PutKvsInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_PUT_KVS)))
                      .addMethod(
                              METHOD_SERVICE_HEARTBEAT,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.ServiceHeartbeatInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_SERVICE_HEARTBEAT)))
                      .addMethod(
                              METHOD_REGISTER_SERVICE,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.RegisterServiceInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_REGISTER_SERVICE)))
                      .addMethod(
                              METHOD_UPDATE_CONFIG_START,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartInput,
                                              com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartOutput>(
                                              this, METHODID_UPDATE_CONFIG_START)))
                      .addMethod(
                              METHOD_UPDATE_CONFIG_COMMIT,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.UpdateConfigCommitInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_UPDATE_CONFIG_COMMIT)))
                      .addMethod(
                              METHOD_UPDATE_CONFIG_ROLLBACK,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.UpdateConfigRollbackInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_UPDATE_CONFIG_ROLLBACK)))
                      .addMethod(
                              METHOD_ALERT,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.AlertInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_ALERT)))
                      .addMethod(
                              METHOD_ALERT_RESOLVE,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.AlertInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_ALERT_RESOLVE)))
                      .addMethod(
                              METHOD_ALERT_RESOLVE_BY_FINGERPRINT,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.AlertResolveByFingerprintInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_ALERT_RESOLVE_BY_FINGERPRINT)))
                      .addMethod(
                              METHOD_GET_UNRESOLVED_ALERTS_NUM,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumInput,
                                              com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumOutput>(
                                              this, METHODID_GET_UNRESOLVED_ALERTS_NUM)))
                      .addMethod(
                              METHOD_SEND_ALERT_TEST_MESSAGE,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.SendAlertTestMessageInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_SEND_ALERT_TEST_MESSAGE)))
                      .addMethod(
                              METHOD_GET_USAGE,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.Empty,
                                              com.actiontech.dble.alarm.UcoreInterface.GetUsageOutput>(
                                              this, METHODID_GET_USAGE)))
                      .addMethod(
                              METHOD_REQUEST_SERVER_CERTIFICATE,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateInput,
                                              com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateOutput>(
                                              this, METHODID_REQUEST_SERVER_CERTIFICATE)))
                      .addMethod(
                              METHOD_GET_CA_CERTIFICATE,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.Empty,
                                              com.actiontech.dble.alarm.UcoreInterface.GetCaCertificateOutput>(
                                              this, METHODID_GET_CA_CERTIFICATE)))
                      .addMethod(
                              METHOD_IS_UCORE_INIT,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.Empty,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_IS_UCORE_INIT)))
                      .addMethod(
                              METHOD_COLLECT_CLUSTER_INFOS,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosInput,
                                              com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosOutput>(
                                              this, METHODID_COLLECT_CLUSTER_INFOS)))
                      .addMethod(
                              METHOD_UCORE_HEALTH_CHECK,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.Empty,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_UCORE_HEALTH_CHECK)))
                      .addMethod(
                              METHOD_LIST_KV_NEXT_LEVEL_RAW,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawInput,
                                              com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawOutput>(
                                              this, METHODID_LIST_KV_NEXT_LEVEL_RAW)))
                      .addMethod(
                              METHOD_LIST_KV_BY_PATH_RAW,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawInput,
                                              com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawOutput>(
                                              this, METHODID_LIST_KV_BY_PATH_RAW)))
                      .addMethod(
                              METHOD_REPORT_UGUARD_EXERCISE_RESULT,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.ReportUguardExerciseResultInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_REPORT_UGUARD_EXERCISE_RESULT)))
                      .addMethod(
                              METHOD_UCORE_LEARDER,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.Empty,
                                              com.actiontech.dble.alarm.UcoreInterface.UcoreLearderOutput>(
                                              this, METHODID_UCORE_LEARDER)))
                      .addMethod(
                              METHOD_GET_UCORE_STATS,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.Empty,
                                              com.actiontech.dble.alarm.UcoreInterface.GetUcoreStatsOutput>(
                                              this, METHODID_GET_UCORE_STATS)))
                      .addMethod(
                              METHOD_FORCE_LEAVE_UCORE,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.ForceLeaveUcoreInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_FORCE_LEAVE_UCORE)))
                      .addMethod(
                              METHOD_GET_KV_TREE_WITH_LIMIT,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitInput,
                                              com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitOutput>(
                                              this, METHODID_GET_KV_TREE_WITH_LIMIT)))
                      .addMethod(
                              METHOD_GET_KVS_TREE,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeInput,
                                              com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeOutput>(
                                              this, METHODID_GET_KVS_TREE)))
                      .addMethod(
                              METHOD_LOCK_ON_SESSION,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.LockOnSessionInput,
                                              com.actiontech.dble.alarm.UcoreInterface.LockOnSessionOutput>(
                                              this, METHODID_LOCK_ON_SESSION)))
                      .addMethod(
                              METHOD_RENEW_SESSION,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.RenewSessionInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_RENEW_SESSION)))
                      .addMethod(
                              METHOD_UNLOCK_ON_SESSION,
                              asyncUnaryCall(
                                      new MethodHandlers<
                                              com.actiontech.dble.alarm.UcoreInterface.UnlockOnSessionInput,
                                              com.actiontech.dble.alarm.UcoreInterface.Empty>(
                                              this, METHODID_UNLOCK_ON_SESSION)))
                      .build();
          }
      }
  
      /**
       *
       */
      public static final class UcoreStub extends io.grpc.stub.AbstractStub<UcoreStub> {
          private UcoreStub(io.grpc.Channel channel) {
              super(channel);
          }
  
          private UcoreStub(io.grpc.Channel channel,
                            io.grpc.CallOptions callOptions) {
              super(channel, callOptions);
          }
  
          @java.lang.Override
          protected UcoreStub build(io.grpc.Channel channel,
                                    io.grpc.CallOptions callOptions) {
              return new UcoreStub(channel, callOptions);
          }
  
          /**
           * <pre>
           * PutKv guarantee atomic.
           * </pre>
           */
          public void putKv(com.actiontech.dble.alarm.UcoreInterface.PutKvInput request,
                            io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_PUT_KV, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * GetKv guarantee atomic.
           * </pre>
           */
          public void getKv(com.actiontech.dble.alarm.UcoreInterface.GetKvInput request,
                            io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_GET_KV, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * DeleteKv guarantee atomic.
           * </pre>
           */
          public void deleteKv(com.actiontech.dble.alarm.UcoreInterface.DeleteKvInput request,
                               io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_DELETE_KV, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * DeleteKvs guarantee atomic.
           * </pre>
           */
          public void deleteKvs(com.actiontech.dble.alarm.UcoreInterface.DeleteKvsInput request,
                                io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_DELETE_KVS, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * DeleteKvTree guarantee atomic.
           * </pre>
           */
          public void deleteKvTree(com.actiontech.dble.alarm.UcoreInterface.DeleteKvTreeInput request,
                                   io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_DELETE_KV_TREE, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * SubscribeKv returns when k-v changes or timeout.
           * </pre>
           */
          public void subscribeKv(com.actiontech.dble.alarm.UcoreInterface.SubscribeKvInput request,
                                  io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_SUBSCRIBE_KV, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefix returns when k-v with prefix changes or timeout.
           * </pre>
           */
          public void subscribeKvPrefix(com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixInput request,
                                        io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_SUBSCRIBE_KV_PREFIX, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefixs subscribe multi k-v prefixs, returns targets changes or timeout.
           * </pre>
           */
          public void subscribeKvPrefixs(com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsInput request,
                                         io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_SUBSCRIBE_KV_PREFIXS, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefixs returns when consul nodes changes or timeout.
           * </pre>
           */
          public void subscribeNodes(com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesInput request,
                                     io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_SUBSCRIBE_NODES, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * GetKvTree guarantee atomic.
           * </pre>
           */
          public void getKvTree(com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput request,
                                io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_GET_KV_TREE, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * GetKvTreeRaw guarantee atomic.
           * </pre>
           */
          public void getKvTreeRaw(com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput request,
                                   io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_GET_KV_TREE_RAW, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * ListKvKeys guarantee atomic.
           * </pre>
           */
          public void listKvKeys(com.actiontech.dble.alarm.UcoreInterface.ListKvKeysInput request,
                                 io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.ListKvKeysOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_LIST_KV_KEYS, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * PutKvs guarantee atomic.
           * </pre>
           */
          public void putKvs(com.actiontech.dble.alarm.UcoreInterface.PutKvsInput request,
                             io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_PUT_KVS, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * ServiceHeartbeat, ucore-guarded service should report heartbeat via `ServiceHeartbeat`.
           * </pre>
           */
          public void serviceHeartbeat(com.actiontech.dble.alarm.UcoreInterface.ServiceHeartbeatInput request,
                                       io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_SERVICE_HEARTBEAT, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * RegisterService mark service as ucore-guarded service.
           * </pre>
           */
          public void registerService(com.actiontech.dble.alarm.UcoreInterface.RegisterServiceInput request,
                                      io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_REGISTER_SERVICE, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * UpdateConfigStart is of 3-phase commit.
           * </pre>
           */
          public void updateConfigStart(com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartInput request,
                                        io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_UPDATE_CONFIG_START, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * UpdateConfigCommit is of 3-phase commit.
           * </pre>
           */
          public void updateConfigCommit(com.actiontech.dble.alarm.UcoreInterface.UpdateConfigCommitInput request,
                                         io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_UPDATE_CONFIG_COMMIT, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * UpdateConfigRollback is of 3-phase commit.
           * </pre>
           */
          public void updateConfigRollback(com.actiontech.dble.alarm.UcoreInterface.UpdateConfigRollbackInput request,
                                           io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_UPDATE_CONFIG_ROLLBACK, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * Alert record an alert message in consul, alertmanager should send notification after some time.
           * </pre>
           */
          public void alert(com.actiontech.dble.alarm.UcoreInterface.AlertInput request,
                            io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_ALERT, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * AlertResolve mark some alerts as resolved.
           * </pre>
           */
          public void alertResolve(com.actiontech.dble.alarm.UcoreInterface.AlertInput request,
                                   io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_ALERT_RESOLVE, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * AlertResolveByFingerprint mark the alert as resolved.
           * </pre>
           */
          public void alertResolveByFingerprint(com.actiontech.dble.alarm.UcoreInterface.AlertResolveByFingerprintInput request,
                                                io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_ALERT_RESOLVE_BY_FINGERPRINT, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void getUnresolvedAlertsNum(com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumInput request,
                                             io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_GET_UNRESOLVED_ALERTS_NUM, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void sendAlertTestMessage(com.actiontech.dble.alarm.UcoreInterface.SendAlertTestMessageInput request,
                                           io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_SEND_ALERT_TEST_MESSAGE, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * GetUsage returns ucore rpc call usages.
           * </pre>
           */
          public void getUsage(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                               io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetUsageOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_GET_USAGE, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void requestServerCertificate(com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateInput request,
                                               io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_REQUEST_SERVER_CERTIFICATE, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void getCaCertificate(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                                       io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetCaCertificateOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_GET_CA_CERTIFICATE, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * IsUcoreInit returns if consul is started.
           * </pre>
           */
          public void isUcoreInit(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                                  io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_IS_UCORE_INIT, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * Collect local nodes infos
           * </pre>
           */
          public void collectClusterInfos(com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosInput request,
                                          io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_COLLECT_CLUSTER_INFOS, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * UcoreHealthCheck check health of ucore and if its leader
           * </pre>
           */
          public void ucoreHealthCheck(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                                       io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_UCORE_HEALTH_CHECK, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * ListKvNextLevelRaw not guarantee atomic.
           * </pre>
           */
          public void listKvNextLevelRaw(com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawInput request,
                                         io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_LIST_KV_NEXT_LEVEL_RAW, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * ListKvByPathRaw not guarantee atomic.
           * </pre>
           */
          public void listKvByPathRaw(com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawInput request,
                                      io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_LIST_KV_BY_PATH_RAW, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void reportUguardExerciseResult(com.actiontech.dble.alarm.UcoreInterface.ReportUguardExerciseResultInput request,
                                                 io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_REPORT_UGUARD_EXERCISE_RESULT, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void ucoreLearder(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                                   io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.UcoreLearderOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_UCORE_LEARDER, getCallOptions()), request, responseObserver);
          }
  
          /**
           * <pre>
           * GetUcoreStats get ucore cluster status
           * </pre>
           */
          public void getUcoreStats(com.actiontech.dble.alarm.UcoreInterface.Empty request,
                                    io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetUcoreStatsOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_GET_UCORE_STATS, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void forceLeaveUcore(com.actiontech.dble.alarm.UcoreInterface.ForceLeaveUcoreInput request,
                                      io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_FORCE_LEAVE_UCORE, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void getKvTreeWithLimit(com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitInput request,
                                         io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_GET_KV_TREE_WITH_LIMIT, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void getKvsTree(com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeInput request,
                                 io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_GET_KVS_TREE, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void lockOnSession(com.actiontech.dble.alarm.UcoreInterface.LockOnSessionInput request,
                                    io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.LockOnSessionOutput> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_LOCK_ON_SESSION, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void renewSession(com.actiontech.dble.alarm.UcoreInterface.RenewSessionInput request,
                                   io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_RENEW_SESSION, getCallOptions()), request, responseObserver);
          }
  
          /**
           *
           */
          public void unlockOnSession(com.actiontech.dble.alarm.UcoreInterface.UnlockOnSessionInput request,
                                      io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty> responseObserver) {
              asyncUnaryCall(
                      getChannel().newCall(METHOD_UNLOCK_ON_SESSION, getCallOptions()), request, responseObserver);
          }
      }
  
      /**
       *
       */
      public static final class UcoreBlockingStub extends io.grpc.stub.AbstractStub<UcoreBlockingStub> {
          private UcoreBlockingStub(io.grpc.Channel channel) {
              super(channel);
          }
  
          private UcoreBlockingStub(io.grpc.Channel channel,
                                    io.grpc.CallOptions callOptions) {
              super(channel, callOptions);
          }
  
          @java.lang.Override
          protected UcoreBlockingStub build(io.grpc.Channel channel,
                                            io.grpc.CallOptions callOptions) {
              return new UcoreBlockingStub(channel, callOptions);
          }
  
          /**
           * <pre>
           * PutKv guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty putKv(com.actiontech.dble.alarm.UcoreInterface.PutKvInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_PUT_KV, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * GetKv guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.GetKvOutput getKv(com.actiontech.dble.alarm.UcoreInterface.GetKvInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_GET_KV, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * DeleteKv guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty deleteKv(com.actiontech.dble.alarm.UcoreInterface.DeleteKvInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_DELETE_KV, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * DeleteKvs guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty deleteKvs(com.actiontech.dble.alarm.UcoreInterface.DeleteKvsInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_DELETE_KVS, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * DeleteKvTree guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty deleteKvTree(com.actiontech.dble.alarm.UcoreInterface.DeleteKvTreeInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_DELETE_KV_TREE, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * SubscribeKv returns when k-v changes or timeout.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.SubscribeKvOutput subscribeKv(com.actiontech.dble.alarm.UcoreInterface.SubscribeKvInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_SUBSCRIBE_KV, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefix returns when k-v with prefix changes or timeout.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixOutput subscribeKvPrefix(com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_SUBSCRIBE_KV_PREFIX, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefixs subscribe multi k-v prefixs, returns targets changes or timeout.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsOutput subscribeKvPrefixs(com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_SUBSCRIBE_KV_PREFIXS, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefixs returns when consul nodes changes or timeout.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesOutput subscribeNodes(com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_SUBSCRIBE_NODES, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * GetKvTree guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput getKvTree(com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_GET_KV_TREE, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * GetKvTreeRaw guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput getKvTreeRaw(com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_GET_KV_TREE_RAW, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * ListKvKeys guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.ListKvKeysOutput listKvKeys(com.actiontech.dble.alarm.UcoreInterface.ListKvKeysInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_LIST_KV_KEYS, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * PutKvs guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty putKvs(com.actiontech.dble.alarm.UcoreInterface.PutKvsInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_PUT_KVS, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * ServiceHeartbeat, ucore-guarded service should report heartbeat via `ServiceHeartbeat`.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty serviceHeartbeat(com.actiontech.dble.alarm.UcoreInterface.ServiceHeartbeatInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_SERVICE_HEARTBEAT, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * RegisterService mark service as ucore-guarded service.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty registerService(com.actiontech.dble.alarm.UcoreInterface.RegisterServiceInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_REGISTER_SERVICE, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * UpdateConfigStart is of 3-phase commit.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartOutput updateConfigStart(com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_UPDATE_CONFIG_START, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * UpdateConfigCommit is of 3-phase commit.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty updateConfigCommit(com.actiontech.dble.alarm.UcoreInterface.UpdateConfigCommitInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_UPDATE_CONFIG_COMMIT, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * UpdateConfigRollback is of 3-phase commit.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty updateConfigRollback(com.actiontech.dble.alarm.UcoreInterface.UpdateConfigRollbackInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_UPDATE_CONFIG_ROLLBACK, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * Alert record an alert message in consul, alertmanager should send notification after some time.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty alert(com.actiontech.dble.alarm.UcoreInterface.AlertInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_ALERT, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * AlertResolve mark some alerts as resolved.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty alertResolve(com.actiontech.dble.alarm.UcoreInterface.AlertInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_ALERT_RESOLVE, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * AlertResolveByFingerprint mark the alert as resolved.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty alertResolveByFingerprint(com.actiontech.dble.alarm.UcoreInterface.AlertResolveByFingerprintInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_ALERT_RESOLVE_BY_FINGERPRINT, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumOutput getUnresolvedAlertsNum(com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_GET_UNRESOLVED_ALERTS_NUM, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty sendAlertTestMessage(com.actiontech.dble.alarm.UcoreInterface.SendAlertTestMessageInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_SEND_ALERT_TEST_MESSAGE, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * GetUsage returns ucore rpc call usages.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.GetUsageOutput getUsage(com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_GET_USAGE, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateOutput requestServerCertificate(com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_REQUEST_SERVER_CERTIFICATE, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.GetCaCertificateOutput getCaCertificate(com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_GET_CA_CERTIFICATE, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * IsUcoreInit returns if consul is started.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty isUcoreInit(com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_IS_UCORE_INIT, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * Collect local nodes infos
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosOutput collectClusterInfos(com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_COLLECT_CLUSTER_INFOS, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * UcoreHealthCheck check health of ucore and if its leader
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty ucoreHealthCheck(com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_UCORE_HEALTH_CHECK, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * ListKvNextLevelRaw not guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawOutput listKvNextLevelRaw(com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_LIST_KV_NEXT_LEVEL_RAW, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * ListKvByPathRaw not guarantee atomic.
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawOutput listKvByPathRaw(com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_LIST_KV_BY_PATH_RAW, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty reportUguardExerciseResult(com.actiontech.dble.alarm.UcoreInterface.ReportUguardExerciseResultInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_REPORT_UGUARD_EXERCISE_RESULT, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.UcoreLearderOutput ucoreLearder(com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_UCORE_LEARDER, getCallOptions(), request);
          }
  
          /**
           * <pre>
           * GetUcoreStats get ucore cluster status
           * </pre>
           */
          public com.actiontech.dble.alarm.UcoreInterface.GetUcoreStatsOutput getUcoreStats(com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_GET_UCORE_STATS, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty forceLeaveUcore(com.actiontech.dble.alarm.UcoreInterface.ForceLeaveUcoreInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_FORCE_LEAVE_UCORE, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitOutput getKvTreeWithLimit(com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_GET_KV_TREE_WITH_LIMIT, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeOutput getKvsTree(com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_GET_KVS_TREE, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.LockOnSessionOutput lockOnSession(com.actiontech.dble.alarm.UcoreInterface.LockOnSessionInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_LOCK_ON_SESSION, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty renewSession(com.actiontech.dble.alarm.UcoreInterface.RenewSessionInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_RENEW_SESSION, getCallOptions(), request);
          }
  
          /**
           *
           */
          public com.actiontech.dble.alarm.UcoreInterface.Empty unlockOnSession(com.actiontech.dble.alarm.UcoreInterface.UnlockOnSessionInput request) {
              return blockingUnaryCall(
                      getChannel(), METHOD_UNLOCK_ON_SESSION, getCallOptions(), request);
          }
      }
  
      /**
       *
       */
      public static final class UcoreFutureStub extends io.grpc.stub.AbstractStub<UcoreFutureStub> {
          private UcoreFutureStub(io.grpc.Channel channel) {
              super(channel);
          }
  
          private UcoreFutureStub(io.grpc.Channel channel,
                                  io.grpc.CallOptions callOptions) {
              super(channel, callOptions);
          }
  
          @java.lang.Override
          protected UcoreFutureStub build(io.grpc.Channel channel,
                                          io.grpc.CallOptions callOptions) {
              return new UcoreFutureStub(channel, callOptions);
          }
  
          /**
           * <pre>
           * PutKv guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> putKv(
                  com.actiontech.dble.alarm.UcoreInterface.PutKvInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_PUT_KV, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * GetKv guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.GetKvOutput> getKv(
                  com.actiontech.dble.alarm.UcoreInterface.GetKvInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_GET_KV, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * DeleteKv guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> deleteKv(
                  com.actiontech.dble.alarm.UcoreInterface.DeleteKvInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_DELETE_KV, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * DeleteKvs guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> deleteKvs(
                  com.actiontech.dble.alarm.UcoreInterface.DeleteKvsInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_DELETE_KVS, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * DeleteKvTree guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> deleteKvTree(
                  com.actiontech.dble.alarm.UcoreInterface.DeleteKvTreeInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_DELETE_KV_TREE, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * SubscribeKv returns when k-v changes or timeout.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvOutput> subscribeKv(
                  com.actiontech.dble.alarm.UcoreInterface.SubscribeKvInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_SUBSCRIBE_KV, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefix returns when k-v with prefix changes or timeout.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixOutput> subscribeKvPrefix(
                  com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_SUBSCRIBE_KV_PREFIX, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefixs subscribe multi k-v prefixs, returns targets changes or timeout.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsOutput> subscribeKvPrefixs(
                  com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_SUBSCRIBE_KV_PREFIXS, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * SubscribeKvPrefixs returns when consul nodes changes or timeout.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesOutput> subscribeNodes(
                  com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_SUBSCRIBE_NODES, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * GetKvTree guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput> getKvTree(
                  com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_GET_KV_TREE, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * GetKvTreeRaw guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput> getKvTreeRaw(
                  com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_GET_KV_TREE_RAW, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * ListKvKeys guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.ListKvKeysOutput> listKvKeys(
                  com.actiontech.dble.alarm.UcoreInterface.ListKvKeysInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_LIST_KV_KEYS, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * PutKvs guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> putKvs(
                  com.actiontech.dble.alarm.UcoreInterface.PutKvsInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_PUT_KVS, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * ServiceHeartbeat, ucore-guarded service should report heartbeat via `ServiceHeartbeat`.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> serviceHeartbeat(
                  com.actiontech.dble.alarm.UcoreInterface.ServiceHeartbeatInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_SERVICE_HEARTBEAT, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * RegisterService mark service as ucore-guarded service.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> registerService(
                  com.actiontech.dble.alarm.UcoreInterface.RegisterServiceInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_REGISTER_SERVICE, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * UpdateConfigStart is of 3-phase commit.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartOutput> updateConfigStart(
                  com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_UPDATE_CONFIG_START, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * UpdateConfigCommit is of 3-phase commit.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> updateConfigCommit(
                  com.actiontech.dble.alarm.UcoreInterface.UpdateConfigCommitInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_UPDATE_CONFIG_COMMIT, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * UpdateConfigRollback is of 3-phase commit.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> updateConfigRollback(
                  com.actiontech.dble.alarm.UcoreInterface.UpdateConfigRollbackInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_UPDATE_CONFIG_ROLLBACK, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * Alert record an alert message in consul, alertmanager should send notification after some time.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> alert(
                  com.actiontech.dble.alarm.UcoreInterface.AlertInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_ALERT, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * AlertResolve mark some alerts as resolved.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> alertResolve(
                  com.actiontech.dble.alarm.UcoreInterface.AlertInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_ALERT_RESOLVE, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * AlertResolveByFingerprint mark the alert as resolved.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> alertResolveByFingerprint(
                  com.actiontech.dble.alarm.UcoreInterface.AlertResolveByFingerprintInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_ALERT_RESOLVE_BY_FINGERPRINT, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumOutput> getUnresolvedAlertsNum(
                  com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_GET_UNRESOLVED_ALERTS_NUM, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> sendAlertTestMessage(
                  com.actiontech.dble.alarm.UcoreInterface.SendAlertTestMessageInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_SEND_ALERT_TEST_MESSAGE, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * GetUsage returns ucore rpc call usages.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.GetUsageOutput> getUsage(
                  com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_GET_USAGE, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateOutput> requestServerCertificate(
                  com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_REQUEST_SERVER_CERTIFICATE, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.GetCaCertificateOutput> getCaCertificate(
                  com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_GET_CA_CERTIFICATE, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * IsUcoreInit returns if consul is started.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> isUcoreInit(
                  com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_IS_UCORE_INIT, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * Collect local nodes infos
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosOutput> collectClusterInfos(
                  com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_COLLECT_CLUSTER_INFOS, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * UcoreHealthCheck check health of ucore and if its leader
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> ucoreHealthCheck(
                  com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_UCORE_HEALTH_CHECK, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * ListKvNextLevelRaw not guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawOutput> listKvNextLevelRaw(
                  com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_LIST_KV_NEXT_LEVEL_RAW, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * ListKvByPathRaw not guarantee atomic.
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawOutput> listKvByPathRaw(
                  com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_LIST_KV_BY_PATH_RAW, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> reportUguardExerciseResult(
                  com.actiontech.dble.alarm.UcoreInterface.ReportUguardExerciseResultInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_REPORT_UGUARD_EXERCISE_RESULT, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.UcoreLearderOutput> ucoreLearder(
                  com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_UCORE_LEARDER, getCallOptions()), request);
          }
  
          /**
           * <pre>
           * GetUcoreStats get ucore cluster status
           * </pre>
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.GetUcoreStatsOutput> getUcoreStats(
                  com.actiontech.dble.alarm.UcoreInterface.Empty request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_GET_UCORE_STATS, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> forceLeaveUcore(
                  com.actiontech.dble.alarm.UcoreInterface.ForceLeaveUcoreInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_FORCE_LEAVE_UCORE, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitOutput> getKvTreeWithLimit(
                  com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_GET_KV_TREE_WITH_LIMIT, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeOutput> getKvsTree(
                  com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_GET_KVS_TREE, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.LockOnSessionOutput> lockOnSession(
                  com.actiontech.dble.alarm.UcoreInterface.LockOnSessionInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_LOCK_ON_SESSION, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> renewSession(
                  com.actiontech.dble.alarm.UcoreInterface.RenewSessionInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_RENEW_SESSION, getCallOptions()), request);
          }
  
          /**
           *
           */
          public com.google.common.util.concurrent.ListenableFuture<com.actiontech.dble.alarm.UcoreInterface.Empty> unlockOnSession(
                  com.actiontech.dble.alarm.UcoreInterface.UnlockOnSessionInput request) {
              return futureUnaryCall(
                      getChannel().newCall(METHOD_UNLOCK_ON_SESSION, getCallOptions()), request);
          }
      }
  
      private static final int METHODID_PUT_KV = 0;
      private static final int METHODID_GET_KV = 1;
      private static final int METHODID_DELETE_KV = 2;
      private static final int METHODID_DELETE_KVS = 3;
      private static final int METHODID_DELETE_KV_TREE = 4;
      private static final int METHODID_SUBSCRIBE_KV = 5;
      private static final int METHODID_SUBSCRIBE_KV_PREFIX = 6;
      private static final int METHODID_SUBSCRIBE_KV_PREFIXS = 7;
      private static final int METHODID_SUBSCRIBE_NODES = 8;
      private static final int METHODID_GET_KV_TREE = 9;
      private static final int METHODID_GET_KV_TREE_RAW = 10;
      private static final int METHODID_LIST_KV_KEYS = 11;
      private static final int METHODID_PUT_KVS = 12;
      private static final int METHODID_SERVICE_HEARTBEAT = 13;
      private static final int METHODID_REGISTER_SERVICE = 14;
      private static final int METHODID_UPDATE_CONFIG_START = 15;
      private static final int METHODID_UPDATE_CONFIG_COMMIT = 16;
      private static final int METHODID_UPDATE_CONFIG_ROLLBACK = 17;
      private static final int METHODID_ALERT = 18;
      private static final int METHODID_ALERT_RESOLVE = 19;
      private static final int METHODID_ALERT_RESOLVE_BY_FINGERPRINT = 20;
      private static final int METHODID_GET_UNRESOLVED_ALERTS_NUM = 21;
      private static final int METHODID_SEND_ALERT_TEST_MESSAGE = 22;
      private static final int METHODID_GET_USAGE = 23;
      private static final int METHODID_REQUEST_SERVER_CERTIFICATE = 24;
      private static final int METHODID_GET_CA_CERTIFICATE = 25;
      private static final int METHODID_IS_UCORE_INIT = 26;
      private static final int METHODID_COLLECT_CLUSTER_INFOS = 27;
      private static final int METHODID_UCORE_HEALTH_CHECK = 28;
      private static final int METHODID_LIST_KV_NEXT_LEVEL_RAW = 29;
      private static final int METHODID_LIST_KV_BY_PATH_RAW = 30;
      private static final int METHODID_REPORT_UGUARD_EXERCISE_RESULT = 31;
      private static final int METHODID_UCORE_LEARDER = 32;
      private static final int METHODID_GET_UCORE_STATS = 33;
      private static final int METHODID_FORCE_LEAVE_UCORE = 34;
      private static final int METHODID_GET_KV_TREE_WITH_LIMIT = 35;
      private static final int METHODID_GET_KVS_TREE = 36;
      private static final int METHODID_LOCK_ON_SESSION = 37;
      private static final int METHODID_RENEW_SESSION = 38;
      private static final int METHODID_UNLOCK_ON_SESSION = 39;
  
      private static final class MethodHandlers<Req, Resp> implements
              io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
              io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
              io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
              io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
          private final UcoreImplBase serviceImpl;
          private final int methodId;
  
          MethodHandlers(UcoreImplBase serviceImpl, int methodId) {
              this.serviceImpl = serviceImpl;
              this.methodId = methodId;
          }
  
          @java.lang.Override
          @java.lang.SuppressWarnings("unchecked")
          public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
              switch (methodId) {
                  case METHODID_PUT_KV:
                      serviceImpl.putKv((com.actiontech.dble.alarm.UcoreInterface.PutKvInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_GET_KV:
                      serviceImpl.getKv((com.actiontech.dble.alarm.UcoreInterface.GetKvInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvOutput>) responseObserver);
                      break;
                  case METHODID_DELETE_KV:
                      serviceImpl.deleteKv((com.actiontech.dble.alarm.UcoreInterface.DeleteKvInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_DELETE_KVS:
                      serviceImpl.deleteKvs((com.actiontech.dble.alarm.UcoreInterface.DeleteKvsInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_DELETE_KV_TREE:
                      serviceImpl.deleteKvTree((com.actiontech.dble.alarm.UcoreInterface.DeleteKvTreeInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_SUBSCRIBE_KV:
                      serviceImpl.subscribeKv((com.actiontech.dble.alarm.UcoreInterface.SubscribeKvInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvOutput>) responseObserver);
                      break;
                  case METHODID_SUBSCRIBE_KV_PREFIX:
                      serviceImpl.subscribeKvPrefix((com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixOutput>) responseObserver);
                      break;
                  case METHODID_SUBSCRIBE_KV_PREFIXS:
                      serviceImpl.subscribeKvPrefixs((com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeKvPrefixsOutput>) responseObserver);
                      break;
                  case METHODID_SUBSCRIBE_NODES:
                      serviceImpl.subscribeNodes((com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.SubscribeNodesOutput>) responseObserver);
                      break;
                  case METHODID_GET_KV_TREE:
                      serviceImpl.getKvTree((com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput>) responseObserver);
                      break;
                  case METHODID_GET_KV_TREE_RAW:
                      serviceImpl.getKvTreeRaw((com.actiontech.dble.alarm.UcoreInterface.GetKvTreeInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeOutput>) responseObserver);
                      break;
                  case METHODID_LIST_KV_KEYS:
                      serviceImpl.listKvKeys((com.actiontech.dble.alarm.UcoreInterface.ListKvKeysInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.ListKvKeysOutput>) responseObserver);
                      break;
                  case METHODID_PUT_KVS:
                      serviceImpl.putKvs((com.actiontech.dble.alarm.UcoreInterface.PutKvsInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_SERVICE_HEARTBEAT:
                      serviceImpl.serviceHeartbeat((com.actiontech.dble.alarm.UcoreInterface.ServiceHeartbeatInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_REGISTER_SERVICE:
                      serviceImpl.registerService((com.actiontech.dble.alarm.UcoreInterface.RegisterServiceInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_UPDATE_CONFIG_START:
                      serviceImpl.updateConfigStart((com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.UpdateConfigStartOutput>) responseObserver);
                      break;
                  case METHODID_UPDATE_CONFIG_COMMIT:
                      serviceImpl.updateConfigCommit((com.actiontech.dble.alarm.UcoreInterface.UpdateConfigCommitInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_UPDATE_CONFIG_ROLLBACK:
                      serviceImpl.updateConfigRollback((com.actiontech.dble.alarm.UcoreInterface.UpdateConfigRollbackInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_ALERT:
                      serviceImpl.alert((com.actiontech.dble.alarm.UcoreInterface.AlertInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_ALERT_RESOLVE:
                      serviceImpl.alertResolve((com.actiontech.dble.alarm.UcoreInterface.AlertInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_ALERT_RESOLVE_BY_FINGERPRINT:
                      serviceImpl.alertResolveByFingerprint((com.actiontech.dble.alarm.UcoreInterface.AlertResolveByFingerprintInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_GET_UNRESOLVED_ALERTS_NUM:
                      serviceImpl.getUnresolvedAlertsNum((com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetUnresolvedAlertsNumOutput>) responseObserver);
                      break;
                  case METHODID_SEND_ALERT_TEST_MESSAGE:
                      serviceImpl.sendAlertTestMessage((com.actiontech.dble.alarm.UcoreInterface.SendAlertTestMessageInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_GET_USAGE:
                      serviceImpl.getUsage((com.actiontech.dble.alarm.UcoreInterface.Empty) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetUsageOutput>) responseObserver);
                      break;
                  case METHODID_REQUEST_SERVER_CERTIFICATE:
                      serviceImpl.requestServerCertificate((com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.RequestServerCertificateOutput>) responseObserver);
                      break;
                  case METHODID_GET_CA_CERTIFICATE:
                      serviceImpl.getCaCertificate((com.actiontech.dble.alarm.UcoreInterface.Empty) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetCaCertificateOutput>) responseObserver);
                      break;
                  case METHODID_IS_UCORE_INIT:
                      serviceImpl.isUcoreInit((com.actiontech.dble.alarm.UcoreInterface.Empty) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_COLLECT_CLUSTER_INFOS:
                      serviceImpl.collectClusterInfos((com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.CollectClusterInfosOutput>) responseObserver);
                      break;
                  case METHODID_UCORE_HEALTH_CHECK:
                      serviceImpl.ucoreHealthCheck((com.actiontech.dble.alarm.UcoreInterface.Empty) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_LIST_KV_NEXT_LEVEL_RAW:
                      serviceImpl.listKvNextLevelRaw((com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.ListKvNextLevelRawOutput>) responseObserver);
                      break;
                  case METHODID_LIST_KV_BY_PATH_RAW:
                      serviceImpl.listKvByPathRaw((com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.ListKvByPathRawOutput>) responseObserver);
                      break;
                  case METHODID_REPORT_UGUARD_EXERCISE_RESULT:
                      serviceImpl.reportUguardExerciseResult((com.actiontech.dble.alarm.UcoreInterface.ReportUguardExerciseResultInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_UCORE_LEARDER:
                      serviceImpl.ucoreLearder((com.actiontech.dble.alarm.UcoreInterface.Empty) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.UcoreLearderOutput>) responseObserver);
                      break;
                  case METHODID_GET_UCORE_STATS:
                      serviceImpl.getUcoreStats((com.actiontech.dble.alarm.UcoreInterface.Empty) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetUcoreStatsOutput>) responseObserver);
                      break;
                  case METHODID_FORCE_LEAVE_UCORE:
                      serviceImpl.forceLeaveUcore((com.actiontech.dble.alarm.UcoreInterface.ForceLeaveUcoreInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_GET_KV_TREE_WITH_LIMIT:
                      serviceImpl.getKvTreeWithLimit((com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvTreeWithLimitOutput>) responseObserver);
                      break;
                  case METHODID_GET_KVS_TREE:
                      serviceImpl.getKvsTree((com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.GetKvsTreeOutput>) responseObserver);
                      break;
                  case METHODID_LOCK_ON_SESSION:
                      serviceImpl.lockOnSession((com.actiontech.dble.alarm.UcoreInterface.LockOnSessionInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.LockOnSessionOutput>) responseObserver);
                      break;
                  case METHODID_RENEW_SESSION:
                      serviceImpl.renewSession((com.actiontech.dble.alarm.UcoreInterface.RenewSessionInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  case METHODID_UNLOCK_ON_SESSION:
                      serviceImpl.unlockOnSession((com.actiontech.dble.alarm.UcoreInterface.UnlockOnSessionInput) request,
                              (io.grpc.stub.StreamObserver<com.actiontech.dble.alarm.UcoreInterface.Empty>) responseObserver);
                      break;
                  default:
                      throw new AssertionError();
              }
          }
  
          @java.lang.Override
          @java.lang.SuppressWarnings("unchecked")
          public io.grpc.stub.StreamObserver<Req> invoke(
                  io.grpc.stub.StreamObserver<Resp> responseObserver) {
              switch (methodId) {
                  default:
                      throw new AssertionError();
              }
          }
      }
  
      private static final class UcoreDescriptorSupplier implements io.grpc.protobuf.ProtoFileDescriptorSupplier {
          @java.lang.Override
          public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
              return com.actiontech.dble.alarm.UcoreInterface.getDescriptor();
          }
      }
  
      private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
  
      public static io.grpc.ServiceDescriptor getServiceDescriptor() {
          io.grpc.ServiceDescriptor result = serviceDescriptor;
          if (result == null) {
              synchronized (UcoreGrpc.class) {
                  result = serviceDescriptor;
                  if (result == null) {
                      serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
                              .setSchemaDescriptor(new UcoreDescriptorSupplier())
                              .addMethod(METHOD_PUT_KV)
                              .addMethod(METHOD_GET_KV)
                              .addMethod(METHOD_DELETE_KV)
                              .addMethod(METHOD_DELETE_KVS)
                              .addMethod(METHOD_DELETE_KV_TREE)
                              .addMethod(METHOD_SUBSCRIBE_KV)
                              .addMethod(METHOD_SUBSCRIBE_KV_PREFIX)
                              .addMethod(METHOD_SUBSCRIBE_KV_PREFIXS)
                              .addMethod(METHOD_SUBSCRIBE_NODES)
                              .addMethod(METHOD_GET_KV_TREE)
                              .addMethod(METHOD_GET_KV_TREE_RAW)
                              .addMethod(METHOD_LIST_KV_KEYS)
                              .addMethod(METHOD_PUT_KVS)
                              .addMethod(METHOD_SERVICE_HEARTBEAT)
                              .addMethod(METHOD_REGISTER_SERVICE)
                              .addMethod(METHOD_UPDATE_CONFIG_START)
                              .addMethod(METHOD_UPDATE_CONFIG_COMMIT)
                              .addMethod(METHOD_UPDATE_CONFIG_ROLLBACK)
                              .addMethod(METHOD_ALERT)
                              .addMethod(METHOD_ALERT_RESOLVE)
                              .addMethod(METHOD_ALERT_RESOLVE_BY_FINGERPRINT)
                              .addMethod(METHOD_GET_UNRESOLVED_ALERTS_NUM)
                              .addMethod(METHOD_SEND_ALERT_TEST_MESSAGE)
                              .addMethod(METHOD_GET_USAGE)
                              .addMethod(METHOD_REQUEST_SERVER_CERTIFICATE)
                              .addMethod(METHOD_GET_CA_CERTIFICATE)
                              .addMethod(METHOD_IS_UCORE_INIT)
                              .addMethod(METHOD_COLLECT_CLUSTER_INFOS)
                              .addMethod(METHOD_UCORE_HEALTH_CHECK)
                              .addMethod(METHOD_LIST_KV_NEXT_LEVEL_RAW)
                              .addMethod(METHOD_LIST_KV_BY_PATH_RAW)
                              .addMethod(METHOD_REPORT_UGUARD_EXERCISE_RESULT)
                              .addMethod(METHOD_UCORE_LEARDER)
                              .addMethod(METHOD_GET_UCORE_STATS)
                              .addMethod(METHOD_FORCE_LEAVE_UCORE)
                              .addMethod(METHOD_GET_KV_TREE_WITH_LIMIT)
                              .addMethod(METHOD_GET_KVS_TREE)
                              .addMethod(METHOD_LOCK_ON_SESSION)
                              .addMethod(METHOD_RENEW_SESSION)
                              .addMethod(METHOD_UNLOCK_ON_SESSION)
                              .build();
                  }
              }
          }
          return result;
      }
  }
  