{
private DataSourceServiceBlockingStub(io.grpc.Channel channel) {
super(channel);
}
private DataSourceServiceBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected DataSourceServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new DataSourceServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Update a transfer run. If successful, resets
* data_source.update_deadline_seconds timer.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.TransferRun updateTransferRun(
com.google.cloud.bigquery.datatransfer.v1.UpdateTransferRunRequest request) {
return blockingUnaryCall(
getChannel(), getUpdateTransferRunMethodHelper(), getCallOptions(), request);
}
/**
*
*
*
* Log messages for a transfer run. If successful (at least 1 message), resets
* data_source.update_deadline_seconds timer.
*
*/
public com.google.protobuf.Empty logTransferRunMessages(
com.google.cloud.bigquery.datatransfer.v1.LogTransferRunMessagesRequest request) {
return blockingUnaryCall(
getChannel(), getLogTransferRunMessagesMethodHelper(), getCallOptions(), request);
}
/**
*
*
*
* Notify the Data Transfer Service that data is ready for loading.
* The Data Transfer Service will start and monitor multiple BigQuery Load
* jobs for a transfer run. Monitored jobs will be automatically retried
* and produce log messages when starting and finishing a job.
* Can be called multiple times for the same transfer run.
*
*/
public com.google.protobuf.Empty startBigQueryJobs(
com.google.cloud.bigquery.datatransfer.v1.StartBigQueryJobsRequest request) {
return blockingUnaryCall(
getChannel(), getStartBigQueryJobsMethodHelper(), getCallOptions(), request);
}
/**
*
*
*
* Notify the Data Transfer Service that the data source is done processing
* the run. No more status updates or requests to start/monitor jobs will be
* accepted. The run will be finalized by the Data Transfer Service when all
* monitored jobs are completed.
* Does not need to be called if the run is set to FAILED.
*
*/
public com.google.protobuf.Empty finishRun(
com.google.cloud.bigquery.datatransfer.v1.FinishRunRequest request) {
return blockingUnaryCall(getChannel(), getFinishRunMethodHelper(), getCallOptions(), request);
}
/**
*
*
*
* Creates a data source definition. Calling this method will automatically
* use your credentials to create the following Google Cloud resources in
* YOUR Google Cloud project.
* 1. OAuth client
* 2. Pub/Sub Topics and Subscriptions in each supported_location_ids. e.g.,
* projects/{project_id}/{topics|subscriptions}/bigquerydatatransfer.{data_source_id}.{location_id}.run
* The field data_source.client_id should be left empty in the input request,
* as the API will create a new OAuth client on behalf of the caller. On the
* other hand data_source.scopes usually need to be set when there are OAuth
* scopes that need to be granted by end users.
* 3. We need a longer deadline due to the 60 seconds SLO from Pub/Sub admin
* Operations. This also applies to update and delete data source definition.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.DataSourceDefinition
createDataSourceDefinition(
com.google.cloud.bigquery.datatransfer.v1.CreateDataSourceDefinitionRequest request) {
return blockingUnaryCall(
getChannel(), getCreateDataSourceDefinitionMethodHelper(), getCallOptions(), request);
}
/**
*
*
*
* Updates an existing data source definition. If changing
* supported_location_ids, triggers same effects as mentioned in "Create a
* data source definition."
*
*/
public com.google.cloud.bigquery.datatransfer.v1.DataSourceDefinition
updateDataSourceDefinition(
com.google.cloud.bigquery.datatransfer.v1.UpdateDataSourceDefinitionRequest request) {
return blockingUnaryCall(
getChannel(), getUpdateDataSourceDefinitionMethodHelper(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a data source definition, all of the transfer configs associated
* with this data source definition (if any) must be deleted first by the user
* in ALL regions, in order to delete the data source definition.
* This method is primarily meant for deleting data sources created during
* testing stage.
* If the data source is referenced by transfer configs in the region
* specified in the request URL, the method will fail immediately. If in the
* current region (e.g., US) it's not used by any transfer configs, but in
* another region (e.g., EU) it is, then although the method will succeed in
* region US, but it will fail when the deletion operation is replicated to
* region EU. And eventually, the system will replicate the data source
* definition back from EU to US, in order to bring all regions to
* consistency. The final effect is that the data source appears to be
* 'undeleted' in the US region.
*
*/
public com.google.protobuf.Empty deleteDataSourceDefinition(
com.google.cloud.bigquery.datatransfer.v1.DeleteDataSourceDefinitionRequest request) {
return blockingUnaryCall(
getChannel(), getDeleteDataSourceDefinitionMethodHelper(), getCallOptions(), request);
}
/**
*
*
*
* Retrieves an existing data source definition.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.DataSourceDefinition getDataSourceDefinition(
com.google.cloud.bigquery.datatransfer.v1.GetDataSourceDefinitionRequest request) {
return blockingUnaryCall(
getChannel(), getGetDataSourceDefinitionMethodHelper(), getCallOptions(), request);
}
/**
*
*
*
* Lists supported data source definitions.
*
*/
public com.google.cloud.bigquery.datatransfer.v1.ListDataSourceDefinitionsResponse
listDataSourceDefinitions(
com.google.cloud.bigquery.datatransfer.v1.ListDataSourceDefinitionsRequest request) {
return blockingUnaryCall(
getChannel(), getListDataSourceDefinitionsMethodHelper(), getCallOptions(), request);
}
}
/**
*
*
*
* The Google BigQuery Data Transfer API allows BigQuery users to
* configure transfer of their data from other Google Products into BigQuery.
* This service exposes methods that should be used by data source backend.
*
*/
public static final class DataSourceServiceFutureStub
extends io.grpc.stub.AbstractStub {
private DataSourceServiceFutureStub(io.grpc.Channel channel) {
super(channel);
}
private DataSourceServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected DataSourceServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new DataSourceServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Update a transfer run. If successful, resets
* data_source.update_deadline_seconds timer.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.TransferRun>
updateTransferRun(
com.google.cloud.bigquery.datatransfer.v1.UpdateTransferRunRequest request) {
return futureUnaryCall(
getChannel().newCall(getUpdateTransferRunMethodHelper(), getCallOptions()), request);
}
/**
*
*
*
* Log messages for a transfer run. If successful (at least 1 message), resets
* data_source.update_deadline_seconds timer.
*
*/
public com.google.common.util.concurrent.ListenableFuture
logTransferRunMessages(
com.google.cloud.bigquery.datatransfer.v1.LogTransferRunMessagesRequest request) {
return futureUnaryCall(
getChannel().newCall(getLogTransferRunMessagesMethodHelper(), getCallOptions()), request);
}
/**
*
*
*
* Notify the Data Transfer Service that data is ready for loading.
* The Data Transfer Service will start and monitor multiple BigQuery Load
* jobs for a transfer run. Monitored jobs will be automatically retried
* and produce log messages when starting and finishing a job.
* Can be called multiple times for the same transfer run.
*
*/
public com.google.common.util.concurrent.ListenableFuture
startBigQueryJobs(
com.google.cloud.bigquery.datatransfer.v1.StartBigQueryJobsRequest request) {
return futureUnaryCall(
getChannel().newCall(getStartBigQueryJobsMethodHelper(), getCallOptions()), request);
}
/**
*
*
*
* Notify the Data Transfer Service that the data source is done processing
* the run. No more status updates or requests to start/monitor jobs will be
* accepted. The run will be finalized by the Data Transfer Service when all
* monitored jobs are completed.
* Does not need to be called if the run is set to FAILED.
*
*/
public com.google.common.util.concurrent.ListenableFuture finishRun(
com.google.cloud.bigquery.datatransfer.v1.FinishRunRequest request) {
return futureUnaryCall(
getChannel().newCall(getFinishRunMethodHelper(), getCallOptions()), request);
}
/**
*
*
*
* Creates a data source definition. Calling this method will automatically
* use your credentials to create the following Google Cloud resources in
* YOUR Google Cloud project.
* 1. OAuth client
* 2. Pub/Sub Topics and Subscriptions in each supported_location_ids. e.g.,
* projects/{project_id}/{topics|subscriptions}/bigquerydatatransfer.{data_source_id}.{location_id}.run
* The field data_source.client_id should be left empty in the input request,
* as the API will create a new OAuth client on behalf of the caller. On the
* other hand data_source.scopes usually need to be set when there are OAuth
* scopes that need to be granted by end users.
* 3. We need a longer deadline due to the 60 seconds SLO from Pub/Sub admin
* Operations. This also applies to update and delete data source definition.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.DataSourceDefinition>
createDataSourceDefinition(
com.google.cloud.bigquery.datatransfer.v1.CreateDataSourceDefinitionRequest request) {
return futureUnaryCall(
getChannel().newCall(getCreateDataSourceDefinitionMethodHelper(), getCallOptions()),
request);
}
/**
*
*
*
* Updates an existing data source definition. If changing
* supported_location_ids, triggers same effects as mentioned in "Create a
* data source definition."
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.DataSourceDefinition>
updateDataSourceDefinition(
com.google.cloud.bigquery.datatransfer.v1.UpdateDataSourceDefinitionRequest request) {
return futureUnaryCall(
getChannel().newCall(getUpdateDataSourceDefinitionMethodHelper(), getCallOptions()),
request);
}
/**
*
*
*
* Deletes a data source definition, all of the transfer configs associated
* with this data source definition (if any) must be deleted first by the user
* in ALL regions, in order to delete the data source definition.
* This method is primarily meant for deleting data sources created during
* testing stage.
* If the data source is referenced by transfer configs in the region
* specified in the request URL, the method will fail immediately. If in the
* current region (e.g., US) it's not used by any transfer configs, but in
* another region (e.g., EU) it is, then although the method will succeed in
* region US, but it will fail when the deletion operation is replicated to
* region EU. And eventually, the system will replicate the data source
* definition back from EU to US, in order to bring all regions to
* consistency. The final effect is that the data source appears to be
* 'undeleted' in the US region.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteDataSourceDefinition(
com.google.cloud.bigquery.datatransfer.v1.DeleteDataSourceDefinitionRequest request) {
return futureUnaryCall(
getChannel().newCall(getDeleteDataSourceDefinitionMethodHelper(), getCallOptions()),
request);
}
/**
*
*
*
* Retrieves an existing data source definition.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.DataSourceDefinition>
getDataSourceDefinition(
com.google.cloud.bigquery.datatransfer.v1.GetDataSourceDefinitionRequest request) {
return futureUnaryCall(
getChannel().newCall(getGetDataSourceDefinitionMethodHelper(), getCallOptions()),
request);
}
/**
*
*
*
* Lists supported data source definitions.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.datatransfer.v1.ListDataSourceDefinitionsResponse>
listDataSourceDefinitions(
com.google.cloud.bigquery.datatransfer.v1.ListDataSourceDefinitionsRequest request) {
return futureUnaryCall(
getChannel().newCall(getListDataSourceDefinitionsMethodHelper(), getCallOptions()),
request);
}
}
private static final int METHODID_UPDATE_TRANSFER_RUN = 0;
private static final int METHODID_LOG_TRANSFER_RUN_MESSAGES = 1;
private static final int METHODID_START_BIG_QUERY_JOBS = 2;
private static final int METHODID_FINISH_RUN = 3;
private static final int METHODID_CREATE_DATA_SOURCE_DEFINITION = 4;
private static final int METHODID_UPDATE_DATA_SOURCE_DEFINITION = 5;
private static final int METHODID_DELETE_DATA_SOURCE_DEFINITION = 6;
private static final int METHODID_GET_DATA_SOURCE_DEFINITION = 7;
private static final int METHODID_LIST_DATA_SOURCE_DEFINITIONS = 8;
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 DataSourceServiceImplBase serviceImpl;
private final int methodId;
MethodHandlers(DataSourceServiceImplBase 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_UPDATE_TRANSFER_RUN:
serviceImpl.updateTransferRun(
(com.google.cloud.bigquery.datatransfer.v1.UpdateTransferRunRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LOG_TRANSFER_RUN_MESSAGES:
serviceImpl.logTransferRunMessages(
(com.google.cloud.bigquery.datatransfer.v1.LogTransferRunMessagesRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_START_BIG_QUERY_JOBS:
serviceImpl.startBigQueryJobs(
(com.google.cloud.bigquery.datatransfer.v1.StartBigQueryJobsRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_FINISH_RUN:
serviceImpl.finishRun(
(com.google.cloud.bigquery.datatransfer.v1.FinishRunRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_DATA_SOURCE_DEFINITION:
serviceImpl.createDataSourceDefinition(
(com.google.cloud.bigquery.datatransfer.v1.CreateDataSourceDefinitionRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.DataSourceDefinition>)
responseObserver);
break;
case METHODID_UPDATE_DATA_SOURCE_DEFINITION:
serviceImpl.updateDataSourceDefinition(
(com.google.cloud.bigquery.datatransfer.v1.UpdateDataSourceDefinitionRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.DataSourceDefinition>)
responseObserver);
break;
case METHODID_DELETE_DATA_SOURCE_DEFINITION:
serviceImpl.deleteDataSourceDefinition(
(com.google.cloud.bigquery.datatransfer.v1.DeleteDataSourceDefinitionRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_DATA_SOURCE_DEFINITION:
serviceImpl.getDataSourceDefinition(
(com.google.cloud.bigquery.datatransfer.v1.GetDataSourceDefinitionRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.DataSourceDefinition>)
responseObserver);
break;
case METHODID_LIST_DATA_SOURCE_DEFINITIONS:
serviceImpl.listDataSourceDefinitions(
(com.google.cloud.bigquery.datatransfer.v1.ListDataSourceDefinitionsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.datatransfer.v1.ListDataSourceDefinitionsResponse>)
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();
}
}
}
private abstract static class DataSourceServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
DataSourceServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.bigquery.datatransfer.v1.DataSourceProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("DataSourceService");
}
}
private static final class DataSourceServiceFileDescriptorSupplier
extends DataSourceServiceBaseDescriptorSupplier {
DataSourceServiceFileDescriptorSupplier() {}
}
private static final class DataSourceServiceMethodDescriptorSupplier
extends DataSourceServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
DataSourceServiceMethodDescriptorSupplier(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 (DataSourceServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new DataSourceServiceFileDescriptorSupplier())
.addMethod(getUpdateTransferRunMethodHelper())
.addMethod(getLogTransferRunMessagesMethodHelper())
.addMethod(getStartBigQueryJobsMethodHelper())
.addMethod(getFinishRunMethodHelper())
.addMethod(getCreateDataSourceDefinitionMethodHelper())
.addMethod(getUpdateDataSourceDefinitionMethodHelper())
.addMethod(getDeleteDataSourceDefinitionMethodHelper())
.addMethod(getGetDataSourceDefinitionMethodHelper())
.addMethod(getListDataSourceDefinitionsMethodHelper())
.build();
}
}
}
return result;
}
}