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

Commit

Permalink
fix(datastream): Change a few resource pattern variables from camelCa…
Browse files Browse the repository at this point in the history 
…se to snake_case (#47)

- [ ] Regenerate this pull request now.

PiperOrigin-RevId: 393705818

Source-Link: googleapis/googleapis@9e99074

Source-Link: https://github.com/googleapis/googleapis-gen/commit/1eee1fcf28b8d8557bd8358d00181ebefffc4a7d
  • Loading branch information
@gcf-owl-bot
gcf-owl-bot[bot] authored Sep 10, 2021
1 parent 6e58596 commit d5f2e39
Showing 9 changed files with 299 additions and 291 deletions.
112 changes: 56 additions & 56 deletions ...cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamClient.java
View file

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/package-info.java
View file
Original file line number Diff line number Diff line change
@@ -26,7 +26,7 @@
* <pre>{@code
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ConnectionProfileName name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]");
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
* ConnectionProfile response = datastreamClient.getConnectionProfile(name);
* }
* }</pre>
4 changes: 3 additions & 1 deletion ...tream/src/main/java/com/google/cloud/datastream/v1alpha1/stub/DatastreamStubSettings.java
View file
Original file line number Diff line number Diff line change
@@ -723,7 +723,9 @@ public static List<String> getDefaultServiceScopes() {

/** Returns a builder for the default credentials for this service. */
public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilder() {
return GoogleCredentialsProvider.newBuilder().setScopesToApply(DEFAULT_SERVICE_SCOPES);
return GoogleCredentialsProvider.newBuilder()
.setScopesToApply(DEFAULT_SERVICE_SCOPES)
.setUseJwtAccessWithScope(true);
}

/** Returns a builder for the default ChannelProvider for this service. */
62 changes: 31 additions & 31 deletions ...d-datastream/src/test/java/com/google/cloud/datastream/v1alpha1/DatastreamClientTest.java
View file
Original file line number Diff line number Diff line change
@@ -186,7 +186,7 @@ public void getConnectionProfileTest() throws Exception {
ConnectionProfile expectedResponse =
ConnectionProfile.newBuilder()
.setName(
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]")
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -196,7 +196,7 @@ public void getConnectionProfileTest() throws Exception {
mockDatastream.addResponse(expectedResponse);

ConnectionProfileName name =
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]");
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");

ConnectionProfile actualResponse = client.getConnectionProfile(name);
Assert.assertEquals(expectedResponse, actualResponse);
@@ -220,7 +220,7 @@ public void getConnectionProfileExceptionTest() throws Exception {

try {
ConnectionProfileName name =
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]");
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
client.getConnectionProfile(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
@@ -233,7 +233,7 @@ public void getConnectionProfileTest2() throws Exception {
ConnectionProfile expectedResponse =
ConnectionProfile.newBuilder()
.setName(
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]")
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -278,7 +278,7 @@ public void createConnectionProfileTest() throws Exception {
ConnectionProfile expectedResponse =
ConnectionProfile.newBuilder()
.setName(
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]")
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -338,7 +338,7 @@ public void createConnectionProfileTest2() throws Exception {
ConnectionProfile expectedResponse =
ConnectionProfile.newBuilder()
.setName(
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]")
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -398,7 +398,7 @@ public void updateConnectionProfileTest() throws Exception {
ConnectionProfile expectedResponse =
ConnectionProfile.newBuilder()
.setName(
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]")
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -462,7 +462,7 @@ public void deleteConnectionProfileTest() throws Exception {
mockDatastream.addResponse(resultOperation);

ConnectionProfileName name =
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]");
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");

client.deleteConnectionProfileAsync(name).get();

@@ -485,7 +485,7 @@ public void deleteConnectionProfileExceptionTest() throws Exception {

try {
ConnectionProfileName name =
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]");
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
client.deleteConnectionProfileAsync(name).get();
Assert.fail("No exception raised");
} catch (ExecutionException e) {
@@ -547,7 +547,7 @@ public void discoverConnectionProfileTest() throws Exception {
DiscoverConnectionProfileRequest request =
DiscoverConnectionProfileRequest.newBuilder()
.setParent(
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]")
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]")
.toString())
.build();

@@ -582,7 +582,7 @@ public void discoverConnectionProfileExceptionTest() throws Exception {
DiscoverConnectionProfileRequest request =
DiscoverConnectionProfileRequest.newBuilder()
.setParent(
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTIONPROFILE]")
ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]")
.toString())
.build();
client.discoverConnectionProfile(request);
@@ -1171,7 +1171,7 @@ public void createPrivateConnectionTest() throws Exception {
PrivateConnection expectedResponse =
PrivateConnection.newBuilder()
.setName(
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]")
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -1233,7 +1233,7 @@ public void createPrivateConnectionTest2() throws Exception {
PrivateConnection expectedResponse =
PrivateConnection.newBuilder()
.setName(
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]")
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -1295,7 +1295,7 @@ public void getPrivateConnectionTest() throws Exception {
PrivateConnection expectedResponse =
PrivateConnection.newBuilder()
.setName(
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]")
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -1307,7 +1307,7 @@ public void getPrivateConnectionTest() throws Exception {
mockDatastream.addResponse(expectedResponse);

PrivateConnectionName name =
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]");
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");

PrivateConnection actualResponse = client.getPrivateConnection(name);
Assert.assertEquals(expectedResponse, actualResponse);
@@ -1331,7 +1331,7 @@ public void getPrivateConnectionExceptionTest() throws Exception {

try {
PrivateConnectionName name =
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]");
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
client.getPrivateConnection(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
@@ -1344,7 +1344,7 @@ public void getPrivateConnectionTest2() throws Exception {
PrivateConnection expectedResponse =
PrivateConnection.newBuilder()
.setName(
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]")
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -1488,7 +1488,7 @@ public void deletePrivateConnectionTest() throws Exception {
mockDatastream.addResponse(resultOperation);

PrivateConnectionName name =
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]");
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");

client.deletePrivateConnectionAsync(name).get();

@@ -1511,7 +1511,7 @@ public void deletePrivateConnectionExceptionTest() throws Exception {

try {
PrivateConnectionName name =
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]");
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
client.deletePrivateConnectionAsync(name).get();
Assert.fail("No exception raised");
} catch (ExecutionException e) {
@@ -1569,7 +1569,7 @@ public void createRouteTest() throws Exception {
Route expectedResponse =
Route.newBuilder()
.setName(
RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]", "[ROUTE]")
RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -1587,7 +1587,7 @@ public void createRouteTest() throws Exception {
mockDatastream.addResponse(resultOperation);

PrivateConnectionName parent =
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]");
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
Route route = Route.newBuilder().build();
String routeId = "routeId1385647428";

@@ -1614,7 +1614,7 @@ public void createRouteExceptionTest() throws Exception {

try {
PrivateConnectionName parent =
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]");
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
Route route = Route.newBuilder().build();
String routeId = "routeId1385647428";
client.createRouteAsync(parent, route, routeId).get();
@@ -1631,7 +1631,7 @@ public void createRouteTest2() throws Exception {
Route expectedResponse =
Route.newBuilder()
.setName(
RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]", "[ROUTE]")
RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -1691,7 +1691,7 @@ public void getRouteTest() throws Exception {
Route expectedResponse =
Route.newBuilder()
.setName(
RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]", "[ROUTE]")
RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -1702,7 +1702,7 @@ public void getRouteTest() throws Exception {
.build();
mockDatastream.addResponse(expectedResponse);

RouteName name = RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]", "[ROUTE]");
RouteName name = RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");

Route actualResponse = client.getRoute(name);
Assert.assertEquals(expectedResponse, actualResponse);
@@ -1724,7 +1724,7 @@ public void getRouteExceptionTest() throws Exception {
mockDatastream.addException(exception);

try {
RouteName name = RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]", "[ROUTE]");
RouteName name = RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
client.getRoute(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
@@ -1737,7 +1737,7 @@ public void getRouteTest2() throws Exception {
Route expectedResponse =
Route.newBuilder()
.setName(
RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]", "[ROUTE]")
RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]")
.toString())
.setCreateTime(Timestamp.newBuilder().build())
.setUpdateTime(Timestamp.newBuilder().build())
@@ -1789,7 +1789,7 @@ public void listRoutesTest() throws Exception {
mockDatastream.addResponse(expectedResponse);

PrivateConnectionName parent =
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]");
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");

ListRoutesPagedResponse pagedListResponse = client.listRoutes(parent);

@@ -1816,7 +1816,7 @@ public void listRoutesExceptionTest() throws Exception {

try {
PrivateConnectionName parent =
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]");
PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
client.listRoutes(parent);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
@@ -1879,7 +1879,7 @@ public void deleteRouteTest() throws Exception {
.build();
mockDatastream.addResponse(resultOperation);

RouteName name = RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]", "[ROUTE]");
RouteName name = RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");

client.deleteRouteAsync(name).get();

@@ -1900,7 +1900,7 @@ public void deleteRouteExceptionTest() throws Exception {
mockDatastream.addException(exception);

try {
RouteName name = RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATECONNECTION]", "[ROUTE]");
RouteName name = RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
client.deleteRouteAsync(name).get();
Assert.fail("No exception raised");
} catch (ExecutionException e) {
Loading

0 comments on commit d5f2e39

Please sign in to comment.