{
private DataTransferServiceBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected DataTransferServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new DataTransferServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Retrieves a supported data source and returns its settings.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.DataSource getDataSource(
com.google.cloud.bigquery.datatransfer.v1.GetDataSourceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetDataSourceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists supported data sources and returns their settings.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesResponse listDataSources(
com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListDataSourcesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new data transfer configuration.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.TransferConfig createTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.CreateTransferConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateTransferConfigMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates a data transfer configuration.
* All fields must be set, even if they are not updated.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.TransferConfig updateTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.UpdateTransferConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateTransferConfigMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a data transfer configuration, including any associated transfer
* runs and logs.
*
*/
public com.google.protobuf.Empty deleteTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.DeleteTransferConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteTransferConfigMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns information about a data transfer config.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.TransferConfig getTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.GetTransferConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetTransferConfigMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns information about all transfer configs owned by a project in the
* specified location.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsResponse
listTransferConfigs(
com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTransferConfigsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates transfer runs for a time range [start_time, end_time].
* For each date - or whatever granularity the data source supports - in the
* range, one transfer run is created.
* Note that runs are created per UTC time in the time range.
* DEPRECATED: use StartManualTransferRuns instead.
*
*/
@java.lang.Deprecated
public com.google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsResponse
scheduleTransferRuns(
com.google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getScheduleTransferRunsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Start manual transfer runs to be executed now with schedule_time equal to
* current time. The transfer runs can be created for a time range where the
* run_time is between start_time (inclusive) and end_time (exclusive), or for
* a specific run_time.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsResponse
startManualTransferRuns(
com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStartManualTransferRunsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns information about the particular transfer run.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.TransferRun getTransferRun(
com.google.cloud.bigquery.datatransfer.v1.GetTransferRunRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetTransferRunMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes the specified transfer run.
*
*/
public com.google.protobuf.Empty deleteTransferRun(
com.google.cloud.bigquery.datatransfer.v1.DeleteTransferRunRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteTransferRunMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns information about running and completed transfer runs.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsResponse listTransferRuns(
com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTransferRunsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns log messages for the transfer run.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsResponse listTransferLogs(
com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTransferLogsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns true if valid credentials exist for the given data source and
* requesting user.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsResponse checkValidCreds(
com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCheckValidCredsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Enroll data sources in a user project. This allows users to create transfer
* configurations for these data sources. They will also appear in the
* ListDataSources RPC and as such, will appear in the
* [BigQuery UI](https://console.cloud.google.com/bigquery), and the documents
* can be found in the public guide for
* [BigQuery Web UI](https://cloud.google.com/bigquery/bigquery-web-ui) and
* [Data Transfer
* Service](https://cloud.google.com/bigquery/docs/working-with-transfers).
*
*/
public com.google.protobuf.Empty enrollDataSources(
com.google.cloud.bigquery.datatransfer.v1.EnrollDataSourcesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getEnrollDataSourcesMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service DataTransferService.
*
*
* This API allows users to manage their data transfers into BigQuery.
*
*/
public static final class DataTransferServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private DataTransferServiceFutureStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected DataTransferServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new DataTransferServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Retrieves a supported data source and returns its settings.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.DataSource>
getDataSource(com.google.cloud.bigquery.datatransfer.v1.GetDataSourceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetDataSourceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists supported data sources and returns their settings.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesResponse>
listDataSources(com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListDataSourcesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new data transfer configuration.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>
createTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.CreateTransferConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateTransferConfigMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates a data transfer configuration.
* All fields must be set, even if they are not updated.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>
updateTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.UpdateTransferConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateTransferConfigMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a data transfer configuration, including any associated transfer
* runs and logs.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.DeleteTransferConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteTransferConfigMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns information about a data transfer config.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>
getTransferConfig(
com.google.cloud.bigquery.datatransfer.v1.GetTransferConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetTransferConfigMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns information about all transfer configs owned by a project in the
* specified location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsResponse>
listTransferConfigs(
com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListTransferConfigsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates transfer runs for a time range [start_time, end_time].
* For each date - or whatever granularity the data source supports - in the
* range, one transfer run is created.
* Note that runs are created per UTC time in the time range.
* DEPRECATED: use StartManualTransferRuns instead.
*
*/
@java.lang.Deprecated
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsResponse>
scheduleTransferRuns(
com.google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getScheduleTransferRunsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Start manual transfer runs to be executed now with schedule_time equal to
* current time. The transfer runs can be created for a time range where the
* run_time is between start_time (inclusive) and end_time (exclusive), or for
* a specific run_time.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsResponse>
startManualTransferRuns(
com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStartManualTransferRunsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns information about the particular transfer run.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.TransferRun>
getTransferRun(com.google.cloud.bigquery.datatransfer.v1.GetTransferRunRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetTransferRunMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes the specified transfer run.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteTransferRun(
com.google.cloud.bigquery.datatransfer.v1.DeleteTransferRunRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteTransferRunMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns information about running and completed transfer runs.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsResponse>
listTransferRuns(
com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListTransferRunsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns log messages for the transfer run.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsResponse>
listTransferLogs(
com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListTransferLogsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns true if valid credentials exist for the given data source and
* requesting user.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsResponse>
checkValidCreds(com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCheckValidCredsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Enroll data sources in a user project. This allows users to create transfer
* configurations for these data sources. They will also appear in the
* ListDataSources RPC and as such, will appear in the
* [BigQuery UI](https://console.cloud.google.com/bigquery), and the documents
* can be found in the public guide for
* [BigQuery Web UI](https://cloud.google.com/bigquery/bigquery-web-ui) and
* [Data Transfer
* Service](https://cloud.google.com/bigquery/docs/working-with-transfers).
*
*/
public com.google.common.util.concurrent.ListenableFuture
enrollDataSources(
com.google.cloud.bigquery.datatransfer.v1.EnrollDataSourcesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getEnrollDataSourcesMethod(), getCallOptions()), request);
}
}
private static final int METHODID_GET_DATA_SOURCE = 0;
private static final int METHODID_LIST_DATA_SOURCES = 1;
private static final int METHODID_CREATE_TRANSFER_CONFIG = 2;
private static final int METHODID_UPDATE_TRANSFER_CONFIG = 3;
private static final int METHODID_DELETE_TRANSFER_CONFIG = 4;
private static final int METHODID_GET_TRANSFER_CONFIG = 5;
private static final int METHODID_LIST_TRANSFER_CONFIGS = 6;
private static final int METHODID_SCHEDULE_TRANSFER_RUNS = 7;
private static final int METHODID_START_MANUAL_TRANSFER_RUNS = 8;
private static final int METHODID_GET_TRANSFER_RUN = 9;
private static final int METHODID_DELETE_TRANSFER_RUN = 10;
private static final int METHODID_LIST_TRANSFER_RUNS = 11;
private static final int METHODID_LIST_TRANSFER_LOGS = 12;
private static final int METHODID_CHECK_VALID_CREDS = 13;
private static final int METHODID_ENROLL_DATA_SOURCES = 14;
private static final class MethodHandlers
implements io.grpc.stub.ServerCalls.UnaryMethod,
io.grpc.stub.ServerCalls.ServerStreamingMethod,
io.grpc.stub.ServerCalls.ClientStreamingMethod,
io.grpc.stub.ServerCalls.BidiStreamingMethod {
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 responseObserver) {
switch (methodId) {
case METHODID_GET_DATA_SOURCE:
serviceImpl.getDataSource(
(com.google.cloud.bigquery.datatransfer.v1.GetDataSourceRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_DATA_SOURCES:
serviceImpl.listDataSources(
(com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesResponse>)
responseObserver);
break;
case METHODID_CREATE_TRANSFER_CONFIG:
serviceImpl.createTransferConfig(
(com.google.cloud.bigquery.datatransfer.v1.CreateTransferConfigRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>)
responseObserver);
break;
case METHODID_UPDATE_TRANSFER_CONFIG:
serviceImpl.updateTransferConfig(
(com.google.cloud.bigquery.datatransfer.v1.UpdateTransferConfigRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>)
responseObserver);
break;
case METHODID_DELETE_TRANSFER_CONFIG:
serviceImpl.deleteTransferConfig(
(com.google.cloud.bigquery.datatransfer.v1.DeleteTransferConfigRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_TRANSFER_CONFIG:
serviceImpl.getTransferConfig(
(com.google.cloud.bigquery.datatransfer.v1.GetTransferConfigRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>)
responseObserver);
break;
case METHODID_LIST_TRANSFER_CONFIGS:
serviceImpl.listTransferConfigs(
(com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsResponse>)
responseObserver);
break;
case METHODID_SCHEDULE_TRANSFER_RUNS:
serviceImpl.scheduleTransferRuns(
(com.google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsResponse>)
responseObserver);
break;
case METHODID_START_MANUAL_TRANSFER_RUNS:
serviceImpl.startManualTransferRuns(
(com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsResponse>)
responseObserver);
break;
case METHODID_GET_TRANSFER_RUN:
serviceImpl.getTransferRun(
(com.google.cloud.bigquery.datatransfer.v1.GetTransferRunRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_TRANSFER_RUN:
serviceImpl.deleteTransferRun(
(com.google.cloud.bigquery.datatransfer.v1.DeleteTransferRunRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_TRANSFER_RUNS:
serviceImpl.listTransferRuns(
(com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsResponse>)
responseObserver);
break;
case METHODID_LIST_TRANSFER_LOGS:
serviceImpl.listTransferLogs(
(com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsResponse>)
responseObserver);
break;
case METHODID_CHECK_VALID_CREDS:
serviceImpl.checkValidCreds(
(com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsResponse>)
responseObserver);
break;
case METHODID_ENROLL_DATA_SOURCES:
serviceImpl.enrollDataSources(
(com.google.cloud.bigquery.datatransfer.v1.EnrollDataSourcesRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
default:
throw new AssertionError();
}
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
default:
throw new AssertionError();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getGetDataSourceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.GetDataSourceRequest,
com.google.cloud.bigquery.datatransfer.v1.DataSource>(
service, METHODID_GET_DATA_SOURCE)))
.addMethod(
getListDataSourcesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesRequest,
com.google.cloud.bigquery.datatransfer.v1.ListDataSourcesResponse>(
service, METHODID_LIST_DATA_SOURCES)))
.addMethod(
getCreateTransferConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.CreateTransferConfigRequest,
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>(
service, METHODID_CREATE_TRANSFER_CONFIG)))
.addMethod(
getUpdateTransferConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.UpdateTransferConfigRequest,
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>(
service, METHODID_UPDATE_TRANSFER_CONFIG)))
.addMethod(
getDeleteTransferConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.DeleteTransferConfigRequest,
com.google.protobuf.Empty>(service, METHODID_DELETE_TRANSFER_CONFIG)))
.addMethod(
getGetTransferConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.GetTransferConfigRequest,
com.google.cloud.bigquery.datatransfer.v1.TransferConfig>(
service, METHODID_GET_TRANSFER_CONFIG)))
.addMethod(
getListTransferConfigsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsRequest,
com.google.cloud.bigquery.datatransfer.v1.ListTransferConfigsResponse>(
service, METHODID_LIST_TRANSFER_CONFIGS)))
.addMethod(
getScheduleTransferRunsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsRequest,
com.google.cloud.bigquery.datatransfer.v1.ScheduleTransferRunsResponse>(
service, METHODID_SCHEDULE_TRANSFER_RUNS)))
.addMethod(
getStartManualTransferRunsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsRequest,
com.google.cloud.bigquery.datatransfer.v1.StartManualTransferRunsResponse>(
service, METHODID_START_MANUAL_TRANSFER_RUNS)))
.addMethod(
getGetTransferRunMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.GetTransferRunRequest,
com.google.cloud.bigquery.datatransfer.v1.TransferRun>(
service, METHODID_GET_TRANSFER_RUN)))
.addMethod(
getDeleteTransferRunMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.DeleteTransferRunRequest,
com.google.protobuf.Empty>(service, METHODID_DELETE_TRANSFER_RUN)))
.addMethod(
getListTransferRunsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest,
com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsResponse>(
service, METHODID_LIST_TRANSFER_RUNS)))
.addMethod(
getListTransferLogsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsRequest,
com.google.cloud.bigquery.datatransfer.v1.ListTransferLogsResponse>(
service, METHODID_LIST_TRANSFER_LOGS)))
.addMethod(
getCheckValidCredsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsRequest,
com.google.cloud.bigquery.datatransfer.v1.CheckValidCredsResponse>(
service, METHODID_CHECK_VALID_CREDS)))
.addMethod(
getEnrollDataSourcesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.datatransfer.v1.EnrollDataSourcesRequest,
com.google.protobuf.Empty>(service, METHODID_ENROLL_DATA_SOURCES)))
.build();
}
private abstract static class DataTransferServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
DataTransferServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.bigquery.datatransfer.v1.DataTransferProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("DataTransferService");
}
}
private static final class DataTransferServiceFileDescriptorSupplier
extends DataTransferServiceBaseDescriptorSupplier {
DataTransferServiceFileDescriptorSupplier() {}
}
private static final class DataTransferServiceMethodDescriptorSupplier
extends DataTransferServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
DataTransferServiceMethodDescriptorSupplier(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 (DataTransferServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new DataTransferServiceFileDescriptorSupplier())
.addMethod(getGetDataSourceMethod())
.addMethod(getListDataSourcesMethod())
.addMethod(getCreateTransferConfigMethod())
.addMethod(getUpdateTransferConfigMethod())
.addMethod(getDeleteTransferConfigMethod())
.addMethod(getGetTransferConfigMethod())
.addMethod(getListTransferConfigsMethod())
.addMethod(getScheduleTransferRunsMethod())
.addMethod(getStartManualTransferRunsMethod())
.addMethod(getGetTransferRunMethod())
.addMethod(getDeleteTransferRunMethod())
.addMethod(getListTransferRunsMethod())
.addMethod(getListTransferLogsMethod())
.addMethod(getCheckValidCredsMethod())
.addMethod(getEnrollDataSourcesMethod())
.build();
}
}
}
return result;
}
}