/*
 * Copyright 2023 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.datastream.v1alpha1;

import static io.grpc.MethodDescriptor.generateFullMethodName;

/**
 *
 *
 * <pre>
 * Datastream service
 * </pre>
 */
@javax.annotation.Generated(
    value = "by gRPC proto compiler",
    comments = "Source: google/cloud/datastream/v1alpha1/datastream.proto")
@io.grpc.stub.annotations.GrpcGenerated
public final class DatastreamGrpc {

  private DatastreamGrpc() {}

  public static final String SERVICE_NAME = "google.cloud.datastream.v1alpha1.Datastream";

  // Static method descriptors that strictly reflect the proto.
  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest,
          com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse>
      getListConnectionProfilesMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "ListConnectionProfiles",
      requestType = com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest.class,
      responseType = com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest,
          com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse>
      getListConnectionProfilesMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest,
            com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse>
        getListConnectionProfilesMethod;
    if ((getListConnectionProfilesMethod = DatastreamGrpc.getListConnectionProfilesMethod)
        == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getListConnectionProfilesMethod = DatastreamGrpc.getListConnectionProfilesMethod)
            == null) {
          DatastreamGrpc.getListConnectionProfilesMethod =
              getListConnectionProfilesMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest,
                          com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "ListConnectionProfiles"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DatastreamMethodDescriptorSupplier("ListConnectionProfiles"))
                      .build();
        }
      }
    }
    return getListConnectionProfilesMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest,
          com.google.cloud.datastream.v1alpha1.ConnectionProfile>
      getGetConnectionProfileMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "GetConnectionProfile",
      requestType = com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest.class,
      responseType = com.google.cloud.datastream.v1alpha1.ConnectionProfile.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest,
          com.google.cloud.datastream.v1alpha1.ConnectionProfile>
      getGetConnectionProfileMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest,
            com.google.cloud.datastream.v1alpha1.ConnectionProfile>
        getGetConnectionProfileMethod;
    if ((getGetConnectionProfileMethod = DatastreamGrpc.getGetConnectionProfileMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getGetConnectionProfileMethod = DatastreamGrpc.getGetConnectionProfileMethod)
            == null) {
          DatastreamGrpc.getGetConnectionProfileMethod =
              getGetConnectionProfileMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest,
                          com.google.cloud.datastream.v1alpha1.ConnectionProfile>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "GetConnectionProfile"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.ConnectionProfile
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DatastreamMethodDescriptorSupplier("GetConnectionProfile"))
                      .build();
        }
      }
    }
    return getGetConnectionProfileMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest,
          com.google.longrunning.Operation>
      getCreateConnectionProfileMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "CreateConnectionProfile",
      requestType = com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest,
          com.google.longrunning.Operation>
      getCreateConnectionProfileMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest,
            com.google.longrunning.Operation>
        getCreateConnectionProfileMethod;
    if ((getCreateConnectionProfileMethod = DatastreamGrpc.getCreateConnectionProfileMethod)
        == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getCreateConnectionProfileMethod = DatastreamGrpc.getCreateConnectionProfileMethod)
            == null) {
          DatastreamGrpc.getCreateConnectionProfileMethod =
              getCreateConnectionProfileMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "CreateConnectionProfile"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DatastreamMethodDescriptorSupplier("CreateConnectionProfile"))
                      .build();
        }
      }
    }
    return getCreateConnectionProfileMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest,
          com.google.longrunning.Operation>
      getUpdateConnectionProfileMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "UpdateConnectionProfile",
      requestType = com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest,
          com.google.longrunning.Operation>
      getUpdateConnectionProfileMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest,
            com.google.longrunning.Operation>
        getUpdateConnectionProfileMethod;
    if ((getUpdateConnectionProfileMethod = DatastreamGrpc.getUpdateConnectionProfileMethod)
        == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getUpdateConnectionProfileMethod = DatastreamGrpc.getUpdateConnectionProfileMethod)
            == null) {
          DatastreamGrpc.getUpdateConnectionProfileMethod =
              getUpdateConnectionProfileMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "UpdateConnectionProfile"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DatastreamMethodDescriptorSupplier("UpdateConnectionProfile"))
                      .build();
        }
      }
    }
    return getUpdateConnectionProfileMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest,
          com.google.longrunning.Operation>
      getDeleteConnectionProfileMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "DeleteConnectionProfile",
      requestType = com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest,
          com.google.longrunning.Operation>
      getDeleteConnectionProfileMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest,
            com.google.longrunning.Operation>
        getDeleteConnectionProfileMethod;
    if ((getDeleteConnectionProfileMethod = DatastreamGrpc.getDeleteConnectionProfileMethod)
        == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getDeleteConnectionProfileMethod = DatastreamGrpc.getDeleteConnectionProfileMethod)
            == null) {
          DatastreamGrpc.getDeleteConnectionProfileMethod =
              getDeleteConnectionProfileMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "DeleteConnectionProfile"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DatastreamMethodDescriptorSupplier("DeleteConnectionProfile"))
                      .build();
        }
      }
    }
    return getDeleteConnectionProfileMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest,
          com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse>
      getDiscoverConnectionProfileMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "DiscoverConnectionProfile",
      requestType = com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest.class,
      responseType = com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest,
          com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse>
      getDiscoverConnectionProfileMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest,
            com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse>
        getDiscoverConnectionProfileMethod;
    if ((getDiscoverConnectionProfileMethod = DatastreamGrpc.getDiscoverConnectionProfileMethod)
        == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getDiscoverConnectionProfileMethod = DatastreamGrpc.getDiscoverConnectionProfileMethod)
            == null) {
          DatastreamGrpc.getDiscoverConnectionProfileMethod =
              getDiscoverConnectionProfileMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest,
                          com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "DiscoverConnectionProfile"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DatastreamMethodDescriptorSupplier("DiscoverConnectionProfile"))
                      .build();
        }
      }
    }
    return getDiscoverConnectionProfileMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.ListStreamsRequest,
          com.google.cloud.datastream.v1alpha1.ListStreamsResponse>
      getListStreamsMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "ListStreams",
      requestType = com.google.cloud.datastream.v1alpha1.ListStreamsRequest.class,
      responseType = com.google.cloud.datastream.v1alpha1.ListStreamsResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.ListStreamsRequest,
          com.google.cloud.datastream.v1alpha1.ListStreamsResponse>
      getListStreamsMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.ListStreamsRequest,
            com.google.cloud.datastream.v1alpha1.ListStreamsResponse>
        getListStreamsMethod;
    if ((getListStreamsMethod = DatastreamGrpc.getListStreamsMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getListStreamsMethod = DatastreamGrpc.getListStreamsMethod) == null) {
          DatastreamGrpc.getListStreamsMethod =
              getListStreamsMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.ListStreamsRequest,
                          com.google.cloud.datastream.v1alpha1.ListStreamsResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListStreams"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.ListStreamsRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.ListStreamsResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("ListStreams"))
                      .build();
        }
      }
    }
    return getListStreamsMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.GetStreamRequest,
          com.google.cloud.datastream.v1alpha1.Stream>
      getGetStreamMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "GetStream",
      requestType = com.google.cloud.datastream.v1alpha1.GetStreamRequest.class,
      responseType = com.google.cloud.datastream.v1alpha1.Stream.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.GetStreamRequest,
          com.google.cloud.datastream.v1alpha1.Stream>
      getGetStreamMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.GetStreamRequest,
            com.google.cloud.datastream.v1alpha1.Stream>
        getGetStreamMethod;
    if ((getGetStreamMethod = DatastreamGrpc.getGetStreamMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getGetStreamMethod = DatastreamGrpc.getGetStreamMethod) == null) {
          DatastreamGrpc.getGetStreamMethod =
              getGetStreamMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.GetStreamRequest,
                          com.google.cloud.datastream.v1alpha1.Stream>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetStream"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.GetStreamRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.Stream.getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("GetStream"))
                      .build();
        }
      }
    }
    return getGetStreamMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.CreateStreamRequest,
          com.google.longrunning.Operation>
      getCreateStreamMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "CreateStream",
      requestType = com.google.cloud.datastream.v1alpha1.CreateStreamRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.CreateStreamRequest,
          com.google.longrunning.Operation>
      getCreateStreamMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.CreateStreamRequest,
            com.google.longrunning.Operation>
        getCreateStreamMethod;
    if ((getCreateStreamMethod = DatastreamGrpc.getCreateStreamMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getCreateStreamMethod = DatastreamGrpc.getCreateStreamMethod) == null) {
          DatastreamGrpc.getCreateStreamMethod =
              getCreateStreamMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.CreateStreamRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateStream"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.CreateStreamRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("CreateStream"))
                      .build();
        }
      }
    }
    return getCreateStreamMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.UpdateStreamRequest,
          com.google.longrunning.Operation>
      getUpdateStreamMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "UpdateStream",
      requestType = com.google.cloud.datastream.v1alpha1.UpdateStreamRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.UpdateStreamRequest,
          com.google.longrunning.Operation>
      getUpdateStreamMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.UpdateStreamRequest,
            com.google.longrunning.Operation>
        getUpdateStreamMethod;
    if ((getUpdateStreamMethod = DatastreamGrpc.getUpdateStreamMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getUpdateStreamMethod = DatastreamGrpc.getUpdateStreamMethod) == null) {
          DatastreamGrpc.getUpdateStreamMethod =
              getUpdateStreamMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.UpdateStreamRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateStream"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.UpdateStreamRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("UpdateStream"))
                      .build();
        }
      }
    }
    return getUpdateStreamMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.DeleteStreamRequest,
          com.google.longrunning.Operation>
      getDeleteStreamMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "DeleteStream",
      requestType = com.google.cloud.datastream.v1alpha1.DeleteStreamRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.DeleteStreamRequest,
          com.google.longrunning.Operation>
      getDeleteStreamMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.DeleteStreamRequest,
            com.google.longrunning.Operation>
        getDeleteStreamMethod;
    if ((getDeleteStreamMethod = DatastreamGrpc.getDeleteStreamMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getDeleteStreamMethod = DatastreamGrpc.getDeleteStreamMethod) == null) {
          DatastreamGrpc.getDeleteStreamMethod =
              getDeleteStreamMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.DeleteStreamRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteStream"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.DeleteStreamRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("DeleteStream"))
                      .build();
        }
      }
    }
    return getDeleteStreamMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.FetchErrorsRequest, com.google.longrunning.Operation>
      getFetchErrorsMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "FetchErrors",
      requestType = com.google.cloud.datastream.v1alpha1.FetchErrorsRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.FetchErrorsRequest, com.google.longrunning.Operation>
      getFetchErrorsMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.FetchErrorsRequest,
            com.google.longrunning.Operation>
        getFetchErrorsMethod;
    if ((getFetchErrorsMethod = DatastreamGrpc.getFetchErrorsMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getFetchErrorsMethod = DatastreamGrpc.getFetchErrorsMethod) == null) {
          DatastreamGrpc.getFetchErrorsMethod =
              getFetchErrorsMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.FetchErrorsRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FetchErrors"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.FetchErrorsRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("FetchErrors"))
                      .build();
        }
      }
    }
    return getFetchErrorsMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest,
          com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse>
      getFetchStaticIpsMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "FetchStaticIps",
      requestType = com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest.class,
      responseType = com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest,
          com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse>
      getFetchStaticIpsMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest,
            com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse>
        getFetchStaticIpsMethod;
    if ((getFetchStaticIpsMethod = DatastreamGrpc.getFetchStaticIpsMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getFetchStaticIpsMethod = DatastreamGrpc.getFetchStaticIpsMethod) == null) {
          DatastreamGrpc.getFetchStaticIpsMethod =
              getFetchStaticIpsMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest,
                          com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FetchStaticIps"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("FetchStaticIps"))
                      .build();
        }
      }
    }
    return getFetchStaticIpsMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest,
          com.google.longrunning.Operation>
      getCreatePrivateConnectionMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "CreatePrivateConnection",
      requestType = com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest,
          com.google.longrunning.Operation>
      getCreatePrivateConnectionMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest,
            com.google.longrunning.Operation>
        getCreatePrivateConnectionMethod;
    if ((getCreatePrivateConnectionMethod = DatastreamGrpc.getCreatePrivateConnectionMethod)
        == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getCreatePrivateConnectionMethod = DatastreamGrpc.getCreatePrivateConnectionMethod)
            == null) {
          DatastreamGrpc.getCreatePrivateConnectionMethod =
              getCreatePrivateConnectionMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "CreatePrivateConnection"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DatastreamMethodDescriptorSupplier("CreatePrivateConnection"))
                      .build();
        }
      }
    }
    return getCreatePrivateConnectionMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest,
          com.google.cloud.datastream.v1alpha1.PrivateConnection>
      getGetPrivateConnectionMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "GetPrivateConnection",
      requestType = com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest.class,
      responseType = com.google.cloud.datastream.v1alpha1.PrivateConnection.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest,
          com.google.cloud.datastream.v1alpha1.PrivateConnection>
      getGetPrivateConnectionMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest,
            com.google.cloud.datastream.v1alpha1.PrivateConnection>
        getGetPrivateConnectionMethod;
    if ((getGetPrivateConnectionMethod = DatastreamGrpc.getGetPrivateConnectionMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getGetPrivateConnectionMethod = DatastreamGrpc.getGetPrivateConnectionMethod)
            == null) {
          DatastreamGrpc.getGetPrivateConnectionMethod =
              getGetPrivateConnectionMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest,
                          com.google.cloud.datastream.v1alpha1.PrivateConnection>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "GetPrivateConnection"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.PrivateConnection
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DatastreamMethodDescriptorSupplier("GetPrivateConnection"))
                      .build();
        }
      }
    }
    return getGetPrivateConnectionMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest,
          com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse>
      getListPrivateConnectionsMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "ListPrivateConnections",
      requestType = com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest.class,
      responseType = com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest,
          com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse>
      getListPrivateConnectionsMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest,
            com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse>
        getListPrivateConnectionsMethod;
    if ((getListPrivateConnectionsMethod = DatastreamGrpc.getListPrivateConnectionsMethod)
        == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getListPrivateConnectionsMethod = DatastreamGrpc.getListPrivateConnectionsMethod)
            == null) {
          DatastreamGrpc.getListPrivateConnectionsMethod =
              getListPrivateConnectionsMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest,
                          com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "ListPrivateConnections"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DatastreamMethodDescriptorSupplier("ListPrivateConnections"))
                      .build();
        }
      }
    }
    return getListPrivateConnectionsMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest,
          com.google.longrunning.Operation>
      getDeletePrivateConnectionMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "DeletePrivateConnection",
      requestType = com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest,
          com.google.longrunning.Operation>
      getDeletePrivateConnectionMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest,
            com.google.longrunning.Operation>
        getDeletePrivateConnectionMethod;
    if ((getDeletePrivateConnectionMethod = DatastreamGrpc.getDeletePrivateConnectionMethod)
        == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getDeletePrivateConnectionMethod = DatastreamGrpc.getDeletePrivateConnectionMethod)
            == null) {
          DatastreamGrpc.getDeletePrivateConnectionMethod =
              getDeletePrivateConnectionMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(
                          generateFullMethodName(SERVICE_NAME, "DeletePrivateConnection"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(
                          new DatastreamMethodDescriptorSupplier("DeletePrivateConnection"))
                      .build();
        }
      }
    }
    return getDeletePrivateConnectionMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.CreateRouteRequest, com.google.longrunning.Operation>
      getCreateRouteMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "CreateRoute",
      requestType = com.google.cloud.datastream.v1alpha1.CreateRouteRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.CreateRouteRequest, com.google.longrunning.Operation>
      getCreateRouteMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.CreateRouteRequest,
            com.google.longrunning.Operation>
        getCreateRouteMethod;
    if ((getCreateRouteMethod = DatastreamGrpc.getCreateRouteMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getCreateRouteMethod = DatastreamGrpc.getCreateRouteMethod) == null) {
          DatastreamGrpc.getCreateRouteMethod =
              getCreateRouteMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.CreateRouteRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateRoute"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.CreateRouteRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("CreateRoute"))
                      .build();
        }
      }
    }
    return getCreateRouteMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.GetRouteRequest,
          com.google.cloud.datastream.v1alpha1.Route>
      getGetRouteMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "GetRoute",
      requestType = com.google.cloud.datastream.v1alpha1.GetRouteRequest.class,
      responseType = com.google.cloud.datastream.v1alpha1.Route.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.GetRouteRequest,
          com.google.cloud.datastream.v1alpha1.Route>
      getGetRouteMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.GetRouteRequest,
            com.google.cloud.datastream.v1alpha1.Route>
        getGetRouteMethod;
    if ((getGetRouteMethod = DatastreamGrpc.getGetRouteMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getGetRouteMethod = DatastreamGrpc.getGetRouteMethod) == null) {
          DatastreamGrpc.getGetRouteMethod =
              getGetRouteMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.GetRouteRequest,
                          com.google.cloud.datastream.v1alpha1.Route>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetRoute"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.GetRouteRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.Route.getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("GetRoute"))
                      .build();
        }
      }
    }
    return getGetRouteMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.ListRoutesRequest,
          com.google.cloud.datastream.v1alpha1.ListRoutesResponse>
      getListRoutesMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "ListRoutes",
      requestType = com.google.cloud.datastream.v1alpha1.ListRoutesRequest.class,
      responseType = com.google.cloud.datastream.v1alpha1.ListRoutesResponse.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.ListRoutesRequest,
          com.google.cloud.datastream.v1alpha1.ListRoutesResponse>
      getListRoutesMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.ListRoutesRequest,
            com.google.cloud.datastream.v1alpha1.ListRoutesResponse>
        getListRoutesMethod;
    if ((getListRoutesMethod = DatastreamGrpc.getListRoutesMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getListRoutesMethod = DatastreamGrpc.getListRoutesMethod) == null) {
          DatastreamGrpc.getListRoutesMethod =
              getListRoutesMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.ListRoutesRequest,
                          com.google.cloud.datastream.v1alpha1.ListRoutesResponse>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListRoutes"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.ListRoutesRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.ListRoutesResponse
                                  .getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("ListRoutes"))
                      .build();
        }
      }
    }
    return getListRoutesMethod;
  }

  private static volatile io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.DeleteRouteRequest, com.google.longrunning.Operation>
      getDeleteRouteMethod;

  @io.grpc.stub.annotations.RpcMethod(
      fullMethodName = SERVICE_NAME + '/' + "DeleteRoute",
      requestType = com.google.cloud.datastream.v1alpha1.DeleteRouteRequest.class,
      responseType = com.google.longrunning.Operation.class,
      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
  public static io.grpc.MethodDescriptor<
          com.google.cloud.datastream.v1alpha1.DeleteRouteRequest, com.google.longrunning.Operation>
      getDeleteRouteMethod() {
    io.grpc.MethodDescriptor<
            com.google.cloud.datastream.v1alpha1.DeleteRouteRequest,
            com.google.longrunning.Operation>
        getDeleteRouteMethod;
    if ((getDeleteRouteMethod = DatastreamGrpc.getDeleteRouteMethod) == null) {
      synchronized (DatastreamGrpc.class) {
        if ((getDeleteRouteMethod = DatastreamGrpc.getDeleteRouteMethod) == null) {
          DatastreamGrpc.getDeleteRouteMethod =
              getDeleteRouteMethod =
                  io.grpc.MethodDescriptor
                      .<com.google.cloud.datastream.v1alpha1.DeleteRouteRequest,
                          com.google.longrunning.Operation>
                          newBuilder()
                      .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
                      .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteRoute"))
                      .setSampledToLocalTracing(true)
                      .setRequestMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.cloud.datastream.v1alpha1.DeleteRouteRequest
                                  .getDefaultInstance()))
                      .setResponseMarshaller(
                          io.grpc.protobuf.ProtoUtils.marshaller(
                              com.google.longrunning.Operation.getDefaultInstance()))
                      .setSchemaDescriptor(new DatastreamMethodDescriptorSupplier("DeleteRoute"))
                      .build();
        }
      }
    }
    return getDeleteRouteMethod;
  }

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

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

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

  /**
   *
   *
   * <pre>
   * Datastream service
   * </pre>
   */
  public interface AsyncService {

    /**
     *
     *
     * <pre>
     * Use this method to list connection profiles created in a project and
     * location.
     * </pre>
     */
    default void listConnectionProfiles(
        com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest request,
        io.grpc.stub.StreamObserver<
                com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getListConnectionProfilesMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a connection profile.
     * </pre>
     */
    default void getConnectionProfile(
        com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.ConnectionProfile>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getGetConnectionProfileMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a connection profile in a project and location.
     * </pre>
     */
    default void createConnectionProfile(
        com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getCreateConnectionProfileMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to update the parameters of a connection profile.
     * </pre>
     */
    default void updateConnectionProfile(
        com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getUpdateConnectionProfileMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a connection profile..
     * </pre>
     */
    default void deleteConnectionProfile(
        com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getDeleteConnectionProfileMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to discover a connection profile.
     * The discover API call exposes the data objects and metadata belonging to
     * the profile. Typically, a request returns children data objects under a
     * parent data object that's optionally supplied in the request.
     * </pre>
     */
    default void discoverConnectionProfile(
        com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest request,
        io.grpc.stub.StreamObserver<
                com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getDiscoverConnectionProfileMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list streams in a project and location.
     * </pre>
     */
    default void listStreams(
        com.google.cloud.datastream.v1alpha1.ListStreamsRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.ListStreamsResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getListStreamsMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a stream.
     * </pre>
     */
    default void getStream(
        com.google.cloud.datastream.v1alpha1.GetStreamRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.Stream> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetStreamMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a stream.
     * </pre>
     */
    default void createStream(
        com.google.cloud.datastream.v1alpha1.CreateStreamRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getCreateStreamMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to update the configuration of a stream.
     * </pre>
     */
    default void updateStream(
        com.google.cloud.datastream.v1alpha1.UpdateStreamRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getUpdateStreamMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a stream.
     * </pre>
     */
    default void deleteStream(
        com.google.cloud.datastream.v1alpha1.DeleteStreamRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getDeleteStreamMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to fetch any errors associated with a stream.
     * </pre>
     */
    default void fetchErrors(
        com.google.cloud.datastream.v1alpha1.FetchErrorsRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getFetchErrorsMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * The FetchStaticIps API call exposes the static ips used by Datastream.
     * Typically, a request returns children data objects under
     * a parent data object that's optionally supplied in the request.
     * </pre>
     */
    default void fetchStaticIps(
        com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getFetchStaticIpsMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a private connectivity configuration.
     * </pre>
     */
    default void createPrivateConnection(
        com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getCreatePrivateConnectionMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a private connectivity configuration.
     * </pre>
     */
    default void getPrivateConnection(
        com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.PrivateConnection>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getGetPrivateConnectionMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list private connectivity configurations in a project
     * and location.
     * </pre>
     */
    default void listPrivateConnections(
        com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest request,
        io.grpc.stub.StreamObserver<
                com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getListPrivateConnectionsMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a private connectivity configuration.
     * </pre>
     */
    default void deletePrivateConnection(
        com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getDeletePrivateConnectionMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a route for a private connectivity in a project
     * and location.
     * </pre>
     */
    default void createRoute(
        com.google.cloud.datastream.v1alpha1.CreateRouteRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getCreateRouteMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a route.
     * </pre>
     */
    default void getRoute(
        com.google.cloud.datastream.v1alpha1.GetRouteRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.Route> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetRouteMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list routes created for a private connectivity in a
     * project and location.
     * </pre>
     */
    default void listRoutes(
        com.google.cloud.datastream.v1alpha1.ListRoutesRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.ListRoutesResponse>
            responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListRoutesMethod(), responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a route.
     * </pre>
     */
    default void deleteRoute(
        com.google.cloud.datastream.v1alpha1.DeleteRouteRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
          getDeleteRouteMethod(), responseObserver);
    }
  }

  /**
   * Base class for the server implementation of the service Datastream.
   *
   * <pre>
   * Datastream service
   * </pre>
   */
  public abstract static class DatastreamImplBase implements io.grpc.BindableService, AsyncService {

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

  /**
   * A stub to allow clients to do asynchronous rpc calls to service Datastream.
   *
   * <pre>
   * Datastream service
   * </pre>
   */
  public static final class DatastreamStub extends io.grpc.stub.AbstractAsyncStub<DatastreamStub> {
    private DatastreamStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      super(channel, callOptions);
    }

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

    /**
     *
     *
     * <pre>
     * Use this method to list connection profiles created in a project and
     * location.
     * </pre>
     */
    public void listConnectionProfiles(
        com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest request,
        io.grpc.stub.StreamObserver<
                com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getListConnectionProfilesMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a connection profile.
     * </pre>
     */
    public void getConnectionProfile(
        com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.ConnectionProfile>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getGetConnectionProfileMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a connection profile in a project and location.
     * </pre>
     */
    public void createConnectionProfile(
        com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getCreateConnectionProfileMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to update the parameters of a connection profile.
     * </pre>
     */
    public void updateConnectionProfile(
        com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getUpdateConnectionProfileMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a connection profile..
     * </pre>
     */
    public void deleteConnectionProfile(
        com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getDeleteConnectionProfileMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to discover a connection profile.
     * The discover API call exposes the data objects and metadata belonging to
     * the profile. Typically, a request returns children data objects under a
     * parent data object that's optionally supplied in the request.
     * </pre>
     */
    public void discoverConnectionProfile(
        com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest request,
        io.grpc.stub.StreamObserver<
                com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getDiscoverConnectionProfileMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list streams in a project and location.
     * </pre>
     */
    public void listStreams(
        com.google.cloud.datastream.v1alpha1.ListStreamsRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.ListStreamsResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getListStreamsMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a stream.
     * </pre>
     */
    public void getStream(
        com.google.cloud.datastream.v1alpha1.GetStreamRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.Stream> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getGetStreamMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a stream.
     * </pre>
     */
    public void createStream(
        com.google.cloud.datastream.v1alpha1.CreateStreamRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getCreateStreamMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to update the configuration of a stream.
     * </pre>
     */
    public void updateStream(
        com.google.cloud.datastream.v1alpha1.UpdateStreamRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getUpdateStreamMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a stream.
     * </pre>
     */
    public void deleteStream(
        com.google.cloud.datastream.v1alpha1.DeleteStreamRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getDeleteStreamMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to fetch any errors associated with a stream.
     * </pre>
     */
    public void fetchErrors(
        com.google.cloud.datastream.v1alpha1.FetchErrorsRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getFetchErrorsMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * The FetchStaticIps API call exposes the static ips used by Datastream.
     * Typically, a request returns children data objects under
     * a parent data object that's optionally supplied in the request.
     * </pre>
     */
    public void fetchStaticIps(
        com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getFetchStaticIpsMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a private connectivity configuration.
     * </pre>
     */
    public void createPrivateConnection(
        com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getCreatePrivateConnectionMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a private connectivity configuration.
     * </pre>
     */
    public void getPrivateConnection(
        com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.PrivateConnection>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getGetPrivateConnectionMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list private connectivity configurations in a project
     * and location.
     * </pre>
     */
    public void listPrivateConnections(
        com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest request,
        io.grpc.stub.StreamObserver<
                com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getListPrivateConnectionsMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a private connectivity configuration.
     * </pre>
     */
    public void deletePrivateConnection(
        com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getDeletePrivateConnectionMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a route for a private connectivity in a project
     * and location.
     * </pre>
     */
    public void createRoute(
        com.google.cloud.datastream.v1alpha1.CreateRouteRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getCreateRouteMethod(), getCallOptions()),
          request,
          responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a route.
     * </pre>
     */
    public void getRoute(
        com.google.cloud.datastream.v1alpha1.GetRouteRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.Route> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getGetRouteMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list routes created for a private connectivity in a
     * project and location.
     * </pre>
     */
    public void listRoutes(
        com.google.cloud.datastream.v1alpha1.ListRoutesRequest request,
        io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.ListRoutesResponse>
            responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getListRoutesMethod(), getCallOptions()), request, responseObserver);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a route.
     * </pre>
     */
    public void deleteRoute(
        com.google.cloud.datastream.v1alpha1.DeleteRouteRequest request,
        io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
      io.grpc.stub.ClientCalls.asyncUnaryCall(
          getChannel().newCall(getDeleteRouteMethod(), getCallOptions()),
          request,
          responseObserver);
    }
  }

  /**
   * A stub to allow clients to do synchronous rpc calls to service Datastream.
   *
   * <pre>
   * Datastream service
   * </pre>
   */
  public static final class DatastreamBlockingStub
      extends io.grpc.stub.AbstractBlockingStub<DatastreamBlockingStub> {
    private DatastreamBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      super(channel, callOptions);
    }

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

    /**
     *
     *
     * <pre>
     * Use this method to list connection profiles created in a project and
     * location.
     * </pre>
     */
    public com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse
        listConnectionProfiles(
            com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getListConnectionProfilesMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a connection profile.
     * </pre>
     */
    public com.google.cloud.datastream.v1alpha1.ConnectionProfile getConnectionProfile(
        com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getGetConnectionProfileMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a connection profile in a project and location.
     * </pre>
     */
    public com.google.longrunning.Operation createConnectionProfile(
        com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getCreateConnectionProfileMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to update the parameters of a connection profile.
     * </pre>
     */
    public com.google.longrunning.Operation updateConnectionProfile(
        com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getUpdateConnectionProfileMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a connection profile..
     * </pre>
     */
    public com.google.longrunning.Operation deleteConnectionProfile(
        com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getDeleteConnectionProfileMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to discover a connection profile.
     * The discover API call exposes the data objects and metadata belonging to
     * the profile. Typically, a request returns children data objects under a
     * parent data object that's optionally supplied in the request.
     * </pre>
     */
    public com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse
        discoverConnectionProfile(
            com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getDiscoverConnectionProfileMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list streams in a project and location.
     * </pre>
     */
    public com.google.cloud.datastream.v1alpha1.ListStreamsResponse listStreams(
        com.google.cloud.datastream.v1alpha1.ListStreamsRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getListStreamsMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a stream.
     * </pre>
     */
    public com.google.cloud.datastream.v1alpha1.Stream getStream(
        com.google.cloud.datastream.v1alpha1.GetStreamRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getGetStreamMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a stream.
     * </pre>
     */
    public com.google.longrunning.Operation createStream(
        com.google.cloud.datastream.v1alpha1.CreateStreamRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getCreateStreamMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to update the configuration of a stream.
     * </pre>
     */
    public com.google.longrunning.Operation updateStream(
        com.google.cloud.datastream.v1alpha1.UpdateStreamRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getUpdateStreamMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a stream.
     * </pre>
     */
    public com.google.longrunning.Operation deleteStream(
        com.google.cloud.datastream.v1alpha1.DeleteStreamRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getDeleteStreamMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to fetch any errors associated with a stream.
     * </pre>
     */
    public com.google.longrunning.Operation fetchErrors(
        com.google.cloud.datastream.v1alpha1.FetchErrorsRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getFetchErrorsMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * The FetchStaticIps API call exposes the static ips used by Datastream.
     * Typically, a request returns children data objects under
     * a parent data object that's optionally supplied in the request.
     * </pre>
     */
    public com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse fetchStaticIps(
        com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getFetchStaticIpsMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a private connectivity configuration.
     * </pre>
     */
    public com.google.longrunning.Operation createPrivateConnection(
        com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getCreatePrivateConnectionMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a private connectivity configuration.
     * </pre>
     */
    public com.google.cloud.datastream.v1alpha1.PrivateConnection getPrivateConnection(
        com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getGetPrivateConnectionMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list private connectivity configurations in a project
     * and location.
     * </pre>
     */
    public com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse
        listPrivateConnections(
            com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getListPrivateConnectionsMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a private connectivity configuration.
     * </pre>
     */
    public com.google.longrunning.Operation deletePrivateConnection(
        com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getDeletePrivateConnectionMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a route for a private connectivity in a project
     * and location.
     * </pre>
     */
    public com.google.longrunning.Operation createRoute(
        com.google.cloud.datastream.v1alpha1.CreateRouteRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getCreateRouteMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a route.
     * </pre>
     */
    public com.google.cloud.datastream.v1alpha1.Route getRoute(
        com.google.cloud.datastream.v1alpha1.GetRouteRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getGetRouteMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list routes created for a private connectivity in a
     * project and location.
     * </pre>
     */
    public com.google.cloud.datastream.v1alpha1.ListRoutesResponse listRoutes(
        com.google.cloud.datastream.v1alpha1.ListRoutesRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getListRoutesMethod(), getCallOptions(), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a route.
     * </pre>
     */
    public com.google.longrunning.Operation deleteRoute(
        com.google.cloud.datastream.v1alpha1.DeleteRouteRequest request) {
      return io.grpc.stub.ClientCalls.blockingUnaryCall(
          getChannel(), getDeleteRouteMethod(), getCallOptions(), request);
    }
  }

  /**
   * A stub to allow clients to do ListenableFuture-style rpc calls to service Datastream.
   *
   * <pre>
   * Datastream service
   * </pre>
   */
  public static final class DatastreamFutureStub
      extends io.grpc.stub.AbstractFutureStub<DatastreamFutureStub> {
    private DatastreamFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
      super(channel, callOptions);
    }

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

    /**
     *
     *
     * <pre>
     * Use this method to list connection profiles created in a project and
     * location.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse>
        listConnectionProfiles(
            com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getListConnectionProfilesMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a connection profile.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datastream.v1alpha1.ConnectionProfile>
        getConnectionProfile(
            com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getGetConnectionProfileMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a connection profile in a project and location.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        createConnectionProfile(
            com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getCreateConnectionProfileMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to update the parameters of a connection profile.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        updateConnectionProfile(
            com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getUpdateConnectionProfileMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a connection profile..
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        deleteConnectionProfile(
            com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getDeleteConnectionProfileMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to discover a connection profile.
     * The discover API call exposes the data objects and metadata belonging to
     * the profile. Typically, a request returns children data objects under a
     * parent data object that's optionally supplied in the request.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse>
        discoverConnectionProfile(
            com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getDiscoverConnectionProfileMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list streams in a project and location.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datastream.v1alpha1.ListStreamsResponse>
        listStreams(com.google.cloud.datastream.v1alpha1.ListStreamsRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getListStreamsMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a stream.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datastream.v1alpha1.Stream>
        getStream(com.google.cloud.datastream.v1alpha1.GetStreamRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getGetStreamMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a stream.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        createStream(com.google.cloud.datastream.v1alpha1.CreateStreamRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getCreateStreamMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to update the configuration of a stream.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        updateStream(com.google.cloud.datastream.v1alpha1.UpdateStreamRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getUpdateStreamMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a stream.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        deleteStream(com.google.cloud.datastream.v1alpha1.DeleteStreamRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getDeleteStreamMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to fetch any errors associated with a stream.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        fetchErrors(com.google.cloud.datastream.v1alpha1.FetchErrorsRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getFetchErrorsMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * The FetchStaticIps API call exposes the static ips used by Datastream.
     * Typically, a request returns children data objects under
     * a parent data object that's optionally supplied in the request.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse>
        fetchStaticIps(com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getFetchStaticIpsMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a private connectivity configuration.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        createPrivateConnection(
            com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getCreatePrivateConnectionMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a private connectivity configuration.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datastream.v1alpha1.PrivateConnection>
        getPrivateConnection(
            com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getGetPrivateConnectionMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list private connectivity configurations in a project
     * and location.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse>
        listPrivateConnections(
            com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getListPrivateConnectionsMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a private connectivity configuration.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        deletePrivateConnection(
            com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getDeletePrivateConnectionMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to create a route for a private connectivity in a project
     * and location.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        createRoute(com.google.cloud.datastream.v1alpha1.CreateRouteRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getCreateRouteMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to get details about a route.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datastream.v1alpha1.Route>
        getRoute(com.google.cloud.datastream.v1alpha1.GetRouteRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getGetRouteMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to list routes created for a private connectivity in a
     * project and location.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<
            com.google.cloud.datastream.v1alpha1.ListRoutesResponse>
        listRoutes(com.google.cloud.datastream.v1alpha1.ListRoutesRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getListRoutesMethod(), getCallOptions()), request);
    }

    /**
     *
     *
     * <pre>
     * Use this method to delete a route.
     * </pre>
     */
    public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
        deleteRoute(com.google.cloud.datastream.v1alpha1.DeleteRouteRequest request) {
      return io.grpc.stub.ClientCalls.futureUnaryCall(
          getChannel().newCall(getDeleteRouteMethod(), getCallOptions()), request);
    }
  }

  private static final int METHODID_LIST_CONNECTION_PROFILES = 0;
  private static final int METHODID_GET_CONNECTION_PROFILE = 1;
  private static final int METHODID_CREATE_CONNECTION_PROFILE = 2;
  private static final int METHODID_UPDATE_CONNECTION_PROFILE = 3;
  private static final int METHODID_DELETE_CONNECTION_PROFILE = 4;
  private static final int METHODID_DISCOVER_CONNECTION_PROFILE = 5;
  private static final int METHODID_LIST_STREAMS = 6;
  private static final int METHODID_GET_STREAM = 7;
  private static final int METHODID_CREATE_STREAM = 8;
  private static final int METHODID_UPDATE_STREAM = 9;
  private static final int METHODID_DELETE_STREAM = 10;
  private static final int METHODID_FETCH_ERRORS = 11;
  private static final int METHODID_FETCH_STATIC_IPS = 12;
  private static final int METHODID_CREATE_PRIVATE_CONNECTION = 13;
  private static final int METHODID_GET_PRIVATE_CONNECTION = 14;
  private static final int METHODID_LIST_PRIVATE_CONNECTIONS = 15;
  private static final int METHODID_DELETE_PRIVATE_CONNECTION = 16;
  private static final int METHODID_CREATE_ROUTE = 17;
  private static final int METHODID_GET_ROUTE = 18;
  private static final int METHODID_LIST_ROUTES = 19;
  private static final int METHODID_DELETE_ROUTE = 20;

  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_CONNECTION_PROFILES:
          serviceImpl.listConnectionProfiles(
              (com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse>)
                  responseObserver);
          break;
        case METHODID_GET_CONNECTION_PROFILE:
          serviceImpl.getConnectionProfile(
              (com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest) request,
              (io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.ConnectionProfile>)
                  responseObserver);
          break;
        case METHODID_CREATE_CONNECTION_PROFILE:
          serviceImpl.createConnectionProfile(
              (com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_UPDATE_CONNECTION_PROFILE:
          serviceImpl.updateConnectionProfile(
              (com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_DELETE_CONNECTION_PROFILE:
          serviceImpl.deleteConnectionProfile(
              (com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_DISCOVER_CONNECTION_PROFILE:
          serviceImpl.discoverConnectionProfile(
              (com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse>)
                  responseObserver);
          break;
        case METHODID_LIST_STREAMS:
          serviceImpl.listStreams(
              (com.google.cloud.datastream.v1alpha1.ListStreamsRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datastream.v1alpha1.ListStreamsResponse>)
                  responseObserver);
          break;
        case METHODID_GET_STREAM:
          serviceImpl.getStream(
              (com.google.cloud.datastream.v1alpha1.GetStreamRequest) request,
              (io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.Stream>)
                  responseObserver);
          break;
        case METHODID_CREATE_STREAM:
          serviceImpl.createStream(
              (com.google.cloud.datastream.v1alpha1.CreateStreamRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_UPDATE_STREAM:
          serviceImpl.updateStream(
              (com.google.cloud.datastream.v1alpha1.UpdateStreamRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_DELETE_STREAM:
          serviceImpl.deleteStream(
              (com.google.cloud.datastream.v1alpha1.DeleteStreamRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_FETCH_ERRORS:
          serviceImpl.fetchErrors(
              (com.google.cloud.datastream.v1alpha1.FetchErrorsRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_FETCH_STATIC_IPS:
          serviceImpl.fetchStaticIps(
              (com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse>)
                  responseObserver);
          break;
        case METHODID_CREATE_PRIVATE_CONNECTION:
          serviceImpl.createPrivateConnection(
              (com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_GET_PRIVATE_CONNECTION:
          serviceImpl.getPrivateConnection(
              (com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest) request,
              (io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.PrivateConnection>)
                  responseObserver);
          break;
        case METHODID_LIST_PRIVATE_CONNECTIONS:
          serviceImpl.listPrivateConnections(
              (com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest) request,
              (io.grpc.stub.StreamObserver<
                      com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse>)
                  responseObserver);
          break;
        case METHODID_DELETE_PRIVATE_CONNECTION:
          serviceImpl.deletePrivateConnection(
              (com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_CREATE_ROUTE:
          serviceImpl.createRoute(
              (com.google.cloud.datastream.v1alpha1.CreateRouteRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
          break;
        case METHODID_GET_ROUTE:
          serviceImpl.getRoute(
              (com.google.cloud.datastream.v1alpha1.GetRouteRequest) request,
              (io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.Route>)
                  responseObserver);
          break;
        case METHODID_LIST_ROUTES:
          serviceImpl.listRoutes(
              (com.google.cloud.datastream.v1alpha1.ListRoutesRequest) request,
              (io.grpc.stub.StreamObserver<com.google.cloud.datastream.v1alpha1.ListRoutesResponse>)
                  responseObserver);
          break;
        case METHODID_DELETE_ROUTE:
          serviceImpl.deleteRoute(
              (com.google.cloud.datastream.v1alpha1.DeleteRouteRequest) request,
              (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) 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(
            getListConnectionProfilesMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.ListConnectionProfilesRequest,
                    com.google.cloud.datastream.v1alpha1.ListConnectionProfilesResponse>(
                    service, METHODID_LIST_CONNECTION_PROFILES)))
        .addMethod(
            getGetConnectionProfileMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.GetConnectionProfileRequest,
                    com.google.cloud.datastream.v1alpha1.ConnectionProfile>(
                    service, METHODID_GET_CONNECTION_PROFILE)))
        .addMethod(
            getCreateConnectionProfileMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.CreateConnectionProfileRequest,
                    com.google.longrunning.Operation>(service, METHODID_CREATE_CONNECTION_PROFILE)))
        .addMethod(
            getUpdateConnectionProfileMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.UpdateConnectionProfileRequest,
                    com.google.longrunning.Operation>(service, METHODID_UPDATE_CONNECTION_PROFILE)))
        .addMethod(
            getDeleteConnectionProfileMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.DeleteConnectionProfileRequest,
                    com.google.longrunning.Operation>(service, METHODID_DELETE_CONNECTION_PROFILE)))
        .addMethod(
            getDiscoverConnectionProfileMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileRequest,
                    com.google.cloud.datastream.v1alpha1.DiscoverConnectionProfileResponse>(
                    service, METHODID_DISCOVER_CONNECTION_PROFILE)))
        .addMethod(
            getListStreamsMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.ListStreamsRequest,
                    com.google.cloud.datastream.v1alpha1.ListStreamsResponse>(
                    service, METHODID_LIST_STREAMS)))
        .addMethod(
            getGetStreamMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.GetStreamRequest,
                    com.google.cloud.datastream.v1alpha1.Stream>(service, METHODID_GET_STREAM)))
        .addMethod(
            getCreateStreamMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.CreateStreamRequest,
                    com.google.longrunning.Operation>(service, METHODID_CREATE_STREAM)))
        .addMethod(
            getUpdateStreamMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.UpdateStreamRequest,
                    com.google.longrunning.Operation>(service, METHODID_UPDATE_STREAM)))
        .addMethod(
            getDeleteStreamMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.DeleteStreamRequest,
                    com.google.longrunning.Operation>(service, METHODID_DELETE_STREAM)))
        .addMethod(
            getFetchErrorsMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.FetchErrorsRequest,
                    com.google.longrunning.Operation>(service, METHODID_FETCH_ERRORS)))
        .addMethod(
            getFetchStaticIpsMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.FetchStaticIpsRequest,
                    com.google.cloud.datastream.v1alpha1.FetchStaticIpsResponse>(
                    service, METHODID_FETCH_STATIC_IPS)))
        .addMethod(
            getCreatePrivateConnectionMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.CreatePrivateConnectionRequest,
                    com.google.longrunning.Operation>(service, METHODID_CREATE_PRIVATE_CONNECTION)))
        .addMethod(
            getGetPrivateConnectionMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.GetPrivateConnectionRequest,
                    com.google.cloud.datastream.v1alpha1.PrivateConnection>(
                    service, METHODID_GET_PRIVATE_CONNECTION)))
        .addMethod(
            getListPrivateConnectionsMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsRequest,
                    com.google.cloud.datastream.v1alpha1.ListPrivateConnectionsResponse>(
                    service, METHODID_LIST_PRIVATE_CONNECTIONS)))
        .addMethod(
            getDeletePrivateConnectionMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.DeletePrivateConnectionRequest,
                    com.google.longrunning.Operation>(service, METHODID_DELETE_PRIVATE_CONNECTION)))
        .addMethod(
            getCreateRouteMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.CreateRouteRequest,
                    com.google.longrunning.Operation>(service, METHODID_CREATE_ROUTE)))
        .addMethod(
            getGetRouteMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.GetRouteRequest,
                    com.google.cloud.datastream.v1alpha1.Route>(service, METHODID_GET_ROUTE)))
        .addMethod(
            getListRoutesMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.ListRoutesRequest,
                    com.google.cloud.datastream.v1alpha1.ListRoutesResponse>(
                    service, METHODID_LIST_ROUTES)))
        .addMethod(
            getDeleteRouteMethod(),
            io.grpc.stub.ServerCalls.asyncUnaryCall(
                new MethodHandlers<
                    com.google.cloud.datastream.v1alpha1.DeleteRouteRequest,
                    com.google.longrunning.Operation>(service, METHODID_DELETE_ROUTE)))
        .build();
  }

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

    @java.lang.Override
    public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
      return com.google.cloud.datastream.v1alpha1.CloudDatastreamServiceProto.getDescriptor();
    }

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

  private static final class DatastreamFileDescriptorSupplier
      extends DatastreamBaseDescriptorSupplier {
    DatastreamFileDescriptorSupplier() {}
  }

  private static final class DatastreamMethodDescriptorSupplier
      extends DatastreamBaseDescriptorSupplier
      implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
    private final String methodName;

    DatastreamMethodDescriptorSupplier(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 (DatastreamGrpc.class) {
        result = serviceDescriptor;
        if (result == null) {
          serviceDescriptor =
              result =
                  io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
                      .setSchemaDescriptor(new DatastreamFileDescriptorSupplier())
                      .addMethod(getListConnectionProfilesMethod())
                      .addMethod(getGetConnectionProfileMethod())
                      .addMethod(getCreateConnectionProfileMethod())
                      .addMethod(getUpdateConnectionProfileMethod())
                      .addMethod(getDeleteConnectionProfileMethod())
                      .addMethod(getDiscoverConnectionProfileMethod())
                      .addMethod(getListStreamsMethod())
                      .addMethod(getGetStreamMethod())
                      .addMethod(getCreateStreamMethod())
                      .addMethod(getUpdateStreamMethod())
                      .addMethod(getDeleteStreamMethod())
                      .addMethod(getFetchErrorsMethod())
                      .addMethod(getFetchStaticIpsMethod())
                      .addMethod(getCreatePrivateConnectionMethod())
                      .addMethod(getGetPrivateConnectionMethod())
                      .addMethod(getListPrivateConnectionsMethod())
                      .addMethod(getDeletePrivateConnectionMethod())
                      .addMethod(getCreateRouteMethod())
                      .addMethod(getGetRouteMethod())
                      .addMethod(getListRoutesMethod())
                      .addMethod(getDeleteRouteMethod())
                      .build();
        }
      }
    }
    return result;
  }
}
