/*
 * Copyright 2020 Google LLC
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.google.cloud.datafusion.v1beta1;

import static io.grpc.MethodDescriptor.generateFullMethodName;

/**
 *
 *
 * <pre>
 * Service for creating and managing Data Fusion instances.
 * Data Fusion enables ETL developers to build code-free, data integration
 * pipelines via a point-and-click UI.
 * </pre>
 */
@javax.annotation.Generated(
    value = "by gRPC proto compiler",
    comments = "Source: google/cloud/datafusion/v1beta1/v1beta1.proto")
@io.grpc.stub.annotations.GrpcGenerated
public final class DataFusionGrpc {

  private DataFusionGrpc() {}

  public static final String SERVICE_NAME = "google.cloud.datafusion.v1beta1.DataFusion";

  // Static method descriptors that strictly reflect the proto.
  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest,
          com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse>
      getListAvailableVersionsMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "ListAvailableVersions",
      requestType = com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest.class,
      responseType = com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest,
          com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse>
      getListAvailableVersionsMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest,
            com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse>
        getListAvailableVersionsMethod;
    if ((getListAvailableVersionsMethod = DataFusionGrpc.getListAvailableVersionsMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getListAvailableVersionsMethod = DataFusionGrpc.getListAvailableVersionsMethod)
            == null) {
          DataFusionGrpc.getListAvailableVersionsMethod =
              getListAvailableVersionsMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest,
                          com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "ListAvailableVersions"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DataFusionMethodDescriptorSupplier("ListAvailableVersions"))
                      .build();
        }
      }
    }
    return getListAvailableVersionsMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.ListInstancesRequest,
          com.google.cloud.datafusion.v1beta1.ListInstancesResponse>
      getListInstancesMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "ListInstances",
      requestType = com.google.cloud.datafusion.v1beta1.ListInstancesRequest.class,
      responseType = com.google.cloud.datafusion.v1beta1.ListInstancesResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.ListInstancesRequest,
          com.google.cloud.datafusion.v1beta1.ListInstancesResponse>
      getListInstancesMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.ListInstancesRequest,
            com.google.cloud.datafusion.v1beta1.ListInstancesResponse>
        getListInstancesMethod;
    if ((getListInstancesMethod = DataFusionGrpc.getListInstancesMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getListInstancesMethod = DataFusionGrpc.getListInstancesMethod) == null) {
          DataFusionGrpc.getListInstancesMethod =
              getListInstancesMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.ListInstancesRequest,
                          com.google.cloud.datafusion.v1beta1.ListInstancesResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListInstances"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.ListInstancesRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.ListInstancesResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(new DataFusionMethodDescriptorSupplier("ListInstances"))
                      .build();
        }
      }
    }
    return getListInstancesMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.GetInstanceRequest,
          com.google.cloud.datafusion.v1beta1.Instance>
      getGetInstanceMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "GetInstance",
      requestType = com.google.cloud.datafusion.v1beta1.GetInstanceRequest.class,
      responseType = com.google.cloud.datafusion.v1beta1.Instance.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.GetInstanceRequest,
          com.google.cloud.datafusion.v1beta1.Instance>
      getGetInstanceMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.GetInstanceRequest,
            com.google.cloud.datafusion.v1beta1.Instance>
        getGetInstanceMethod;
    if ((getGetInstanceMethod = DataFusionGrpc.getGetInstanceMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getGetInstanceMethod = DataFusionGrpc.getGetInstanceMethod) == null) {
          DataFusionGrpc.getGetInstanceMethod =
              getGetInstanceMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.GetInstanceRequest,
                          com.google.cloud.datafusion.v1beta1.Instance>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetInstance"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.GetInstanceRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.Instance.getDefaultInstance()))
                      .setSchemaDescriptor(new DataFusionMethodDescriptorSupplier("GetInstance"))
                      .build();
        }
      }
    }
    return getGetInstanceMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.CreateInstanceRequest,
          com.google.longrunning.Operation>
      getCreateInstanceMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "CreateInstance",
      requestType = com.google.cloud.datafusion.v1beta1.CreateInstanceRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.CreateInstanceRequest,
          com.google.longrunning.Operation>
      getCreateInstanceMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.CreateInstanceRequest,
            com.google.longrunning.Operation>
        getCreateInstanceMethod;
    if ((getCreateInstanceMethod = DataFusionGrpc.getCreateInstanceMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getCreateInstanceMethod = DataFusionGrpc.getCreateInstanceMethod) == null) {
          DataFusionGrpc.getCreateInstanceMethod =
              getCreateInstanceMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.CreateInstanceRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateInstance"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.CreateInstanceRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(new DataFusionMethodDescriptorSupplier("CreateInstance"))
                      .build();
        }
      }
    }
    return getCreateInstanceMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest,
          com.google.longrunning.Operation>
      getDeleteInstanceMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "DeleteInstance",
      requestType = com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest,
          com.google.longrunning.Operation>
      getDeleteInstanceMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest,
            com.google.longrunning.Operation>
        getDeleteInstanceMethod;
    if ((getDeleteInstanceMethod = DataFusionGrpc.getDeleteInstanceMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getDeleteInstanceMethod = DataFusionGrpc.getDeleteInstanceMethod) == null) {
          DataFusionGrpc.getDeleteInstanceMethod =
              getDeleteInstanceMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteInstance"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(new DataFusionMethodDescriptorSupplier("DeleteInstance"))
                      .build();
        }
      }
    }
    return getDeleteInstanceMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest,
          com.google.longrunning.Operation>
      getUpdateInstanceMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "UpdateInstance",
      requestType = com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest,
          com.google.longrunning.Operation>
      getUpdateInstanceMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest,
            com.google.longrunning.Operation>
        getUpdateInstanceMethod;
    if ((getUpdateInstanceMethod = DataFusionGrpc.getUpdateInstanceMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getUpdateInstanceMethod = DataFusionGrpc.getUpdateInstanceMethod) == null) {
          DataFusionGrpc.getUpdateInstanceMethod =
              getUpdateInstanceMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateInstance"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(new DataFusionMethodDescriptorSupplier("UpdateInstance"))
                      .build();
        }
      }
    }
    return getUpdateInstanceMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.RestartInstanceRequest,
          com.google.longrunning.Operation>
      getRestartInstanceMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "RestartInstance",
      requestType = com.google.cloud.datafusion.v1beta1.RestartInstanceRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.RestartInstanceRequest,
          com.google.longrunning.Operation>
      getRestartInstanceMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.RestartInstanceRequest,
            com.google.longrunning.Operation>
        getRestartInstanceMethod;
    if ((getRestartInstanceMethod = DataFusionGrpc.getRestartInstanceMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getRestartInstanceMethod = DataFusionGrpc.getRestartInstanceMethod) == null) {
          DataFusionGrpc.getRestartInstanceMethod =
              getRestartInstanceMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.RestartInstanceRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RestartInstance"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.RestartInstanceRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DataFusionMethodDescriptorSupplier("RestartInstance"))
                      .build();
        }
      }
    }
    return getRestartInstanceMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest,
          com.google.longrunning.Operation>
      getUpgradeInstanceMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "UpgradeInstance",
      requestType = com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest,
          com.google.longrunning.Operation>
      getUpgradeInstanceMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest,
            com.google.longrunning.Operation>
        getUpgradeInstanceMethod;
    if ((getUpgradeInstanceMethod = DataFusionGrpc.getUpgradeInstanceMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getUpgradeInstanceMethod = DataFusionGrpc.getUpgradeInstanceMethod) == null) {
          DataFusionGrpc.getUpgradeInstanceMethod =
              getUpgradeInstanceMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpgradeInstance"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DataFusionMethodDescriptorSupplier("UpgradeInstance"))
                      .build();
        }
      }
    }
    return getUpgradeInstanceMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest,
          com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse>
      getRemoveIamPolicyMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "RemoveIamPolicy",
      requestType = com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest.class,
      responseType = com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest,
          com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse>
      getRemoveIamPolicyMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest,
            com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse>
        getRemoveIamPolicyMethod;
    if ((getRemoveIamPolicyMethod = DataFusionGrpc.getRemoveIamPolicyMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getRemoveIamPolicyMethod = DataFusionGrpc.getRemoveIamPolicyMethod) == null) {
          DataFusionGrpc.getRemoveIamPolicyMethod =
              getRemoveIamPolicyMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest,
                          com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RemoveIamPolicy"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DataFusionMethodDescriptorSupplier("RemoveIamPolicy"))
                      .build();
        }
      }
    }
    return getRemoveIamPolicyMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.ListNamespacesRequest,
          com.google.cloud.datafusion.v1beta1.ListNamespacesResponse>
      getListNamespacesMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "ListNamespaces",
      requestType = com.google.cloud.datafusion.v1beta1.ListNamespacesRequest.class,
      responseType = com.google.cloud.datafusion.v1beta1.ListNamespacesResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.ListNamespacesRequest,
          com.google.cloud.datafusion.v1beta1.ListNamespacesResponse>
      getListNamespacesMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.ListNamespacesRequest,
            com.google.cloud.datafusion.v1beta1.ListNamespacesResponse>
        getListNamespacesMethod;
    if ((getListNamespacesMethod = DataFusionGrpc.getListNamespacesMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getListNamespacesMethod = DataFusionGrpc.getListNamespacesMethod) == null) {
          DataFusionGrpc.getListNamespacesMethod =
              getListNamespacesMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.ListNamespacesRequest,
                          com.google.cloud.datafusion.v1beta1.ListNamespacesResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListNamespaces"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.ListNamespacesRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.ListNamespacesResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(new DataFusionMethodDescriptorSupplier("ListNamespaces"))
                      .build();
        }
      }
    }
    return getListNamespacesMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest,
          com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse>
      getAddDnsPeeringMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "AddDnsPeering",
      requestType = com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest.class,
      responseType = com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest,
          com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse>
      getAddDnsPeeringMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest,
            com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse>
        getAddDnsPeeringMethod;
    if ((getAddDnsPeeringMethod = DataFusionGrpc.getAddDnsPeeringMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getAddDnsPeeringMethod = DataFusionGrpc.getAddDnsPeeringMethod) == null) {
          DataFusionGrpc.getAddDnsPeeringMethod =
              getAddDnsPeeringMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest,
                          com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "AddDnsPeering"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(new DataFusionMethodDescriptorSupplier("AddDnsPeering"))
                      .build();
        }
      }
    }
    return getAddDnsPeeringMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest,
          com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse>
      getRemoveDnsPeeringMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "RemoveDnsPeering",
      requestType = com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest.class,
      responseType = com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest,
          com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse>
      getRemoveDnsPeeringMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest,
            com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse>
        getRemoveDnsPeeringMethod;
    if ((getRemoveDnsPeeringMethod = DataFusionGrpc.getRemoveDnsPeeringMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getRemoveDnsPeeringMethod = DataFusionGrpc.getRemoveDnsPeeringMethod) == null) {
          DataFusionGrpc.getRemoveDnsPeeringMethod =
              getRemoveDnsPeeringMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest,
                          com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RemoveDnsPeering"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DataFusionMethodDescriptorSupplier("RemoveDnsPeering"))
                      .build();
        }
      }
    }
    return getRemoveDnsPeeringMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest,
          com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse>
      getListDnsPeeringsMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "ListDnsPeerings",
      requestType = com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest.class,
      responseType = com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest,
          com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse>
      getListDnsPeeringsMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest,
            com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse>
        getListDnsPeeringsMethod;
    if ((getListDnsPeeringsMethod = DataFusionGrpc.getListDnsPeeringsMethod) == null) {
      synchronized (DataFusionGrpc.class) {
        if ((getListDnsPeeringsMethod = DataFusionGrpc.getListDnsPeeringsMethod) == null) {
          DataFusionGrpc.getListDnsPeeringsMethod =
              getListDnsPeeringsMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest,
                          com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListDnsPeerings"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DataFusionMethodDescriptorSupplier("ListDnsPeerings"))
                      .build();
        }
      }
    }
    return getListDnsPeeringsMethod;
  }

  /** Creates a new async stub that supports all call types for the service */
  public static DataFusionStub newStub(io.grpc.Channel channel) {
    io.grpc.stub.AbstractStub.StubFactory<DataFusionStub> factory =
        new io.grpc.stub.AbstractStub.StubFactory<DataFusionStub>() {
          @java.lang.Override
          public DataFusionStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
            return new DataFusionStub(channel, callOptions);
          }
        };
    return DataFusionStub.newStub(factory, channel);
  }

  /**
   * Creates a new blocking-style stub that supports unary and streaming output calls on the service
   */
  public static DataFusionBlockingStub newBlockingStub(io.grpc.Channel channel) {
    io.grpc.stub.AbstractStub.StubFactory<DataFusionBlockingStub> factory =
        new io.grpc.stub.AbstractStub.StubFactory<DataFusionBlockingStub>() {
          @java.lang.Override
          public DataFusionBlockingStub newStub(
              io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
            return new DataFusionBlockingStub(channel, callOptions);
          }
        };
    return DataFusionBlockingStub.newStub(factory, channel);
  }

  /** Creates a new ListenableFuture-style stub that supports unary calls on the service */
  public static DataFusionFutureStub newFutureStub(io.grpc.Channel channel) {
    io.grpc.stub.AbstractStub.StubFactory<DataFusionFutureStub> factory =
        new io.grpc.stub.AbstractStub.StubFactory<DataFusionFutureStub>() {
          @java.lang.Override
          public DataFusionFutureStub newStub(
              io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
            return new DataFusionFutureStub(channel, callOptions);
          }
        };
    return DataFusionFutureStub.newStub(factory, channel);
  }

  /**
   *
   *
   * <pre>
   * Service for creating and managing Data Fusion instances.
   * Data Fusion enables ETL developers to build code-free, data integration
   * pipelines via a point-and-click UI.
   * </pre>
   */
  public interface AsyncService {

    /**
     *
     *
     * <pre>
     * Lists possible versions for Data Fusion instances in the specified project
     * and location.
     * </pre>
     */
    default void listAvailableVersions(
        com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest request,
        io.grpc.stub.StreamObserver<
                com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getListAvailableVersionsMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Lists Data Fusion instances in the specified project and location.
     * </pre>
     */
    default void listInstances(
        com.google.cloud.datafusion.v1beta1.ListInstancesRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.ListInstancesResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getListInstancesMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Gets details of a single Data Fusion instance.
     * </pre>
     */
    default void getInstance(
        com.google.cloud.datafusion.v1beta1.GetInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.Instance>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getGetInstanceMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Creates a new Data Fusion instance in the specified project and location.
     * </pre>
     */
    default void createInstance(
        com.google.cloud.datafusion.v1beta1.CreateInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getCreateInstanceMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Deletes a single Data Fusion instance.
     * </pre>
     */
    default void deleteInstance(
        com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getDeleteInstanceMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Updates a single Data Fusion instance.
     * </pre>
     */
    default void updateInstance(
        com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getUpdateInstanceMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Restart a single Data Fusion instance.
     * At the end of an operation instance is fully restarted.
     * </pre>
     */
    default void restartInstance(
        com.google.cloud.datafusion.v1beta1.RestartInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getRestartInstanceMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Upgrade a single Data Fusion instance.
     * At the end of an operation instance is fully upgraded.
     * </pre>
     */
    default void upgradeInstance(
        com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getUpgradeInstanceMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Remove IAM policy that is currently set on the given resource.
     * </pre>
     */
    default void removeIamPolicy(
        com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getRemoveIamPolicyMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * List namespaces in a given instance
     * </pre>
     */
    default void listNamespaces(
        com.google.cloud.datafusion.v1beta1.ListNamespacesRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.ListNamespacesResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getListNamespacesMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Add DNS peering on the given resource.
     * </pre>
     */
    default void addDnsPeering(
        com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getAddDnsPeeringMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Remove DNS peering on the given resource.
     * </pre>
     */
    default void removeDnsPeering(
        com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getRemoveDnsPeeringMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * List DNS peering for a given resource.
     * </pre>
     */
    default void listDnsPeerings(
        com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getListDnsPeeringsMethod(), responseObserver);
    }
  }

  /**
   * Base class for the server implementation of the service DataFusion.
   *
   * <pre>
   * Service for creating and managing Data Fusion instances.
   * Data Fusion enables ETL developers to build code-free, data integration
   * pipelines via a point-and-click UI.
   * </pre>
   */
  public abstract static class DataFusionImplBase implements io.grpc.BindableService, AsyncService {

    @java.lang.Override
    public final io.grpc.ServerServiceDefinition bindService() {
      return DataFusionGrpc.bindService(this);
    }
  }

  /**
   * A stub to allow clients to do asynchronous rpc calls to service DataFusion.
   *
   * <pre>
   * Service for creating and managing Data Fusion instances.
   * Data Fusion enables ETL developers to build code-free, data integration
   * pipelines via a point-and-click UI.
   * </pre>
   */
  public static final class DataFusionStub extends io.grpc.stub.AbstractAsyncStub<DataFusionStub> {
    private DataFusionStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      super(channel, callOptions);
    }

    @java.lang.Override
    protected DataFusionStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      return new DataFusionStub(channel, callOptions);
    }

    /**
     *
     *
     * <pre>
     * Lists possible versions for Data Fusion instances in the specified project
     * and location.
     * </pre>
     */
    public void listAvailableVersions(
        com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest request,
        io.grpc.stub.StreamObserver<
                com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getListAvailableVersionsMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Lists Data Fusion instances in the specified project and location.
     * </pre>
     */
    public void listInstances(
        com.google.cloud.datafusion.v1beta1.ListInstancesRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.ListInstancesResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getListInstancesMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Gets details of a single Data Fusion instance.
     * </pre>
     */
    public void getInstance(
        com.google.cloud.datafusion.v1beta1.GetInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.Instance>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getGetInstanceMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Creates a new Data Fusion instance in the specified project and location.
     * </pre>
     */
    public void createInstance(
        com.google.cloud.datafusion.v1beta1.CreateInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getCreateInstanceMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Deletes a single Data Fusion instance.
     * </pre>
     */
    public void deleteInstance(
        com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getDeleteInstanceMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Updates a single Data Fusion instance.
     * </pre>
     */
    public void updateInstance(
        com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getUpdateInstanceMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Restart a single Data Fusion instance.
     * At the end of an operation instance is fully restarted.
     * </pre>
     */
    public void restartInstance(
        com.google.cloud.datafusion.v1beta1.RestartInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getRestartInstanceMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Upgrade a single Data Fusion instance.
     * At the end of an operation instance is fully upgraded.
     * </pre>
     */
    public void upgradeInstance(
        com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getUpgradeInstanceMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Remove IAM policy that is currently set on the given resource.
     * </pre>
     */
    public void removeIamPolicy(
        com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getRemoveIamPolicyMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * List namespaces in a given instance
     * </pre>
     */
    public void listNamespaces(
        com.google.cloud.datafusion.v1beta1.ListNamespacesRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.ListNamespacesResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getListNamespacesMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Add DNS peering on the given resource.
     * </pre>
     */
    public void addDnsPeering(
        com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getAddDnsPeeringMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Remove DNS peering on the given resource.
     * </pre>
     */
    public void removeDnsPeering(
        com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getRemoveDnsPeeringMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * List DNS peering for a given resource.
     * </pre>
     */
    public void listDnsPeerings(
        com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getListDnsPeeringsMethod(), getCallOptions()),
          request,
          responseObserver);
    }
  }

  /**
   * A stub to allow clients to do synchronous rpc calls to service DataFusion.
   *
   * <pre>
   * Service for creating and managing Data Fusion instances.
   * Data Fusion enables ETL developers to build code-free, data integration
   * pipelines via a point-and-click UI.
   * </pre>
   */
  public static final class DataFusionBlockingStub
      extends io.grpc.stub.AbstractBlockingStub<DataFusionBlockingStub> {
    private DataFusionBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      super(channel, callOptions);
    }

    @java.lang.Override
    protected DataFusionBlockingStub build(
        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      return new DataFusionBlockingStub(channel, callOptions);
    }

    /**
     *
     *
     * <pre>
     * Lists possible versions for Data Fusion instances in the specified project
     * and location.
     * </pre>
     */
    public com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse listAvailableVersions(
        com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getListAvailableVersionsMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Lists Data Fusion instances in the specified project and location.
     * </pre>
     */
    public com.google.cloud.datafusion.v1beta1.ListInstancesResponse listInstances(
        com.google.cloud.datafusion.v1beta1.ListInstancesRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getListInstancesMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Gets details of a single Data Fusion instance.
     * </pre>
     */
    public com.google.cloud.datafusion.v1beta1.Instance getInstance(
        com.google.cloud.datafusion.v1beta1.GetInstanceRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getGetInstanceMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Creates a new Data Fusion instance in the specified project and location.
     * </pre>
     */
    public com.google.longrunning.Operation createInstance(
        com.google.cloud.datafusion.v1beta1.CreateInstanceRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getCreateInstanceMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Deletes a single Data Fusion instance.
     * </pre>
     */
    public com.google.longrunning.Operation deleteInstance(
        com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getDeleteInstanceMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Updates a single Data Fusion instance.
     * </pre>
     */
    public com.google.longrunning.Operation updateInstance(
        com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getUpdateInstanceMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Restart a single Data Fusion instance.
     * At the end of an operation instance is fully restarted.
     * </pre>
     */
    public com.google.longrunning.Operation restartInstance(
        com.google.cloud.datafusion.v1beta1.RestartInstanceRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getRestartInstanceMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Upgrade a single Data Fusion instance.
     * At the end of an operation instance is fully upgraded.
     * </pre>
     */
    public com.google.longrunning.Operation upgradeInstance(
        com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getUpgradeInstanceMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Remove IAM policy that is currently set on the given resource.
     * </pre>
     */
    public com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse removeIamPolicy(
        com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getRemoveIamPolicyMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * List namespaces in a given instance
     * </pre>
     */
    public com.google.cloud.datafusion.v1beta1.ListNamespacesResponse listNamespaces(
        com.google.cloud.datafusion.v1beta1.ListNamespacesRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getListNamespacesMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Add DNS peering on the given resource.
     * </pre>
     */
    public com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse addDnsPeering(
        com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getAddDnsPeeringMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Remove DNS peering on the given resource.
     * </pre>
     */
    public com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse removeDnsPeering(
        com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getRemoveDnsPeeringMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * List DNS peering for a given resource.
     * </pre>
     */
    public com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse listDnsPeerings(
        com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getListDnsPeeringsMethod(), getCallOptions(), request);
    }
  }

  /**
   * A stub to allow clients to do ListenableFuture-style rpc calls to service DataFusion.
   *
   * <pre>
   * Service for creating and managing Data Fusion instances.
   * Data Fusion enables ETL developers to build code-free, data integration
   * pipelines via a point-and-click UI.
   * </pre>
   */
  public static final class DataFusionFutureStub
      extends io.grpc.stub.AbstractFutureStub<DataFusionFutureStub> {
    private DataFusionFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      super(channel, callOptions);
    }

    @java.lang.Override
    protected DataFusionFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      return new DataFusionFutureStub(channel, callOptions);
    }

    /**
     *
     *
     * <pre>
     * Lists possible versions for Data Fusion instances in the specified project
     * and location.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse>
        listAvailableVersions(
            com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getListAvailableVersionsMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Lists Data Fusion instances in the specified project and location.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datafusion.v1beta1.ListInstancesResponse>
        listInstances(com.google.cloud.datafusion.v1beta1.ListInstancesRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getListInstancesMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Gets details of a single Data Fusion instance.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datafusion.v1beta1.Instance>
        getInstance(com.google.cloud.datafusion.v1beta1.GetInstanceRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getGetInstanceMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Creates a new Data Fusion instance in the specified project and location.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        createInstance(com.google.cloud.datafusion.v1beta1.CreateInstanceRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getCreateInstanceMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Deletes a single Data Fusion instance.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        deleteInstance(com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getDeleteInstanceMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Updates a single Data Fusion instance.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        updateInstance(com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getUpdateInstanceMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Restart a single Data Fusion instance.
     * At the end of an operation instance is fully restarted.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        restartInstance(com.google.cloud.datafusion.v1beta1.RestartInstanceRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getRestartInstanceMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Upgrade a single Data Fusion instance.
     * At the end of an operation instance is fully upgraded.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        upgradeInstance(com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getUpgradeInstanceMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Remove IAM policy that is currently set on the given resource.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse>
        removeIamPolicy(com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getRemoveIamPolicyMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * List namespaces in a given instance
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datafusion.v1beta1.ListNamespacesResponse>
        listNamespaces(com.google.cloud.datafusion.v1beta1.ListNamespacesRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getListNamespacesMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Add DNS peering on the given resource.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse>
        addDnsPeering(com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getAddDnsPeeringMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Remove DNS peering on the given resource.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse>
        removeDnsPeering(com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getRemoveDnsPeeringMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * List DNS peering for a given resource.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse>
        listDnsPeerings(com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getListDnsPeeringsMethod(), getCallOptions()), request);
    }
  }

  private static final int METHODID_LIST_AVAILABLE_VERSIONS = 0;
  private static final int METHODID_LIST_INSTANCES = 1;
  private static final int METHODID_GET_INSTANCE = 2;
  private static final int METHODID_CREATE_INSTANCE = 3;
  private static final int METHODID_DELETE_INSTANCE = 4;
  private static final int METHODID_UPDATE_INSTANCE = 5;
  private static final int METHODID_RESTART_INSTANCE = 6;
  private static final int METHODID_UPGRADE_INSTANCE = 7;
  private static final int METHODID_REMOVE_IAM_POLICY = 8;
  private static final int METHODID_LIST_NAMESPACES = 9;
  private static final int METHODID_ADD_DNS_PEERING = 10;
  private static final int METHODID_REMOVE_DNS_PEERING = 11;
  private static final int METHODID_LIST_DNS_PEERINGS = 12;

  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 AsyncService serviceImpl;
    private final int methodId;

    MethodHandlers(AsyncService 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_LIST_AVAILABLE_VERSIONS:
          serviceImpl.listAvailableVersions(
              (com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse>)
                  responseObserver);
          break;
        case METHODID_LIST_INSTANCES:
          serviceImpl.listInstances(
              (com.google.cloud.datafusion.v1beta1.ListInstancesRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datafusion.v1beta1.ListInstancesResponse>)
                  responseObserver);
          break;
        case METHODID_GET_INSTANCE:
          serviceImpl.getInstance(
              (com.google.cloud.datafusion.v1beta1.GetInstanceRequest) request,
              (io.grpc.stub.StreamObserver<com.google.cloud.datafusion.v1beta1.Instance>)
                  responseObserver);
          break;
        case METHODID_CREATE_INSTANCE:
          serviceImpl.createInstance(
              (com.google.cloud.datafusion.v1beta1.CreateInstanceRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_DELETE_INSTANCE:
          serviceImpl.deleteInstance(
              (com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_UPDATE_INSTANCE:
          serviceImpl.updateInstance(
              (com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_RESTART_INSTANCE:
          serviceImpl.restartInstance(
              (com.google.cloud.datafusion.v1beta1.RestartInstanceRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_UPGRADE_INSTANCE:
          serviceImpl.upgradeInstance(
              (com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_REMOVE_IAM_POLICY:
          serviceImpl.removeIamPolicy(
              (com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse>)
                  responseObserver);
          break;
        case METHODID_LIST_NAMESPACES:
          serviceImpl.listNamespaces(
              (com.google.cloud.datafusion.v1beta1.ListNamespacesRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datafusion.v1beta1.ListNamespacesResponse>)
                  responseObserver);
          break;
        case METHODID_ADD_DNS_PEERING:
          serviceImpl.addDnsPeering(
              (com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse>)
                  responseObserver);
          break;
        case METHODID_REMOVE_DNS_PEERING:
          serviceImpl.removeDnsPeering(
              (com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse>)
                  responseObserver);
          break;
        case METHODID_LIST_DNS_PEERINGS:
          serviceImpl.listDnsPeerings(
              (com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse>)
                  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();
      }
    }
  }

  public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
    return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
        .addMethod(
            getListAvailableVersionsMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.ListAvailableVersionsRequest,
                    com.google.cloud.datafusion.v1beta1.ListAvailableVersionsResponse>(
                    service, METHODID_LIST_AVAILABLE_VERSIONS)))
        .addMethod(
            getListInstancesMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.ListInstancesRequest,
                    com.google.cloud.datafusion.v1beta1.ListInstancesResponse>(
                    service, METHODID_LIST_INSTANCES)))
        .addMethod(
            getGetInstanceMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.GetInstanceRequest,
                    com.google.cloud.datafusion.v1beta1.Instance>(service, METHODID_GET_INSTANCE)))
        .addMethod(
            getCreateInstanceMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.CreateInstanceRequest,
                    com.google.longrunning.Operation>(service, METHODID_CREATE_INSTANCE)))
        .addMethod(
            getDeleteInstanceMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest,
                    com.google.longrunning.Operation>(service, METHODID_DELETE_INSTANCE)))
        .addMethod(
            getUpdateInstanceMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.UpdateInstanceRequest,
                    com.google.longrunning.Operation>(service, METHODID_UPDATE_INSTANCE)))
        .addMethod(
            getRestartInstanceMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.RestartInstanceRequest,
                    com.google.longrunning.Operation>(service, METHODID_RESTART_INSTANCE)))
        .addMethod(
            getUpgradeInstanceMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.UpgradeInstanceRequest,
                    com.google.longrunning.Operation>(service, METHODID_UPGRADE_INSTANCE)))
        .addMethod(
            getRemoveIamPolicyMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.RemoveIamPolicyRequest,
                    com.google.cloud.datafusion.v1beta1.RemoveIamPolicyResponse>(
                    service, METHODID_REMOVE_IAM_POLICY)))
        .addMethod(
            getListNamespacesMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.ListNamespacesRequest,
                    com.google.cloud.datafusion.v1beta1.ListNamespacesResponse>(
                    service, METHODID_LIST_NAMESPACES)))
        .addMethod(
            getAddDnsPeeringMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.AddDnsPeeringRequest,
                    com.google.cloud.datafusion.v1beta1.AddDnsPeeringResponse>(
                    service, METHODID_ADD_DNS_PEERING)))
        .addMethod(
            getRemoveDnsPeeringMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringRequest,
                    com.google.cloud.datafusion.v1beta1.RemoveDnsPeeringResponse>(
                    service, METHODID_REMOVE_DNS_PEERING)))
        .addMethod(
            getListDnsPeeringsMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datafusion.v1beta1.ListDnsPeeringsRequest,
                    com.google.cloud.datafusion.v1beta1.ListDnsPeeringsResponse>(
                    service, METHODID_LIST_DNS_PEERINGS)))
        .build();
  }

  private abstract static class DataFusionBaseDescriptorSupplier
      implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
          io.grpc.protobuf.ProtoServiceDescriptorSupplier {
    DataFusionBaseDescriptorSupplier() {}

    @java.lang.Override
    public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
      return com.google.cloud.datafusion.v1beta1.V1Beta1.getDescriptor();
    }

    @java.lang.Override
    public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
      return getFileDescriptor().findServiceByName("DataFusion");
    }
  }

  private static final class DataFusionFileDescriptorSupplier
      extends DataFusionBaseDescriptorSupplier {
    DataFusionFileDescriptorSupplier() {}
  }

  private static final class DataFusionMethodDescriptorSupplier
      extends DataFusionBaseDescriptorSupplier
      implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
    private final String methodName;

    DataFusionMethodDescriptorSupplier(String methodName) {
      this.methodName = methodName;
    }

    @java.lang.Override
    public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
      return getServiceDescriptor().findMethodByName(methodName);
    }
  }

  private static volatile io.grpc.ServiceDescriptor serviceDescriptor;

  public static io.grpc.ServiceDescriptor getServiceDescriptor() {
    io.grpc.ServiceDescriptor result = serviceDescriptor;
    if (result == null) {
      synchronized (DataFusionGrpc.class) {
        result = serviceDescriptor;
        if (result == null) {
          serviceDescriptor =
              result =
                  io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
                      .setSchemaDescriptor(new DataFusionFileDescriptorSupplier())
                      .addMethod(getListAvailableVersionsMethod())
                      .addMethod(getListInstancesMethod())
                      .addMethod(getGetInstanceMethod())
                      .addMethod(getCreateInstanceMethod())
                      .addMethod(getDeleteInstanceMethod())
                      .addMethod(getUpdateInstanceMethod())
                      .addMethod(getRestartInstanceMethod())
                      .addMethod(getUpgradeInstanceMethod())
                      .addMethod(getRemoveIamPolicyMethod())
                      .addMethod(getListNamespacesMethod())
                      .addMethod(getAddDnsPeeringMethod())
                      .addMethod(getRemoveDnsPeeringMethod())
                      .addMethod(getListDnsPeeringsMethod())
                      .build();
        }
      }
    }
    return result;
  }
}