Skip to content
This repository has been archived by the owner on Sep 27, 2023. It is now read-only.

Commit

Permalink
chore: update gapic-generator-java to 0.0.20 (#638)
Browse files Browse the repository at this point in the history 
Committer: @miraleung
PiperOrigin-RevId: 357800868

Source-Author: Google APIs <noreply@google.com>
Source-Date: Tue Feb 16 14:06:04 2021 -0800
Source-Repo: googleapis/googleapis
Source-Sha: e8bc4471a88ac5f60defe3ed436f517174e59ba0
Source-Link: googleapis/googleapis@e8bc447
  • Loading branch information
@yoshi-automation
yoshi-automation committed Feb 17, 2021
1 parent d05ad82 commit a2e5630
Show file tree
Hide file tree
Showing 4 changed files with 129 additions and 17 deletions.
18 changes: 18 additions & 0 deletions ...main/java/com/google/cloud/bigquery/datatransfer/v1/stub/GrpcDataTransferServiceStub.java
View file
Expand Up @@ -585,83 +585,101 @@ public GrpcOperationsStub getOperationsStub() {
return operationsStub;
}

@Override
public UnaryCallable<GetDataSourceRequest, DataSource> getDataSourceCallable() {
return getDataSourceCallable;
}

@Override
public UnaryCallable<ListDataSourcesRequest, ListDataSourcesResponse> listDataSourcesCallable() {
return listDataSourcesCallable;
}

@Override
public UnaryCallable<ListDataSourcesRequest, ListDataSourcesPagedResponse>
listDataSourcesPagedCallable() {
return listDataSourcesPagedCallable;
}

@Override
public UnaryCallable<CreateTransferConfigRequest, TransferConfig> createTransferConfigCallable() {
return createTransferConfigCallable;
}

@Override
public UnaryCallable<UpdateTransferConfigRequest, TransferConfig> updateTransferConfigCallable() {
return updateTransferConfigCallable;
}

@Override
public UnaryCallable<DeleteTransferConfigRequest, Empty> deleteTransferConfigCallable() {
return deleteTransferConfigCallable;
}

@Override
public UnaryCallable<GetTransferConfigRequest, TransferConfig> getTransferConfigCallable() {
return getTransferConfigCallable;
}

@Override
public UnaryCallable<ListTransferConfigsRequest, ListTransferConfigsResponse>
listTransferConfigsCallable() {
return listTransferConfigsCallable;
}

@Override
public UnaryCallable<ListTransferConfigsRequest, ListTransferConfigsPagedResponse>
listTransferConfigsPagedCallable() {
return listTransferConfigsPagedCallable;
}

@Override
public UnaryCallable<ScheduleTransferRunsRequest, ScheduleTransferRunsResponse>
scheduleTransferRunsCallable() {
return scheduleTransferRunsCallable;
}

@Override
public UnaryCallable<StartManualTransferRunsRequest, StartManualTransferRunsResponse>
startManualTransferRunsCallable() {
return startManualTransferRunsCallable;
}

@Override
public UnaryCallable<GetTransferRunRequest, TransferRun> getTransferRunCallable() {
return getTransferRunCallable;
}

@Override
public UnaryCallable<DeleteTransferRunRequest, Empty> deleteTransferRunCallable() {
return deleteTransferRunCallable;
}

@Override
public UnaryCallable<ListTransferRunsRequest, ListTransferRunsResponse>
listTransferRunsCallable() {
return listTransferRunsCallable;
}

@Override
public UnaryCallable<ListTransferRunsRequest, ListTransferRunsPagedResponse>
listTransferRunsPagedCallable() {
return listTransferRunsPagedCallable;
}

@Override
public UnaryCallable<ListTransferLogsRequest, ListTransferLogsResponse>
listTransferLogsCallable() {
return listTransferLogsCallable;
}

@Override
public UnaryCallable<ListTransferLogsRequest, ListTransferLogsPagedResponse>
listTransferLogsPagedCallable() {
return listTransferLogsPagedCallable;
}

@Override
public UnaryCallable<CheckValidCredsRequest, CheckValidCredsResponse> checkValidCredsCallable() {
return checkValidCredsCallable;
}
Expand Down
10 changes: 10 additions & 0 deletions ...rc/test/java/com/google/cloud/bigquery/datatransfer/v1/DataTransferServiceClientTest.java
View file
Expand Up @@ -99,6 +99,7 @@ public void getDataSourceTest() throws Exception {
.setDescription("description-1724546052")
.setClientId("clientId908408390")
.addAllScopes(new ArrayList<String>())
.setTransferType(TransferType.forNumber(0))
.setSupportsMultipleTransfers(true)
.setUpdateDeadlineSeconds(991471694)
.setDefaultSchedule("defaultSchedule1300167672")
Expand Down Expand Up @@ -152,6 +153,7 @@ public void getDataSourceTest2() throws Exception {
.setDescription("description-1724546052")
.setClientId("clientId908408390")
.addAllScopes(new ArrayList<String>())
.setTransferType(TransferType.forNumber(0))
.setSupportsMultipleTransfers(true)
.setUpdateDeadlineSeconds(991471694)
.setDefaultSchedule("defaultSchedule1300167672")
Expand Down Expand Up @@ -342,6 +344,7 @@ public void createTransferConfigTest() throws Exception {
.setDisabled(true)
.setUpdateTime(Timestamp.newBuilder().build())
.setNextRunTime(Timestamp.newBuilder().build())
.setState(TransferState.forNumber(0))
.setUserId(-147132913)
.setDatasetRegion("datasetRegion1032293772")
.setNotificationPubsubTopic("notificationPubsubTopic-1361224991")
Expand Down Expand Up @@ -399,6 +402,7 @@ public void createTransferConfigTest2() throws Exception {
.setDisabled(true)
.setUpdateTime(Timestamp.newBuilder().build())
.setNextRunTime(Timestamp.newBuilder().build())
.setState(TransferState.forNumber(0))
.setUserId(-147132913)
.setDatasetRegion("datasetRegion1032293772")
.setNotificationPubsubTopic("notificationPubsubTopic-1361224991")
Expand Down Expand Up @@ -456,6 +460,7 @@ public void createTransferConfigTest3() throws Exception {
.setDisabled(true)
.setUpdateTime(Timestamp.newBuilder().build())
.setNextRunTime(Timestamp.newBuilder().build())
.setState(TransferState.forNumber(0))
.setUserId(-147132913)
.setDatasetRegion("datasetRegion1032293772")
.setNotificationPubsubTopic("notificationPubsubTopic-1361224991")
Expand Down Expand Up @@ -513,6 +518,7 @@ public void updateTransferConfigTest() throws Exception {
.setDisabled(true)
.setUpdateTime(Timestamp.newBuilder().build())
.setNextRunTime(Timestamp.newBuilder().build())
.setState(TransferState.forNumber(0))
.setUserId(-147132913)
.setDatasetRegion("datasetRegion1032293772")
.setNotificationPubsubTopic("notificationPubsubTopic-1361224991")
Expand Down Expand Up @@ -642,6 +648,7 @@ public void getTransferConfigTest() throws Exception {
.setDisabled(true)
.setUpdateTime(Timestamp.newBuilder().build())
.setNextRunTime(Timestamp.newBuilder().build())
.setState(TransferState.forNumber(0))
.setUserId(-147132913)
.setDatasetRegion("datasetRegion1032293772")
.setNotificationPubsubTopic("notificationPubsubTopic-1361224991")
Expand Down Expand Up @@ -697,6 +704,7 @@ public void getTransferConfigTest2() throws Exception {
.setDisabled(true)
.setUpdateTime(Timestamp.newBuilder().build())
.setNextRunTime(Timestamp.newBuilder().build())
.setState(TransferState.forNumber(0))
.setUserId(-147132913)
.setDatasetRegion("datasetRegion1032293772")
.setNotificationPubsubTopic("notificationPubsubTopic-1361224991")
Expand Down Expand Up @@ -1022,6 +1030,7 @@ public void getTransferRunTest() throws Exception {
.setUpdateTime(Timestamp.newBuilder().build())
.setParams(Struct.newBuilder().build())
.setDataSourceId("dataSourceId-1221402528")
.setState(TransferState.forNumber(0))
.setUserId(-147132913)
.setSchedule("schedule-697920873")
.setNotificationPubsubTopic("notificationPubsubTopic-1361224991")
Expand Down Expand Up @@ -1076,6 +1085,7 @@ public void getTransferRunTest2() throws Exception {
.setUpdateTime(Timestamp.newBuilder().build())
.setParams(Struct.newBuilder().build())
.setDataSourceId("dataSourceId-1221402528")
.setState(TransferState.forNumber(0))
.setUserId(-147132913)
.setSchedule("schedule-697920873")
.setNotificationPubsubTopic("notificationPubsubTopic-1361224991")
Expand Down
112 changes: 98 additions & 14 deletions .../src/test/java/com/google/cloud/bigquery/datatransfer/v1/MockDataTransferServiceImpl.java
View file
Expand Up @@ -70,7 +70,13 @@ public void getDataSource(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetDataSource, expected %s or %s",
response.getClass().getName(),
DataSource.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -85,7 +91,13 @@ public void listDataSources(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListDataSources, expected %s or %s",
response.getClass().getName(),
ListDataSourcesResponse.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -100,7 +112,13 @@ public void createTransferConfig(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateTransferConfig, expected %s or %s",
response.getClass().getName(),
TransferConfig.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -115,7 +133,13 @@ public void updateTransferConfig(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method UpdateTransferConfig, expected %s or %s",
response.getClass().getName(),
TransferConfig.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -130,7 +154,13 @@ public void deleteTransferConfig(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteTransferConfig, expected %s or %s",
response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -145,7 +175,13 @@ public void getTransferConfig(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetTransferConfig, expected %s or %s",
response.getClass().getName(),
TransferConfig.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -161,7 +197,13 @@ public void listTransferConfigs(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListTransferConfigs, expected %s or %s",
response.getClass().getName(),
ListTransferConfigsResponse.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -177,7 +219,13 @@ public void scheduleTransferRuns(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ScheduleTransferRuns, expected %s or %s",
response.getClass().getName(),
ScheduleTransferRunsResponse.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -193,7 +241,13 @@ public void startManualTransferRuns(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method StartManualTransferRuns, expected %s or %s",
response.getClass().getName(),
StartManualTransferRunsResponse.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -208,7 +262,13 @@ public void getTransferRun(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetTransferRun, expected %s or %s",
response.getClass().getName(),
TransferRun.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -223,7 +283,13 @@ public void deleteTransferRun(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteTransferRun, expected %s or %s",
response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -238,7 +304,13 @@ public void listTransferRuns(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListTransferRuns, expected %s or %s",
response.getClass().getName(),
ListTransferRunsResponse.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -253,7 +325,13 @@ public void listTransferLogs(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListTransferLogs, expected %s or %s",
response.getClass().getName(),
ListTransferLogsResponse.class.getName(),
Exception.class.getName())));
}
}

Expand All @@ -268,7 +346,13 @@ public void checkValidCreds(
} else if (response instanceof Exception) {
responseObserver.onError(((Exception) response));
} else {
responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
responseObserver.onError(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CheckValidCreds, expected %s or %s",
response.getClass().getName(),
CheckValidCredsResponse.class.getName(),
Exception.class.getName())));
}
}
}

0 comments on commit a2e5630

Please sign in to comment.