Skip to content

Commit 8363070

Browse files
andreamlinandrey-qlogic
andreamlin
authored and
andrey-qlogic
committed
---
yaml --- r: 24187 b: refs/heads/autosynth-language c: 08ca27f h: refs/heads/master i: 24185: ebcff46 24183: c071b1f
1 parent 86f5da7 commit 8363070

3 files changed

Lines changed: 49 additions & 14 deletions

File tree

‎[refs]‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ refs/heads/autosynth-errorreporting: 3f176c20b55dfaaa8fc32f28d82b31784b93e636
133133
refs/heads/autosynth-firestore: d48d82caace227856b6cd85ac30ee474528733ea
134134
refs/heads/autosynth-iot: 4025d1804241e74d54950a324dc4f667aeaad4b3
135135
refs/heads/autosynth-kms: 6b65b0f34c12d141031c7288cdc01e550212d0f6
136-
refs/heads/autosynth-language: 704c84ab979bbe616c807e26556f05e0673abe67
136+
refs/heads/autosynth-language: 08ca27f68f532c7ee9dcd1675a3c1f59fd6e3493
137137
refs/heads/autosynth-os-login: 092fdbed6d5317948f92b708e9f50dedd89fc666
138138
refs/heads/autosynth-redis: 9e1fe503973c7b4a9ba26afb1fcddc2a57ba795a
139139
refs/heads/autosynth-scheduler: 93995812e12a2fc009f4fd2e31f169b3d3cbbac8

‎branches/autosynth-language/google-cloud-clients/google-cloud-redis/src/main/java/com/google/cloud/redis/v1/CloudRedisClient.java‎

Lines changed: 43 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -984,9 +984,44 @@ public final UnaryCallable<DeleteInstanceRequest, Operation> deleteInstanceCalla
984984
*
985985
* <pre><code>
986986
* try (CloudRedisClient cloudRedisClient = CloudRedisClient.create()) {
987-
* String formattedName = InstanceName.format("[PROJECT]", "[LOCATION]", "[INSTANCE]");
987+
* InstanceName name = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
988988
* FailoverInstanceRequest.DataProtectionMode dataProtectionMode = FailoverInstanceRequest.DataProtectionMode.DATA_PROTECTION_MODE_UNSPECIFIED;
989-
* Instance response = cloudRedisClient.failoverInstanceAsync(formattedName, dataProtectionMode).get();
989+
* Instance response = cloudRedisClient.failoverInstanceAsync(name, dataProtectionMode).get();
990+
* }
991+
* </code></pre>
992+
*
993+
* @param name Required. Redis instance resource name using the form:
994+
* `projects/{project_id}/locations/{location_id}/instances/{instance_id}` where `location_id`
995+
* refers to a GCP region
996+
* @param dataProtectionMode Optional. Available data protection modes that the user can choose.
997+
* If it's unspecified, data protection mode will be LIMITED_DATA_LOSS by default.
998+
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
999+
*/
1000+
@BetaApi(
1001+
"The surface for long-running operations is not stable yet and may change in the future.")
1002+
public final OperationFuture<Instance, OperationMetadata> failoverInstanceAsync(
1003+
InstanceName name, FailoverInstanceRequest.DataProtectionMode dataProtectionMode) {
1004+
1005+
FailoverInstanceRequest request =
1006+
FailoverInstanceRequest.newBuilder()
1007+
.setName(name == null ? null : name.toString())
1008+
.setDataProtectionMode(dataProtectionMode)
1009+
.build();
1010+
return failoverInstanceAsync(request);
1011+
}
1012+
1013+
// AUTO-GENERATED DOCUMENTATION AND METHOD
1014+
/**
1015+
* Failover the master role to current replica node against a specific STANDARD tier redis
1016+
* instance.
1017+
*
1018+
* <p>Sample code:
1019+
*
1020+
* <pre><code>
1021+
* try (CloudRedisClient cloudRedisClient = CloudRedisClient.create()) {
1022+
* InstanceName name = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
1023+
* FailoverInstanceRequest.DataProtectionMode dataProtectionMode = FailoverInstanceRequest.DataProtectionMode.DATA_PROTECTION_MODE_UNSPECIFIED;
1024+
* Instance response = cloudRedisClient.failoverInstanceAsync(name.toString(), dataProtectionMode).get();
9901025
* }
9911026
* </code></pre>
9921027
*
@@ -1019,10 +1054,10 @@ public final OperationFuture<Instance, OperationMetadata> failoverInstanceAsync(
10191054
*
10201055
* <pre><code>
10211056
* try (CloudRedisClient cloudRedisClient = CloudRedisClient.create()) {
1022-
* String formattedName = InstanceName.format("[PROJECT]", "[LOCATION]", "[INSTANCE]");
1057+
* InstanceName name = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
10231058
* FailoverInstanceRequest.DataProtectionMode dataProtectionMode = FailoverInstanceRequest.DataProtectionMode.DATA_PROTECTION_MODE_UNSPECIFIED;
10241059
* FailoverInstanceRequest request = FailoverInstanceRequest.newBuilder()
1025-
* .setName(formattedName)
1060+
* .setName(name.toString())
10261061
* .setDataProtectionMode(dataProtectionMode)
10271062
* .build();
10281063
* Instance response = cloudRedisClient.failoverInstanceAsync(request).get();
@@ -1048,10 +1083,10 @@ public final OperationFuture<Instance, OperationMetadata> failoverInstanceAsync(
10481083
*
10491084
* <pre><code>
10501085
* try (CloudRedisClient cloudRedisClient = CloudRedisClient.create()) {
1051-
* String formattedName = InstanceName.format("[PROJECT]", "[LOCATION]", "[INSTANCE]");
1086+
* InstanceName name = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
10521087
* FailoverInstanceRequest.DataProtectionMode dataProtectionMode = FailoverInstanceRequest.DataProtectionMode.DATA_PROTECTION_MODE_UNSPECIFIED;
10531088
* FailoverInstanceRequest request = FailoverInstanceRequest.newBuilder()
1054-
* .setName(formattedName)
1089+
* .setName(name.toString())
10551090
* .setDataProtectionMode(dataProtectionMode)
10561091
* .build();
10571092
* OperationFuture&lt;Instance, OperationMetadata&gt; future = cloudRedisClient.failoverInstanceOperationCallable().futureCall(request);
@@ -1075,10 +1110,10 @@ public final OperationFuture<Instance, OperationMetadata> failoverInstanceAsync(
10751110
*
10761111
* <pre><code>
10771112
* try (CloudRedisClient cloudRedisClient = CloudRedisClient.create()) {
1078-
* String formattedName = InstanceName.format("[PROJECT]", "[LOCATION]", "[INSTANCE]");
1113+
* InstanceName name = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
10791114
* FailoverInstanceRequest.DataProtectionMode dataProtectionMode = FailoverInstanceRequest.DataProtectionMode.DATA_PROTECTION_MODE_UNSPECIFIED;
10801115
* FailoverInstanceRequest request = FailoverInstanceRequest.newBuilder()
1081-
* .setName(formattedName)
1116+
* .setName(name.toString())
10821117
* .setDataProtectionMode(dataProtectionMode)
10831118
* .build();
10841119
* ApiFuture&lt;Operation&gt; future = cloudRedisClient.failoverInstanceCallable().futureCall(request);

‎branches/autosynth-language/google-cloud-clients/google-cloud-redis/src/test/java/com/google/cloud/redis/v1/CloudRedisClientTest.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -446,18 +446,18 @@ public void failoverInstanceTest() throws Exception {
446446
.build();
447447
mockCloudRedis.addResponse(resultOperation);
448448

449-
String formattedName = InstanceName.format("[PROJECT]", "[LOCATION]", "[INSTANCE]");
449+
InstanceName name = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
450450
FailoverInstanceRequest.DataProtectionMode dataProtectionMode =
451451
FailoverInstanceRequest.DataProtectionMode.DATA_PROTECTION_MODE_UNSPECIFIED;
452452

453-
Instance actualResponse = client.failoverInstanceAsync(formattedName, dataProtectionMode).get();
453+
Instance actualResponse = client.failoverInstanceAsync(name, dataProtectionMode).get();
454454
Assert.assertEquals(expectedResponse, actualResponse);
455455

456456
List<GeneratedMessageV3> actualRequests = mockCloudRedis.getRequests();
457457
Assert.assertEquals(1, actualRequests.size());
458458
FailoverInstanceRequest actualRequest = (FailoverInstanceRequest) actualRequests.get(0);
459459

460-
Assert.assertEquals(formattedName, actualRequest.getName());
460+
Assert.assertEquals(name, InstanceName.parse(actualRequest.getName()));
461461
Assert.assertEquals(dataProtectionMode, actualRequest.getDataProtectionMode());
462462
Assert.assertTrue(
463463
channelProvider.isHeaderSent(
@@ -472,11 +472,11 @@ public void failoverInstanceExceptionTest() throws Exception {
472472
mockCloudRedis.addException(exception);
473473

474474
try {
475-
String formattedName = InstanceName.format("[PROJECT]", "[LOCATION]", "[INSTANCE]");
475+
InstanceName name = InstanceName.of("[PROJECT]", "[LOCATION]", "[INSTANCE]");
476476
FailoverInstanceRequest.DataProtectionMode dataProtectionMode =
477477
FailoverInstanceRequest.DataProtectionMode.DATA_PROTECTION_MODE_UNSPECIFIED;
478478

479-
client.failoverInstanceAsync(formattedName, dataProtectionMode).get();
479+
client.failoverInstanceAsync(name, dataProtectionMode).get();
480480
Assert.fail("No exception raised");
481481
} catch (ExecutionException e) {
482482
Assert.assertEquals(InvalidArgumentException.class, e.getCause().getClass());

0 commit comments

Comments
 (0)