1 /* 2 * Copyright 2022 Google LLC 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * https://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17 package com.google.cloud.container.v1; 18 19 import static com.google.cloud.container.v1.ClusterManagerClient.ListUsableSubnetworksPagedResponse; 20 21 import com.google.api.gax.core.NoCredentialsProvider; 22 import com.google.api.gax.grpc.GaxGrpcProperties; 23 import com.google.api.gax.grpc.testing.LocalChannelProvider; 24 import com.google.api.gax.grpc.testing.MockGrpcService; 25 import com.google.api.gax.grpc.testing.MockServiceHelper; 26 import com.google.api.gax.rpc.ApiClientHeaderProvider; 27 import com.google.api.gax.rpc.InvalidArgumentException; 28 import com.google.common.collect.Lists; 29 import com.google.container.v1.AddonsConfig; 30 import com.google.container.v1.AuthenticatorGroupsConfig; 31 import com.google.container.v1.Autopilot; 32 import com.google.container.v1.BinaryAuthorization; 33 import com.google.container.v1.CancelOperationRequest; 34 import com.google.container.v1.Cluster; 35 import com.google.container.v1.ClusterAutoscaling; 36 import com.google.container.v1.ClusterUpdate; 37 import com.google.container.v1.CompleteIPRotationRequest; 38 import com.google.container.v1.CompleteNodePoolUpgradeRequest; 39 import com.google.container.v1.ConfidentialNodes; 40 import com.google.container.v1.CostManagementConfig; 41 import com.google.container.v1.CreateClusterRequest; 42 import com.google.container.v1.CreateNodePoolRequest; 43 import com.google.container.v1.DatabaseEncryption; 44 import com.google.container.v1.DeleteClusterRequest; 45 import com.google.container.v1.DeleteNodePoolRequest; 46 import com.google.container.v1.FastSocket; 47 import com.google.container.v1.Fleet; 48 import com.google.container.v1.GcfsConfig; 49 import com.google.container.v1.GetClusterRequest; 50 import com.google.container.v1.GetJSONWebKeysRequest; 51 import com.google.container.v1.GetJSONWebKeysResponse; 52 import com.google.container.v1.GetNodePoolRequest; 53 import com.google.container.v1.GetOperationRequest; 54 import com.google.container.v1.GetServerConfigRequest; 55 import com.google.container.v1.IPAllocationPolicy; 56 import com.google.container.v1.IdentityServiceConfig; 57 import com.google.container.v1.Jwk; 58 import com.google.container.v1.LegacyAbac; 59 import com.google.container.v1.LinuxNodeConfig; 60 import com.google.container.v1.ListClustersRequest; 61 import com.google.container.v1.ListClustersResponse; 62 import com.google.container.v1.ListNodePoolsRequest; 63 import com.google.container.v1.ListNodePoolsResponse; 64 import com.google.container.v1.ListOperationsRequest; 65 import com.google.container.v1.ListOperationsResponse; 66 import com.google.container.v1.ListUsableSubnetworksRequest; 67 import com.google.container.v1.ListUsableSubnetworksResponse; 68 import com.google.container.v1.LoggingConfig; 69 import com.google.container.v1.MaintenancePolicy; 70 import com.google.container.v1.MasterAuth; 71 import com.google.container.v1.MasterAuthorizedNetworksConfig; 72 import com.google.container.v1.MaxPodsConstraint; 73 import com.google.container.v1.MeshCertificates; 74 import com.google.container.v1.MonitoringConfig; 75 import com.google.container.v1.NetworkConfig; 76 import com.google.container.v1.NetworkPolicy; 77 import com.google.container.v1.NetworkTags; 78 import com.google.container.v1.NodeConfig; 79 import com.google.container.v1.NodeKubeletConfig; 80 import com.google.container.v1.NodeLabels; 81 import com.google.container.v1.NodeManagement; 82 import com.google.container.v1.NodeNetworkConfig; 83 import com.google.container.v1.NodePool; 84 import com.google.container.v1.NodePoolAutoConfig; 85 import com.google.container.v1.NodePoolAutoscaling; 86 import com.google.container.v1.NodePoolDefaults; 87 import com.google.container.v1.NodePoolLoggingConfig; 88 import com.google.container.v1.NodeTaints; 89 import com.google.container.v1.NotificationConfig; 90 import com.google.container.v1.Operation; 91 import com.google.container.v1.OperationProgress; 92 import com.google.container.v1.PrivateClusterConfig; 93 import com.google.container.v1.ReleaseChannel; 94 import com.google.container.v1.ResourceLabels; 95 import com.google.container.v1.ResourceUsageExportConfig; 96 import com.google.container.v1.RollbackNodePoolUpgradeRequest; 97 import com.google.container.v1.ServerConfig; 98 import com.google.container.v1.SetAddonsConfigRequest; 99 import com.google.container.v1.SetLabelsRequest; 100 import com.google.container.v1.SetLegacyAbacRequest; 101 import com.google.container.v1.SetLocationsRequest; 102 import com.google.container.v1.SetLoggingServiceRequest; 103 import com.google.container.v1.SetMaintenancePolicyRequest; 104 import com.google.container.v1.SetMasterAuthRequest; 105 import com.google.container.v1.SetMonitoringServiceRequest; 106 import com.google.container.v1.SetNetworkPolicyRequest; 107 import com.google.container.v1.SetNodePoolAutoscalingRequest; 108 import com.google.container.v1.SetNodePoolManagementRequest; 109 import com.google.container.v1.SetNodePoolSizeRequest; 110 import com.google.container.v1.ShieldedNodes; 111 import com.google.container.v1.StartIPRotationRequest; 112 import com.google.container.v1.StatusCondition; 113 import com.google.container.v1.UpdateClusterRequest; 114 import com.google.container.v1.UpdateMasterRequest; 115 import com.google.container.v1.UpdateNodePoolRequest; 116 import com.google.container.v1.UsableSubnetwork; 117 import com.google.container.v1.VerticalPodAutoscaling; 118 import com.google.container.v1.VirtualNIC; 119 import com.google.container.v1.WindowsNodeConfig; 120 import com.google.container.v1.WorkloadIdentityConfig; 121 import com.google.container.v1.WorkloadMetadataConfig; 122 import com.google.protobuf.AbstractMessage; 123 import com.google.protobuf.Empty; 124 import com.google.rpc.Status; 125 import io.grpc.StatusRuntimeException; 126 import java.io.IOException; 127 import java.util.ArrayList; 128 import java.util.Arrays; 129 import java.util.HashMap; 130 import java.util.List; 131 import java.util.UUID; 132 import javax.annotation.Generated; 133 import org.junit.After; 134 import org.junit.AfterClass; 135 import org.junit.Assert; 136 import org.junit.Before; 137 import org.junit.BeforeClass; 138 import org.junit.Test; 139 140 @Generated("by gapic-generator-java") 141 public class ClusterManagerClientTest { 142 private static MockClusterManager mockClusterManager; 143 private static MockServiceHelper mockServiceHelper; 144 private LocalChannelProvider channelProvider; 145 private ClusterManagerClient client; 146 147 @BeforeClass startStaticServer()148 public static void startStaticServer() { 149 mockClusterManager = new MockClusterManager(); 150 mockServiceHelper = 151 new MockServiceHelper( 152 UUID.randomUUID().toString(), Arrays.<MockGrpcService>asList(mockClusterManager)); 153 mockServiceHelper.start(); 154 } 155 156 @AfterClass stopServer()157 public static void stopServer() { 158 mockServiceHelper.stop(); 159 } 160 161 @Before setUp()162 public void setUp() throws IOException { 163 mockServiceHelper.reset(); 164 channelProvider = mockServiceHelper.createChannelProvider(); 165 ClusterManagerSettings settings = 166 ClusterManagerSettings.newBuilder() 167 .setTransportChannelProvider(channelProvider) 168 .setCredentialsProvider(NoCredentialsProvider.create()) 169 .build(); 170 client = ClusterManagerClient.create(settings); 171 } 172 173 @After tearDown()174 public void tearDown() throws Exception { 175 client.close(); 176 } 177 178 @Test listClustersTest()179 public void listClustersTest() throws Exception { 180 ListClustersResponse expectedResponse = 181 ListClustersResponse.newBuilder() 182 .addAllClusters(new ArrayList<Cluster>()) 183 .addAllMissingZones(new ArrayList<String>()) 184 .build(); 185 mockClusterManager.addResponse(expectedResponse); 186 187 String parent = "parent-995424086"; 188 189 ListClustersResponse actualResponse = client.listClusters(parent); 190 Assert.assertEquals(expectedResponse, actualResponse); 191 192 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 193 Assert.assertEquals(1, actualRequests.size()); 194 ListClustersRequest actualRequest = ((ListClustersRequest) actualRequests.get(0)); 195 196 Assert.assertEquals(parent, actualRequest.getParent()); 197 Assert.assertTrue( 198 channelProvider.isHeaderSent( 199 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 200 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 201 } 202 203 @Test listClustersExceptionTest()204 public void listClustersExceptionTest() throws Exception { 205 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 206 mockClusterManager.addException(exception); 207 208 try { 209 String parent = "parent-995424086"; 210 client.listClusters(parent); 211 Assert.fail("No exception raised"); 212 } catch (InvalidArgumentException e) { 213 // Expected exception. 214 } 215 } 216 217 @Test listClustersTest2()218 public void listClustersTest2() throws Exception { 219 ListClustersResponse expectedResponse = 220 ListClustersResponse.newBuilder() 221 .addAllClusters(new ArrayList<Cluster>()) 222 .addAllMissingZones(new ArrayList<String>()) 223 .build(); 224 mockClusterManager.addResponse(expectedResponse); 225 226 String projectId = "projectId-894832108"; 227 String zone = "zone3744684"; 228 229 ListClustersResponse actualResponse = client.listClusters(projectId, zone); 230 Assert.assertEquals(expectedResponse, actualResponse); 231 232 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 233 Assert.assertEquals(1, actualRequests.size()); 234 ListClustersRequest actualRequest = ((ListClustersRequest) actualRequests.get(0)); 235 236 Assert.assertEquals(projectId, actualRequest.getProjectId()); 237 Assert.assertEquals(zone, actualRequest.getZone()); 238 Assert.assertTrue( 239 channelProvider.isHeaderSent( 240 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 241 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 242 } 243 244 @Test listClustersExceptionTest2()245 public void listClustersExceptionTest2() throws Exception { 246 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 247 mockClusterManager.addException(exception); 248 249 try { 250 String projectId = "projectId-894832108"; 251 String zone = "zone3744684"; 252 client.listClusters(projectId, zone); 253 Assert.fail("No exception raised"); 254 } catch (InvalidArgumentException e) { 255 // Expected exception. 256 } 257 } 258 259 @Test getClusterTest()260 public void getClusterTest() throws Exception { 261 Cluster expectedResponse = 262 Cluster.newBuilder() 263 .setName("name3373707") 264 .setDescription("description-1724546052") 265 .setInitialNodeCount(1682564205) 266 .setNodeConfig(NodeConfig.newBuilder().build()) 267 .setMasterAuth(MasterAuth.newBuilder().build()) 268 .setLoggingService("loggingService1098570326") 269 .setMonitoringService("monitoringService-1431578291") 270 .setNetwork("network1843485230") 271 .setClusterIpv4Cidr("clusterIpv4Cidr-277423341") 272 .setAddonsConfig(AddonsConfig.newBuilder().build()) 273 .setSubnetwork("subnetwork-1302785042") 274 .addAllNodePools(new ArrayList<NodePool>()) 275 .addAllLocations(new ArrayList<String>()) 276 .setEnableKubernetesAlpha(true) 277 .putAllResourceLabels(new HashMap<String, String>()) 278 .setLabelFingerprint("labelFingerprint379449680") 279 .setLegacyAbac(LegacyAbac.newBuilder().build()) 280 .setNetworkPolicy(NetworkPolicy.newBuilder().build()) 281 .setIpAllocationPolicy(IPAllocationPolicy.newBuilder().build()) 282 .setMasterAuthorizedNetworksConfig(MasterAuthorizedNetworksConfig.newBuilder().build()) 283 .setMaintenancePolicy(MaintenancePolicy.newBuilder().build()) 284 .setBinaryAuthorization(BinaryAuthorization.newBuilder().build()) 285 .setAutoscaling(ClusterAutoscaling.newBuilder().build()) 286 .setNetworkConfig(NetworkConfig.newBuilder().build()) 287 .setDefaultMaxPodsConstraint(MaxPodsConstraint.newBuilder().build()) 288 .setResourceUsageExportConfig(ResourceUsageExportConfig.newBuilder().build()) 289 .setAuthenticatorGroupsConfig(AuthenticatorGroupsConfig.newBuilder().build()) 290 .setPrivateClusterConfig(PrivateClusterConfig.newBuilder().build()) 291 .setDatabaseEncryption(DatabaseEncryption.newBuilder().build()) 292 .setVerticalPodAutoscaling(VerticalPodAutoscaling.newBuilder().build()) 293 .setShieldedNodes(ShieldedNodes.newBuilder().build()) 294 .setReleaseChannel(ReleaseChannel.newBuilder().build()) 295 .setWorkloadIdentityConfig(WorkloadIdentityConfig.newBuilder().build()) 296 .setMeshCertificates(MeshCertificates.newBuilder().build()) 297 .setCostManagementConfig(CostManagementConfig.newBuilder().build()) 298 .setNotificationConfig(NotificationConfig.newBuilder().build()) 299 .setConfidentialNodes(ConfidentialNodes.newBuilder().build()) 300 .setIdentityServiceConfig(IdentityServiceConfig.newBuilder().build()) 301 .setSelfLink("selfLink1191800166") 302 .setZone("zone3744684") 303 .setEndpoint("endpoint1741102485") 304 .setInitialClusterVersion("initialClusterVersion-1547734558") 305 .setCurrentMasterVersion("currentMasterVersion1871927069") 306 .setCurrentNodeVersion("currentNodeVersion373921085") 307 .setCreateTime("createTime1369213417") 308 .setStatusMessage("statusMessage-958704715") 309 .setNodeIpv4CidrSize(1181176815) 310 .setServicesIpv4Cidr("servicesIpv4Cidr-1785842313") 311 .addAllInstanceGroupUrls(new ArrayList<String>()) 312 .setCurrentNodeCount(178977560) 313 .setExpireTime("expireTime-834724724") 314 .setLocation("location1901043637") 315 .setEnableTpu(true) 316 .setTpuIpv4CidrBlock("tpuIpv4CidrBlock997172251") 317 .addAllConditions(new ArrayList<StatusCondition>()) 318 .setAutopilot(Autopilot.newBuilder().build()) 319 .setId("id3355") 320 .setNodePoolDefaults(NodePoolDefaults.newBuilder().build()) 321 .setLoggingConfig(LoggingConfig.newBuilder().build()) 322 .setMonitoringConfig(MonitoringConfig.newBuilder().build()) 323 .setNodePoolAutoConfig(NodePoolAutoConfig.newBuilder().build()) 324 .setEtag("etag3123477") 325 .setFleet(Fleet.newBuilder().build()) 326 .build(); 327 mockClusterManager.addResponse(expectedResponse); 328 329 String name = "name3373707"; 330 331 Cluster actualResponse = client.getCluster(name); 332 Assert.assertEquals(expectedResponse, actualResponse); 333 334 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 335 Assert.assertEquals(1, actualRequests.size()); 336 GetClusterRequest actualRequest = ((GetClusterRequest) actualRequests.get(0)); 337 338 Assert.assertEquals(name, actualRequest.getName()); 339 Assert.assertTrue( 340 channelProvider.isHeaderSent( 341 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 342 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 343 } 344 345 @Test getClusterExceptionTest()346 public void getClusterExceptionTest() throws Exception { 347 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 348 mockClusterManager.addException(exception); 349 350 try { 351 String name = "name3373707"; 352 client.getCluster(name); 353 Assert.fail("No exception raised"); 354 } catch (InvalidArgumentException e) { 355 // Expected exception. 356 } 357 } 358 359 @Test getClusterTest2()360 public void getClusterTest2() throws Exception { 361 Cluster expectedResponse = 362 Cluster.newBuilder() 363 .setName("name3373707") 364 .setDescription("description-1724546052") 365 .setInitialNodeCount(1682564205) 366 .setNodeConfig(NodeConfig.newBuilder().build()) 367 .setMasterAuth(MasterAuth.newBuilder().build()) 368 .setLoggingService("loggingService1098570326") 369 .setMonitoringService("monitoringService-1431578291") 370 .setNetwork("network1843485230") 371 .setClusterIpv4Cidr("clusterIpv4Cidr-277423341") 372 .setAddonsConfig(AddonsConfig.newBuilder().build()) 373 .setSubnetwork("subnetwork-1302785042") 374 .addAllNodePools(new ArrayList<NodePool>()) 375 .addAllLocations(new ArrayList<String>()) 376 .setEnableKubernetesAlpha(true) 377 .putAllResourceLabels(new HashMap<String, String>()) 378 .setLabelFingerprint("labelFingerprint379449680") 379 .setLegacyAbac(LegacyAbac.newBuilder().build()) 380 .setNetworkPolicy(NetworkPolicy.newBuilder().build()) 381 .setIpAllocationPolicy(IPAllocationPolicy.newBuilder().build()) 382 .setMasterAuthorizedNetworksConfig(MasterAuthorizedNetworksConfig.newBuilder().build()) 383 .setMaintenancePolicy(MaintenancePolicy.newBuilder().build()) 384 .setBinaryAuthorization(BinaryAuthorization.newBuilder().build()) 385 .setAutoscaling(ClusterAutoscaling.newBuilder().build()) 386 .setNetworkConfig(NetworkConfig.newBuilder().build()) 387 .setDefaultMaxPodsConstraint(MaxPodsConstraint.newBuilder().build()) 388 .setResourceUsageExportConfig(ResourceUsageExportConfig.newBuilder().build()) 389 .setAuthenticatorGroupsConfig(AuthenticatorGroupsConfig.newBuilder().build()) 390 .setPrivateClusterConfig(PrivateClusterConfig.newBuilder().build()) 391 .setDatabaseEncryption(DatabaseEncryption.newBuilder().build()) 392 .setVerticalPodAutoscaling(VerticalPodAutoscaling.newBuilder().build()) 393 .setShieldedNodes(ShieldedNodes.newBuilder().build()) 394 .setReleaseChannel(ReleaseChannel.newBuilder().build()) 395 .setWorkloadIdentityConfig(WorkloadIdentityConfig.newBuilder().build()) 396 .setMeshCertificates(MeshCertificates.newBuilder().build()) 397 .setCostManagementConfig(CostManagementConfig.newBuilder().build()) 398 .setNotificationConfig(NotificationConfig.newBuilder().build()) 399 .setConfidentialNodes(ConfidentialNodes.newBuilder().build()) 400 .setIdentityServiceConfig(IdentityServiceConfig.newBuilder().build()) 401 .setSelfLink("selfLink1191800166") 402 .setZone("zone3744684") 403 .setEndpoint("endpoint1741102485") 404 .setInitialClusterVersion("initialClusterVersion-1547734558") 405 .setCurrentMasterVersion("currentMasterVersion1871927069") 406 .setCurrentNodeVersion("currentNodeVersion373921085") 407 .setCreateTime("createTime1369213417") 408 .setStatusMessage("statusMessage-958704715") 409 .setNodeIpv4CidrSize(1181176815) 410 .setServicesIpv4Cidr("servicesIpv4Cidr-1785842313") 411 .addAllInstanceGroupUrls(new ArrayList<String>()) 412 .setCurrentNodeCount(178977560) 413 .setExpireTime("expireTime-834724724") 414 .setLocation("location1901043637") 415 .setEnableTpu(true) 416 .setTpuIpv4CidrBlock("tpuIpv4CidrBlock997172251") 417 .addAllConditions(new ArrayList<StatusCondition>()) 418 .setAutopilot(Autopilot.newBuilder().build()) 419 .setId("id3355") 420 .setNodePoolDefaults(NodePoolDefaults.newBuilder().build()) 421 .setLoggingConfig(LoggingConfig.newBuilder().build()) 422 .setMonitoringConfig(MonitoringConfig.newBuilder().build()) 423 .setNodePoolAutoConfig(NodePoolAutoConfig.newBuilder().build()) 424 .setEtag("etag3123477") 425 .setFleet(Fleet.newBuilder().build()) 426 .build(); 427 mockClusterManager.addResponse(expectedResponse); 428 429 String projectId = "projectId-894832108"; 430 String zone = "zone3744684"; 431 String clusterId = "clusterId561939637"; 432 433 Cluster actualResponse = client.getCluster(projectId, zone, clusterId); 434 Assert.assertEquals(expectedResponse, actualResponse); 435 436 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 437 Assert.assertEquals(1, actualRequests.size()); 438 GetClusterRequest actualRequest = ((GetClusterRequest) actualRequests.get(0)); 439 440 Assert.assertEquals(projectId, actualRequest.getProjectId()); 441 Assert.assertEquals(zone, actualRequest.getZone()); 442 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 443 Assert.assertTrue( 444 channelProvider.isHeaderSent( 445 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 446 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 447 } 448 449 @Test getClusterExceptionTest2()450 public void getClusterExceptionTest2() throws Exception { 451 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 452 mockClusterManager.addException(exception); 453 454 try { 455 String projectId = "projectId-894832108"; 456 String zone = "zone3744684"; 457 String clusterId = "clusterId561939637"; 458 client.getCluster(projectId, zone, clusterId); 459 Assert.fail("No exception raised"); 460 } catch (InvalidArgumentException e) { 461 // Expected exception. 462 } 463 } 464 465 @Test createClusterTest()466 public void createClusterTest() throws Exception { 467 Operation expectedResponse = 468 Operation.newBuilder() 469 .setName("name3373707") 470 .setZone("zone3744684") 471 .setDetail("detail-1335224239") 472 .setStatusMessage("statusMessage-958704715") 473 .setSelfLink("selfLink1191800166") 474 .setTargetLink("targetLink486368555") 475 .setLocation("location1901043637") 476 .setStartTime("startTime-2129294769") 477 .setEndTime("endTime-1607243192") 478 .setProgress(OperationProgress.newBuilder().build()) 479 .addAllClusterConditions(new ArrayList<StatusCondition>()) 480 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 481 .setError(Status.newBuilder().build()) 482 .build(); 483 mockClusterManager.addResponse(expectedResponse); 484 485 String parent = "parent-995424086"; 486 Cluster cluster = Cluster.newBuilder().build(); 487 488 Operation actualResponse = client.createCluster(parent, cluster); 489 Assert.assertEquals(expectedResponse, actualResponse); 490 491 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 492 Assert.assertEquals(1, actualRequests.size()); 493 CreateClusterRequest actualRequest = ((CreateClusterRequest) actualRequests.get(0)); 494 495 Assert.assertEquals(parent, actualRequest.getParent()); 496 Assert.assertEquals(cluster, actualRequest.getCluster()); 497 Assert.assertTrue( 498 channelProvider.isHeaderSent( 499 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 500 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 501 } 502 503 @Test createClusterExceptionTest()504 public void createClusterExceptionTest() throws Exception { 505 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 506 mockClusterManager.addException(exception); 507 508 try { 509 String parent = "parent-995424086"; 510 Cluster cluster = Cluster.newBuilder().build(); 511 client.createCluster(parent, cluster); 512 Assert.fail("No exception raised"); 513 } catch (InvalidArgumentException e) { 514 // Expected exception. 515 } 516 } 517 518 @Test createClusterTest2()519 public void createClusterTest2() throws Exception { 520 Operation expectedResponse = 521 Operation.newBuilder() 522 .setName("name3373707") 523 .setZone("zone3744684") 524 .setDetail("detail-1335224239") 525 .setStatusMessage("statusMessage-958704715") 526 .setSelfLink("selfLink1191800166") 527 .setTargetLink("targetLink486368555") 528 .setLocation("location1901043637") 529 .setStartTime("startTime-2129294769") 530 .setEndTime("endTime-1607243192") 531 .setProgress(OperationProgress.newBuilder().build()) 532 .addAllClusterConditions(new ArrayList<StatusCondition>()) 533 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 534 .setError(Status.newBuilder().build()) 535 .build(); 536 mockClusterManager.addResponse(expectedResponse); 537 538 String projectId = "projectId-894832108"; 539 String zone = "zone3744684"; 540 Cluster cluster = Cluster.newBuilder().build(); 541 542 Operation actualResponse = client.createCluster(projectId, zone, cluster); 543 Assert.assertEquals(expectedResponse, actualResponse); 544 545 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 546 Assert.assertEquals(1, actualRequests.size()); 547 CreateClusterRequest actualRequest = ((CreateClusterRequest) actualRequests.get(0)); 548 549 Assert.assertEquals(projectId, actualRequest.getProjectId()); 550 Assert.assertEquals(zone, actualRequest.getZone()); 551 Assert.assertEquals(cluster, actualRequest.getCluster()); 552 Assert.assertTrue( 553 channelProvider.isHeaderSent( 554 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 555 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 556 } 557 558 @Test createClusterExceptionTest2()559 public void createClusterExceptionTest2() throws Exception { 560 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 561 mockClusterManager.addException(exception); 562 563 try { 564 String projectId = "projectId-894832108"; 565 String zone = "zone3744684"; 566 Cluster cluster = Cluster.newBuilder().build(); 567 client.createCluster(projectId, zone, cluster); 568 Assert.fail("No exception raised"); 569 } catch (InvalidArgumentException e) { 570 // Expected exception. 571 } 572 } 573 574 @Test updateClusterTest()575 public void updateClusterTest() throws Exception { 576 Operation expectedResponse = 577 Operation.newBuilder() 578 .setName("name3373707") 579 .setZone("zone3744684") 580 .setDetail("detail-1335224239") 581 .setStatusMessage("statusMessage-958704715") 582 .setSelfLink("selfLink1191800166") 583 .setTargetLink("targetLink486368555") 584 .setLocation("location1901043637") 585 .setStartTime("startTime-2129294769") 586 .setEndTime("endTime-1607243192") 587 .setProgress(OperationProgress.newBuilder().build()) 588 .addAllClusterConditions(new ArrayList<StatusCondition>()) 589 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 590 .setError(Status.newBuilder().build()) 591 .build(); 592 mockClusterManager.addResponse(expectedResponse); 593 594 String name = "name3373707"; 595 ClusterUpdate update = ClusterUpdate.newBuilder().build(); 596 597 Operation actualResponse = client.updateCluster(name, update); 598 Assert.assertEquals(expectedResponse, actualResponse); 599 600 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 601 Assert.assertEquals(1, actualRequests.size()); 602 UpdateClusterRequest actualRequest = ((UpdateClusterRequest) actualRequests.get(0)); 603 604 Assert.assertEquals(name, actualRequest.getName()); 605 Assert.assertEquals(update, actualRequest.getUpdate()); 606 Assert.assertTrue( 607 channelProvider.isHeaderSent( 608 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 609 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 610 } 611 612 @Test updateClusterExceptionTest()613 public void updateClusterExceptionTest() throws Exception { 614 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 615 mockClusterManager.addException(exception); 616 617 try { 618 String name = "name3373707"; 619 ClusterUpdate update = ClusterUpdate.newBuilder().build(); 620 client.updateCluster(name, update); 621 Assert.fail("No exception raised"); 622 } catch (InvalidArgumentException e) { 623 // Expected exception. 624 } 625 } 626 627 @Test updateClusterTest2()628 public void updateClusterTest2() throws Exception { 629 Operation expectedResponse = 630 Operation.newBuilder() 631 .setName("name3373707") 632 .setZone("zone3744684") 633 .setDetail("detail-1335224239") 634 .setStatusMessage("statusMessage-958704715") 635 .setSelfLink("selfLink1191800166") 636 .setTargetLink("targetLink486368555") 637 .setLocation("location1901043637") 638 .setStartTime("startTime-2129294769") 639 .setEndTime("endTime-1607243192") 640 .setProgress(OperationProgress.newBuilder().build()) 641 .addAllClusterConditions(new ArrayList<StatusCondition>()) 642 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 643 .setError(Status.newBuilder().build()) 644 .build(); 645 mockClusterManager.addResponse(expectedResponse); 646 647 String projectId = "projectId-894832108"; 648 String zone = "zone3744684"; 649 String clusterId = "clusterId561939637"; 650 ClusterUpdate update = ClusterUpdate.newBuilder().build(); 651 652 Operation actualResponse = client.updateCluster(projectId, zone, clusterId, update); 653 Assert.assertEquals(expectedResponse, actualResponse); 654 655 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 656 Assert.assertEquals(1, actualRequests.size()); 657 UpdateClusterRequest actualRequest = ((UpdateClusterRequest) actualRequests.get(0)); 658 659 Assert.assertEquals(projectId, actualRequest.getProjectId()); 660 Assert.assertEquals(zone, actualRequest.getZone()); 661 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 662 Assert.assertEquals(update, actualRequest.getUpdate()); 663 Assert.assertTrue( 664 channelProvider.isHeaderSent( 665 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 666 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 667 } 668 669 @Test updateClusterExceptionTest2()670 public void updateClusterExceptionTest2() throws Exception { 671 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 672 mockClusterManager.addException(exception); 673 674 try { 675 String projectId = "projectId-894832108"; 676 String zone = "zone3744684"; 677 String clusterId = "clusterId561939637"; 678 ClusterUpdate update = ClusterUpdate.newBuilder().build(); 679 client.updateCluster(projectId, zone, clusterId, update); 680 Assert.fail("No exception raised"); 681 } catch (InvalidArgumentException e) { 682 // Expected exception. 683 } 684 } 685 686 @Test updateNodePoolTest()687 public void updateNodePoolTest() throws Exception { 688 Operation expectedResponse = 689 Operation.newBuilder() 690 .setName("name3373707") 691 .setZone("zone3744684") 692 .setDetail("detail-1335224239") 693 .setStatusMessage("statusMessage-958704715") 694 .setSelfLink("selfLink1191800166") 695 .setTargetLink("targetLink486368555") 696 .setLocation("location1901043637") 697 .setStartTime("startTime-2129294769") 698 .setEndTime("endTime-1607243192") 699 .setProgress(OperationProgress.newBuilder().build()) 700 .addAllClusterConditions(new ArrayList<StatusCondition>()) 701 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 702 .setError(Status.newBuilder().build()) 703 .build(); 704 mockClusterManager.addResponse(expectedResponse); 705 706 UpdateNodePoolRequest request = 707 UpdateNodePoolRequest.newBuilder() 708 .setProjectId("projectId-894832108") 709 .setZone("zone3744684") 710 .setClusterId("clusterId561939637") 711 .setNodePoolId("nodePoolId1121557241") 712 .setNodeVersion("nodeVersion1155309686") 713 .setImageType("imageType-878147787") 714 .setName("name3373707") 715 .addAllLocations(new ArrayList<String>()) 716 .setWorkloadMetadataConfig(WorkloadMetadataConfig.newBuilder().build()) 717 .setUpgradeSettings(NodePool.UpgradeSettings.newBuilder().build()) 718 .setTags(NetworkTags.newBuilder().build()) 719 .setTaints(NodeTaints.newBuilder().build()) 720 .setLabels(NodeLabels.newBuilder().build()) 721 .setLinuxNodeConfig(LinuxNodeConfig.newBuilder().build()) 722 .setKubeletConfig(NodeKubeletConfig.newBuilder().build()) 723 .setNodeNetworkConfig(NodeNetworkConfig.newBuilder().build()) 724 .setGcfsConfig(GcfsConfig.newBuilder().build()) 725 .setConfidentialNodes(ConfidentialNodes.newBuilder().build()) 726 .setGvnic(VirtualNIC.newBuilder().build()) 727 .setEtag("etag3123477") 728 .setFastSocket(FastSocket.newBuilder().build()) 729 .setLoggingConfig(NodePoolLoggingConfig.newBuilder().build()) 730 .setResourceLabels(ResourceLabels.newBuilder().build()) 731 .setWindowsNodeConfig(WindowsNodeConfig.newBuilder().build()) 732 .build(); 733 734 Operation actualResponse = client.updateNodePool(request); 735 Assert.assertEquals(expectedResponse, actualResponse); 736 737 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 738 Assert.assertEquals(1, actualRequests.size()); 739 UpdateNodePoolRequest actualRequest = ((UpdateNodePoolRequest) actualRequests.get(0)); 740 741 Assert.assertEquals(request.getProjectId(), actualRequest.getProjectId()); 742 Assert.assertEquals(request.getZone(), actualRequest.getZone()); 743 Assert.assertEquals(request.getClusterId(), actualRequest.getClusterId()); 744 Assert.assertEquals(request.getNodePoolId(), actualRequest.getNodePoolId()); 745 Assert.assertEquals(request.getNodeVersion(), actualRequest.getNodeVersion()); 746 Assert.assertEquals(request.getImageType(), actualRequest.getImageType()); 747 Assert.assertEquals(request.getName(), actualRequest.getName()); 748 Assert.assertEquals(request.getLocationsList(), actualRequest.getLocationsList()); 749 Assert.assertEquals( 750 request.getWorkloadMetadataConfig(), actualRequest.getWorkloadMetadataConfig()); 751 Assert.assertEquals(request.getUpgradeSettings(), actualRequest.getUpgradeSettings()); 752 Assert.assertEquals(request.getTags(), actualRequest.getTags()); 753 Assert.assertEquals(request.getTaints(), actualRequest.getTaints()); 754 Assert.assertEquals(request.getLabels(), actualRequest.getLabels()); 755 Assert.assertEquals(request.getLinuxNodeConfig(), actualRequest.getLinuxNodeConfig()); 756 Assert.assertEquals(request.getKubeletConfig(), actualRequest.getKubeletConfig()); 757 Assert.assertEquals(request.getNodeNetworkConfig(), actualRequest.getNodeNetworkConfig()); 758 Assert.assertEquals(request.getGcfsConfig(), actualRequest.getGcfsConfig()); 759 Assert.assertEquals(request.getConfidentialNodes(), actualRequest.getConfidentialNodes()); 760 Assert.assertEquals(request.getGvnic(), actualRequest.getGvnic()); 761 Assert.assertEquals(request.getEtag(), actualRequest.getEtag()); 762 Assert.assertEquals(request.getFastSocket(), actualRequest.getFastSocket()); 763 Assert.assertEquals(request.getLoggingConfig(), actualRequest.getLoggingConfig()); 764 Assert.assertEquals(request.getResourceLabels(), actualRequest.getResourceLabels()); 765 Assert.assertEquals(request.getWindowsNodeConfig(), actualRequest.getWindowsNodeConfig()); 766 Assert.assertTrue( 767 channelProvider.isHeaderSent( 768 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 769 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 770 } 771 772 @Test updateNodePoolExceptionTest()773 public void updateNodePoolExceptionTest() throws Exception { 774 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 775 mockClusterManager.addException(exception); 776 777 try { 778 UpdateNodePoolRequest request = 779 UpdateNodePoolRequest.newBuilder() 780 .setProjectId("projectId-894832108") 781 .setZone("zone3744684") 782 .setClusterId("clusterId561939637") 783 .setNodePoolId("nodePoolId1121557241") 784 .setNodeVersion("nodeVersion1155309686") 785 .setImageType("imageType-878147787") 786 .setName("name3373707") 787 .addAllLocations(new ArrayList<String>()) 788 .setWorkloadMetadataConfig(WorkloadMetadataConfig.newBuilder().build()) 789 .setUpgradeSettings(NodePool.UpgradeSettings.newBuilder().build()) 790 .setTags(NetworkTags.newBuilder().build()) 791 .setTaints(NodeTaints.newBuilder().build()) 792 .setLabels(NodeLabels.newBuilder().build()) 793 .setLinuxNodeConfig(LinuxNodeConfig.newBuilder().build()) 794 .setKubeletConfig(NodeKubeletConfig.newBuilder().build()) 795 .setNodeNetworkConfig(NodeNetworkConfig.newBuilder().build()) 796 .setGcfsConfig(GcfsConfig.newBuilder().build()) 797 .setConfidentialNodes(ConfidentialNodes.newBuilder().build()) 798 .setGvnic(VirtualNIC.newBuilder().build()) 799 .setEtag("etag3123477") 800 .setFastSocket(FastSocket.newBuilder().build()) 801 .setLoggingConfig(NodePoolLoggingConfig.newBuilder().build()) 802 .setResourceLabels(ResourceLabels.newBuilder().build()) 803 .setWindowsNodeConfig(WindowsNodeConfig.newBuilder().build()) 804 .build(); 805 client.updateNodePool(request); 806 Assert.fail("No exception raised"); 807 } catch (InvalidArgumentException e) { 808 // Expected exception. 809 } 810 } 811 812 @Test setNodePoolAutoscalingTest()813 public void setNodePoolAutoscalingTest() throws Exception { 814 Operation expectedResponse = 815 Operation.newBuilder() 816 .setName("name3373707") 817 .setZone("zone3744684") 818 .setDetail("detail-1335224239") 819 .setStatusMessage("statusMessage-958704715") 820 .setSelfLink("selfLink1191800166") 821 .setTargetLink("targetLink486368555") 822 .setLocation("location1901043637") 823 .setStartTime("startTime-2129294769") 824 .setEndTime("endTime-1607243192") 825 .setProgress(OperationProgress.newBuilder().build()) 826 .addAllClusterConditions(new ArrayList<StatusCondition>()) 827 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 828 .setError(Status.newBuilder().build()) 829 .build(); 830 mockClusterManager.addResponse(expectedResponse); 831 832 SetNodePoolAutoscalingRequest request = 833 SetNodePoolAutoscalingRequest.newBuilder() 834 .setProjectId("projectId-894832108") 835 .setZone("zone3744684") 836 .setClusterId("clusterId561939637") 837 .setNodePoolId("nodePoolId1121557241") 838 .setAutoscaling(NodePoolAutoscaling.newBuilder().build()) 839 .setName("name3373707") 840 .build(); 841 842 Operation actualResponse = client.setNodePoolAutoscaling(request); 843 Assert.assertEquals(expectedResponse, actualResponse); 844 845 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 846 Assert.assertEquals(1, actualRequests.size()); 847 SetNodePoolAutoscalingRequest actualRequest = 848 ((SetNodePoolAutoscalingRequest) actualRequests.get(0)); 849 850 Assert.assertEquals(request.getProjectId(), actualRequest.getProjectId()); 851 Assert.assertEquals(request.getZone(), actualRequest.getZone()); 852 Assert.assertEquals(request.getClusterId(), actualRequest.getClusterId()); 853 Assert.assertEquals(request.getNodePoolId(), actualRequest.getNodePoolId()); 854 Assert.assertEquals(request.getAutoscaling(), actualRequest.getAutoscaling()); 855 Assert.assertEquals(request.getName(), actualRequest.getName()); 856 Assert.assertTrue( 857 channelProvider.isHeaderSent( 858 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 859 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 860 } 861 862 @Test setNodePoolAutoscalingExceptionTest()863 public void setNodePoolAutoscalingExceptionTest() throws Exception { 864 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 865 mockClusterManager.addException(exception); 866 867 try { 868 SetNodePoolAutoscalingRequest request = 869 SetNodePoolAutoscalingRequest.newBuilder() 870 .setProjectId("projectId-894832108") 871 .setZone("zone3744684") 872 .setClusterId("clusterId561939637") 873 .setNodePoolId("nodePoolId1121557241") 874 .setAutoscaling(NodePoolAutoscaling.newBuilder().build()) 875 .setName("name3373707") 876 .build(); 877 client.setNodePoolAutoscaling(request); 878 Assert.fail("No exception raised"); 879 } catch (InvalidArgumentException e) { 880 // Expected exception. 881 } 882 } 883 884 @Test setLoggingServiceTest()885 public void setLoggingServiceTest() throws Exception { 886 Operation expectedResponse = 887 Operation.newBuilder() 888 .setName("name3373707") 889 .setZone("zone3744684") 890 .setDetail("detail-1335224239") 891 .setStatusMessage("statusMessage-958704715") 892 .setSelfLink("selfLink1191800166") 893 .setTargetLink("targetLink486368555") 894 .setLocation("location1901043637") 895 .setStartTime("startTime-2129294769") 896 .setEndTime("endTime-1607243192") 897 .setProgress(OperationProgress.newBuilder().build()) 898 .addAllClusterConditions(new ArrayList<StatusCondition>()) 899 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 900 .setError(Status.newBuilder().build()) 901 .build(); 902 mockClusterManager.addResponse(expectedResponse); 903 904 String name = "name3373707"; 905 String loggingService = "loggingService1098570326"; 906 907 Operation actualResponse = client.setLoggingService(name, loggingService); 908 Assert.assertEquals(expectedResponse, actualResponse); 909 910 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 911 Assert.assertEquals(1, actualRequests.size()); 912 SetLoggingServiceRequest actualRequest = ((SetLoggingServiceRequest) actualRequests.get(0)); 913 914 Assert.assertEquals(name, actualRequest.getName()); 915 Assert.assertEquals(loggingService, actualRequest.getLoggingService()); 916 Assert.assertTrue( 917 channelProvider.isHeaderSent( 918 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 919 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 920 } 921 922 @Test setLoggingServiceExceptionTest()923 public void setLoggingServiceExceptionTest() throws Exception { 924 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 925 mockClusterManager.addException(exception); 926 927 try { 928 String name = "name3373707"; 929 String loggingService = "loggingService1098570326"; 930 client.setLoggingService(name, loggingService); 931 Assert.fail("No exception raised"); 932 } catch (InvalidArgumentException e) { 933 // Expected exception. 934 } 935 } 936 937 @Test setLoggingServiceTest2()938 public void setLoggingServiceTest2() throws Exception { 939 Operation expectedResponse = 940 Operation.newBuilder() 941 .setName("name3373707") 942 .setZone("zone3744684") 943 .setDetail("detail-1335224239") 944 .setStatusMessage("statusMessage-958704715") 945 .setSelfLink("selfLink1191800166") 946 .setTargetLink("targetLink486368555") 947 .setLocation("location1901043637") 948 .setStartTime("startTime-2129294769") 949 .setEndTime("endTime-1607243192") 950 .setProgress(OperationProgress.newBuilder().build()) 951 .addAllClusterConditions(new ArrayList<StatusCondition>()) 952 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 953 .setError(Status.newBuilder().build()) 954 .build(); 955 mockClusterManager.addResponse(expectedResponse); 956 957 String projectId = "projectId-894832108"; 958 String zone = "zone3744684"; 959 String clusterId = "clusterId561939637"; 960 String loggingService = "loggingService1098570326"; 961 962 Operation actualResponse = client.setLoggingService(projectId, zone, clusterId, loggingService); 963 Assert.assertEquals(expectedResponse, actualResponse); 964 965 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 966 Assert.assertEquals(1, actualRequests.size()); 967 SetLoggingServiceRequest actualRequest = ((SetLoggingServiceRequest) actualRequests.get(0)); 968 969 Assert.assertEquals(projectId, actualRequest.getProjectId()); 970 Assert.assertEquals(zone, actualRequest.getZone()); 971 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 972 Assert.assertEquals(loggingService, actualRequest.getLoggingService()); 973 Assert.assertTrue( 974 channelProvider.isHeaderSent( 975 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 976 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 977 } 978 979 @Test setLoggingServiceExceptionTest2()980 public void setLoggingServiceExceptionTest2() throws Exception { 981 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 982 mockClusterManager.addException(exception); 983 984 try { 985 String projectId = "projectId-894832108"; 986 String zone = "zone3744684"; 987 String clusterId = "clusterId561939637"; 988 String loggingService = "loggingService1098570326"; 989 client.setLoggingService(projectId, zone, clusterId, loggingService); 990 Assert.fail("No exception raised"); 991 } catch (InvalidArgumentException e) { 992 // Expected exception. 993 } 994 } 995 996 @Test setMonitoringServiceTest()997 public void setMonitoringServiceTest() throws Exception { 998 Operation expectedResponse = 999 Operation.newBuilder() 1000 .setName("name3373707") 1001 .setZone("zone3744684") 1002 .setDetail("detail-1335224239") 1003 .setStatusMessage("statusMessage-958704715") 1004 .setSelfLink("selfLink1191800166") 1005 .setTargetLink("targetLink486368555") 1006 .setLocation("location1901043637") 1007 .setStartTime("startTime-2129294769") 1008 .setEndTime("endTime-1607243192") 1009 .setProgress(OperationProgress.newBuilder().build()) 1010 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1011 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1012 .setError(Status.newBuilder().build()) 1013 .build(); 1014 mockClusterManager.addResponse(expectedResponse); 1015 1016 String name = "name3373707"; 1017 String monitoringService = "monitoringService-1431578291"; 1018 1019 Operation actualResponse = client.setMonitoringService(name, monitoringService); 1020 Assert.assertEquals(expectedResponse, actualResponse); 1021 1022 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1023 Assert.assertEquals(1, actualRequests.size()); 1024 SetMonitoringServiceRequest actualRequest = 1025 ((SetMonitoringServiceRequest) actualRequests.get(0)); 1026 1027 Assert.assertEquals(name, actualRequest.getName()); 1028 Assert.assertEquals(monitoringService, actualRequest.getMonitoringService()); 1029 Assert.assertTrue( 1030 channelProvider.isHeaderSent( 1031 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1032 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1033 } 1034 1035 @Test setMonitoringServiceExceptionTest()1036 public void setMonitoringServiceExceptionTest() throws Exception { 1037 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1038 mockClusterManager.addException(exception); 1039 1040 try { 1041 String name = "name3373707"; 1042 String monitoringService = "monitoringService-1431578291"; 1043 client.setMonitoringService(name, monitoringService); 1044 Assert.fail("No exception raised"); 1045 } catch (InvalidArgumentException e) { 1046 // Expected exception. 1047 } 1048 } 1049 1050 @Test setMonitoringServiceTest2()1051 public void setMonitoringServiceTest2() throws Exception { 1052 Operation expectedResponse = 1053 Operation.newBuilder() 1054 .setName("name3373707") 1055 .setZone("zone3744684") 1056 .setDetail("detail-1335224239") 1057 .setStatusMessage("statusMessage-958704715") 1058 .setSelfLink("selfLink1191800166") 1059 .setTargetLink("targetLink486368555") 1060 .setLocation("location1901043637") 1061 .setStartTime("startTime-2129294769") 1062 .setEndTime("endTime-1607243192") 1063 .setProgress(OperationProgress.newBuilder().build()) 1064 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1065 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1066 .setError(Status.newBuilder().build()) 1067 .build(); 1068 mockClusterManager.addResponse(expectedResponse); 1069 1070 String projectId = "projectId-894832108"; 1071 String zone = "zone3744684"; 1072 String clusterId = "clusterId561939637"; 1073 String monitoringService = "monitoringService-1431578291"; 1074 1075 Operation actualResponse = 1076 client.setMonitoringService(projectId, zone, clusterId, monitoringService); 1077 Assert.assertEquals(expectedResponse, actualResponse); 1078 1079 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1080 Assert.assertEquals(1, actualRequests.size()); 1081 SetMonitoringServiceRequest actualRequest = 1082 ((SetMonitoringServiceRequest) actualRequests.get(0)); 1083 1084 Assert.assertEquals(projectId, actualRequest.getProjectId()); 1085 Assert.assertEquals(zone, actualRequest.getZone()); 1086 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 1087 Assert.assertEquals(monitoringService, actualRequest.getMonitoringService()); 1088 Assert.assertTrue( 1089 channelProvider.isHeaderSent( 1090 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1091 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1092 } 1093 1094 @Test setMonitoringServiceExceptionTest2()1095 public void setMonitoringServiceExceptionTest2() throws Exception { 1096 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1097 mockClusterManager.addException(exception); 1098 1099 try { 1100 String projectId = "projectId-894832108"; 1101 String zone = "zone3744684"; 1102 String clusterId = "clusterId561939637"; 1103 String monitoringService = "monitoringService-1431578291"; 1104 client.setMonitoringService(projectId, zone, clusterId, monitoringService); 1105 Assert.fail("No exception raised"); 1106 } catch (InvalidArgumentException e) { 1107 // Expected exception. 1108 } 1109 } 1110 1111 @Test setAddonsConfigTest()1112 public void setAddonsConfigTest() throws Exception { 1113 Operation expectedResponse = 1114 Operation.newBuilder() 1115 .setName("name3373707") 1116 .setZone("zone3744684") 1117 .setDetail("detail-1335224239") 1118 .setStatusMessage("statusMessage-958704715") 1119 .setSelfLink("selfLink1191800166") 1120 .setTargetLink("targetLink486368555") 1121 .setLocation("location1901043637") 1122 .setStartTime("startTime-2129294769") 1123 .setEndTime("endTime-1607243192") 1124 .setProgress(OperationProgress.newBuilder().build()) 1125 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1126 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1127 .setError(Status.newBuilder().build()) 1128 .build(); 1129 mockClusterManager.addResponse(expectedResponse); 1130 1131 String name = "name3373707"; 1132 AddonsConfig addonsConfig = AddonsConfig.newBuilder().build(); 1133 1134 Operation actualResponse = client.setAddonsConfig(name, addonsConfig); 1135 Assert.assertEquals(expectedResponse, actualResponse); 1136 1137 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1138 Assert.assertEquals(1, actualRequests.size()); 1139 SetAddonsConfigRequest actualRequest = ((SetAddonsConfigRequest) actualRequests.get(0)); 1140 1141 Assert.assertEquals(name, actualRequest.getName()); 1142 Assert.assertEquals(addonsConfig, actualRequest.getAddonsConfig()); 1143 Assert.assertTrue( 1144 channelProvider.isHeaderSent( 1145 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1146 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1147 } 1148 1149 @Test setAddonsConfigExceptionTest()1150 public void setAddonsConfigExceptionTest() throws Exception { 1151 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1152 mockClusterManager.addException(exception); 1153 1154 try { 1155 String name = "name3373707"; 1156 AddonsConfig addonsConfig = AddonsConfig.newBuilder().build(); 1157 client.setAddonsConfig(name, addonsConfig); 1158 Assert.fail("No exception raised"); 1159 } catch (InvalidArgumentException e) { 1160 // Expected exception. 1161 } 1162 } 1163 1164 @Test setAddonsConfigTest2()1165 public void setAddonsConfigTest2() throws Exception { 1166 Operation expectedResponse = 1167 Operation.newBuilder() 1168 .setName("name3373707") 1169 .setZone("zone3744684") 1170 .setDetail("detail-1335224239") 1171 .setStatusMessage("statusMessage-958704715") 1172 .setSelfLink("selfLink1191800166") 1173 .setTargetLink("targetLink486368555") 1174 .setLocation("location1901043637") 1175 .setStartTime("startTime-2129294769") 1176 .setEndTime("endTime-1607243192") 1177 .setProgress(OperationProgress.newBuilder().build()) 1178 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1179 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1180 .setError(Status.newBuilder().build()) 1181 .build(); 1182 mockClusterManager.addResponse(expectedResponse); 1183 1184 String projectId = "projectId-894832108"; 1185 String zone = "zone3744684"; 1186 String clusterId = "clusterId561939637"; 1187 AddonsConfig addonsConfig = AddonsConfig.newBuilder().build(); 1188 1189 Operation actualResponse = client.setAddonsConfig(projectId, zone, clusterId, addonsConfig); 1190 Assert.assertEquals(expectedResponse, actualResponse); 1191 1192 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1193 Assert.assertEquals(1, actualRequests.size()); 1194 SetAddonsConfigRequest actualRequest = ((SetAddonsConfigRequest) actualRequests.get(0)); 1195 1196 Assert.assertEquals(projectId, actualRequest.getProjectId()); 1197 Assert.assertEquals(zone, actualRequest.getZone()); 1198 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 1199 Assert.assertEquals(addonsConfig, actualRequest.getAddonsConfig()); 1200 Assert.assertTrue( 1201 channelProvider.isHeaderSent( 1202 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1203 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1204 } 1205 1206 @Test setAddonsConfigExceptionTest2()1207 public void setAddonsConfigExceptionTest2() throws Exception { 1208 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1209 mockClusterManager.addException(exception); 1210 1211 try { 1212 String projectId = "projectId-894832108"; 1213 String zone = "zone3744684"; 1214 String clusterId = "clusterId561939637"; 1215 AddonsConfig addonsConfig = AddonsConfig.newBuilder().build(); 1216 client.setAddonsConfig(projectId, zone, clusterId, addonsConfig); 1217 Assert.fail("No exception raised"); 1218 } catch (InvalidArgumentException e) { 1219 // Expected exception. 1220 } 1221 } 1222 1223 @Test setLocationsTest()1224 public void setLocationsTest() throws Exception { 1225 Operation expectedResponse = 1226 Operation.newBuilder() 1227 .setName("name3373707") 1228 .setZone("zone3744684") 1229 .setDetail("detail-1335224239") 1230 .setStatusMessage("statusMessage-958704715") 1231 .setSelfLink("selfLink1191800166") 1232 .setTargetLink("targetLink486368555") 1233 .setLocation("location1901043637") 1234 .setStartTime("startTime-2129294769") 1235 .setEndTime("endTime-1607243192") 1236 .setProgress(OperationProgress.newBuilder().build()) 1237 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1238 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1239 .setError(Status.newBuilder().build()) 1240 .build(); 1241 mockClusterManager.addResponse(expectedResponse); 1242 1243 String name = "name3373707"; 1244 List<String> locations = new ArrayList<>(); 1245 1246 Operation actualResponse = client.setLocations(name, locations); 1247 Assert.assertEquals(expectedResponse, actualResponse); 1248 1249 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1250 Assert.assertEquals(1, actualRequests.size()); 1251 SetLocationsRequest actualRequest = ((SetLocationsRequest) actualRequests.get(0)); 1252 1253 Assert.assertEquals(name, actualRequest.getName()); 1254 Assert.assertEquals(locations, actualRequest.getLocationsList()); 1255 Assert.assertTrue( 1256 channelProvider.isHeaderSent( 1257 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1258 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1259 } 1260 1261 @Test setLocationsExceptionTest()1262 public void setLocationsExceptionTest() throws Exception { 1263 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1264 mockClusterManager.addException(exception); 1265 1266 try { 1267 String name = "name3373707"; 1268 List<String> locations = new ArrayList<>(); 1269 client.setLocations(name, locations); 1270 Assert.fail("No exception raised"); 1271 } catch (InvalidArgumentException e) { 1272 // Expected exception. 1273 } 1274 } 1275 1276 @Test setLocationsTest2()1277 public void setLocationsTest2() throws Exception { 1278 Operation expectedResponse = 1279 Operation.newBuilder() 1280 .setName("name3373707") 1281 .setZone("zone3744684") 1282 .setDetail("detail-1335224239") 1283 .setStatusMessage("statusMessage-958704715") 1284 .setSelfLink("selfLink1191800166") 1285 .setTargetLink("targetLink486368555") 1286 .setLocation("location1901043637") 1287 .setStartTime("startTime-2129294769") 1288 .setEndTime("endTime-1607243192") 1289 .setProgress(OperationProgress.newBuilder().build()) 1290 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1291 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1292 .setError(Status.newBuilder().build()) 1293 .build(); 1294 mockClusterManager.addResponse(expectedResponse); 1295 1296 String projectId = "projectId-894832108"; 1297 String zone = "zone3744684"; 1298 String clusterId = "clusterId561939637"; 1299 List<String> locations = new ArrayList<>(); 1300 1301 Operation actualResponse = client.setLocations(projectId, zone, clusterId, locations); 1302 Assert.assertEquals(expectedResponse, actualResponse); 1303 1304 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1305 Assert.assertEquals(1, actualRequests.size()); 1306 SetLocationsRequest actualRequest = ((SetLocationsRequest) actualRequests.get(0)); 1307 1308 Assert.assertEquals(projectId, actualRequest.getProjectId()); 1309 Assert.assertEquals(zone, actualRequest.getZone()); 1310 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 1311 Assert.assertEquals(locations, actualRequest.getLocationsList()); 1312 Assert.assertTrue( 1313 channelProvider.isHeaderSent( 1314 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1315 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1316 } 1317 1318 @Test setLocationsExceptionTest2()1319 public void setLocationsExceptionTest2() throws Exception { 1320 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1321 mockClusterManager.addException(exception); 1322 1323 try { 1324 String projectId = "projectId-894832108"; 1325 String zone = "zone3744684"; 1326 String clusterId = "clusterId561939637"; 1327 List<String> locations = new ArrayList<>(); 1328 client.setLocations(projectId, zone, clusterId, locations); 1329 Assert.fail("No exception raised"); 1330 } catch (InvalidArgumentException e) { 1331 // Expected exception. 1332 } 1333 } 1334 1335 @Test updateMasterTest()1336 public void updateMasterTest() throws Exception { 1337 Operation expectedResponse = 1338 Operation.newBuilder() 1339 .setName("name3373707") 1340 .setZone("zone3744684") 1341 .setDetail("detail-1335224239") 1342 .setStatusMessage("statusMessage-958704715") 1343 .setSelfLink("selfLink1191800166") 1344 .setTargetLink("targetLink486368555") 1345 .setLocation("location1901043637") 1346 .setStartTime("startTime-2129294769") 1347 .setEndTime("endTime-1607243192") 1348 .setProgress(OperationProgress.newBuilder().build()) 1349 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1350 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1351 .setError(Status.newBuilder().build()) 1352 .build(); 1353 mockClusterManager.addResponse(expectedResponse); 1354 1355 String name = "name3373707"; 1356 String masterVersion = "masterVersion1167095830"; 1357 1358 Operation actualResponse = client.updateMaster(name, masterVersion); 1359 Assert.assertEquals(expectedResponse, actualResponse); 1360 1361 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1362 Assert.assertEquals(1, actualRequests.size()); 1363 UpdateMasterRequest actualRequest = ((UpdateMasterRequest) actualRequests.get(0)); 1364 1365 Assert.assertEquals(name, actualRequest.getName()); 1366 Assert.assertEquals(masterVersion, actualRequest.getMasterVersion()); 1367 Assert.assertTrue( 1368 channelProvider.isHeaderSent( 1369 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1370 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1371 } 1372 1373 @Test updateMasterExceptionTest()1374 public void updateMasterExceptionTest() throws Exception { 1375 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1376 mockClusterManager.addException(exception); 1377 1378 try { 1379 String name = "name3373707"; 1380 String masterVersion = "masterVersion1167095830"; 1381 client.updateMaster(name, masterVersion); 1382 Assert.fail("No exception raised"); 1383 } catch (InvalidArgumentException e) { 1384 // Expected exception. 1385 } 1386 } 1387 1388 @Test updateMasterTest2()1389 public void updateMasterTest2() throws Exception { 1390 Operation expectedResponse = 1391 Operation.newBuilder() 1392 .setName("name3373707") 1393 .setZone("zone3744684") 1394 .setDetail("detail-1335224239") 1395 .setStatusMessage("statusMessage-958704715") 1396 .setSelfLink("selfLink1191800166") 1397 .setTargetLink("targetLink486368555") 1398 .setLocation("location1901043637") 1399 .setStartTime("startTime-2129294769") 1400 .setEndTime("endTime-1607243192") 1401 .setProgress(OperationProgress.newBuilder().build()) 1402 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1403 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1404 .setError(Status.newBuilder().build()) 1405 .build(); 1406 mockClusterManager.addResponse(expectedResponse); 1407 1408 String projectId = "projectId-894832108"; 1409 String zone = "zone3744684"; 1410 String clusterId = "clusterId561939637"; 1411 String masterVersion = "masterVersion1167095830"; 1412 1413 Operation actualResponse = client.updateMaster(projectId, zone, clusterId, masterVersion); 1414 Assert.assertEquals(expectedResponse, actualResponse); 1415 1416 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1417 Assert.assertEquals(1, actualRequests.size()); 1418 UpdateMasterRequest actualRequest = ((UpdateMasterRequest) actualRequests.get(0)); 1419 1420 Assert.assertEquals(projectId, actualRequest.getProjectId()); 1421 Assert.assertEquals(zone, actualRequest.getZone()); 1422 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 1423 Assert.assertEquals(masterVersion, actualRequest.getMasterVersion()); 1424 Assert.assertTrue( 1425 channelProvider.isHeaderSent( 1426 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1427 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1428 } 1429 1430 @Test updateMasterExceptionTest2()1431 public void updateMasterExceptionTest2() throws Exception { 1432 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1433 mockClusterManager.addException(exception); 1434 1435 try { 1436 String projectId = "projectId-894832108"; 1437 String zone = "zone3744684"; 1438 String clusterId = "clusterId561939637"; 1439 String masterVersion = "masterVersion1167095830"; 1440 client.updateMaster(projectId, zone, clusterId, masterVersion); 1441 Assert.fail("No exception raised"); 1442 } catch (InvalidArgumentException e) { 1443 // Expected exception. 1444 } 1445 } 1446 1447 @Test setMasterAuthTest()1448 public void setMasterAuthTest() throws Exception { 1449 Operation expectedResponse = 1450 Operation.newBuilder() 1451 .setName("name3373707") 1452 .setZone("zone3744684") 1453 .setDetail("detail-1335224239") 1454 .setStatusMessage("statusMessage-958704715") 1455 .setSelfLink("selfLink1191800166") 1456 .setTargetLink("targetLink486368555") 1457 .setLocation("location1901043637") 1458 .setStartTime("startTime-2129294769") 1459 .setEndTime("endTime-1607243192") 1460 .setProgress(OperationProgress.newBuilder().build()) 1461 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1462 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1463 .setError(Status.newBuilder().build()) 1464 .build(); 1465 mockClusterManager.addResponse(expectedResponse); 1466 1467 SetMasterAuthRequest request = 1468 SetMasterAuthRequest.newBuilder() 1469 .setProjectId("projectId-894832108") 1470 .setZone("zone3744684") 1471 .setClusterId("clusterId561939637") 1472 .setUpdate(MasterAuth.newBuilder().build()) 1473 .setName("name3373707") 1474 .build(); 1475 1476 Operation actualResponse = client.setMasterAuth(request); 1477 Assert.assertEquals(expectedResponse, actualResponse); 1478 1479 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1480 Assert.assertEquals(1, actualRequests.size()); 1481 SetMasterAuthRequest actualRequest = ((SetMasterAuthRequest) actualRequests.get(0)); 1482 1483 Assert.assertEquals(request.getProjectId(), actualRequest.getProjectId()); 1484 Assert.assertEquals(request.getZone(), actualRequest.getZone()); 1485 Assert.assertEquals(request.getClusterId(), actualRequest.getClusterId()); 1486 Assert.assertEquals(request.getAction(), actualRequest.getAction()); 1487 Assert.assertEquals(request.getUpdate(), actualRequest.getUpdate()); 1488 Assert.assertEquals(request.getName(), actualRequest.getName()); 1489 Assert.assertTrue( 1490 channelProvider.isHeaderSent( 1491 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1492 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1493 } 1494 1495 @Test setMasterAuthExceptionTest()1496 public void setMasterAuthExceptionTest() throws Exception { 1497 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1498 mockClusterManager.addException(exception); 1499 1500 try { 1501 SetMasterAuthRequest request = 1502 SetMasterAuthRequest.newBuilder() 1503 .setProjectId("projectId-894832108") 1504 .setZone("zone3744684") 1505 .setClusterId("clusterId561939637") 1506 .setUpdate(MasterAuth.newBuilder().build()) 1507 .setName("name3373707") 1508 .build(); 1509 client.setMasterAuth(request); 1510 Assert.fail("No exception raised"); 1511 } catch (InvalidArgumentException e) { 1512 // Expected exception. 1513 } 1514 } 1515 1516 @Test deleteClusterTest()1517 public void deleteClusterTest() throws Exception { 1518 Operation expectedResponse = 1519 Operation.newBuilder() 1520 .setName("name3373707") 1521 .setZone("zone3744684") 1522 .setDetail("detail-1335224239") 1523 .setStatusMessage("statusMessage-958704715") 1524 .setSelfLink("selfLink1191800166") 1525 .setTargetLink("targetLink486368555") 1526 .setLocation("location1901043637") 1527 .setStartTime("startTime-2129294769") 1528 .setEndTime("endTime-1607243192") 1529 .setProgress(OperationProgress.newBuilder().build()) 1530 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1531 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1532 .setError(Status.newBuilder().build()) 1533 .build(); 1534 mockClusterManager.addResponse(expectedResponse); 1535 1536 String name = "name3373707"; 1537 1538 Operation actualResponse = client.deleteCluster(name); 1539 Assert.assertEquals(expectedResponse, actualResponse); 1540 1541 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1542 Assert.assertEquals(1, actualRequests.size()); 1543 DeleteClusterRequest actualRequest = ((DeleteClusterRequest) actualRequests.get(0)); 1544 1545 Assert.assertEquals(name, actualRequest.getName()); 1546 Assert.assertTrue( 1547 channelProvider.isHeaderSent( 1548 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1549 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1550 } 1551 1552 @Test deleteClusterExceptionTest()1553 public void deleteClusterExceptionTest() throws Exception { 1554 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1555 mockClusterManager.addException(exception); 1556 1557 try { 1558 String name = "name3373707"; 1559 client.deleteCluster(name); 1560 Assert.fail("No exception raised"); 1561 } catch (InvalidArgumentException e) { 1562 // Expected exception. 1563 } 1564 } 1565 1566 @Test deleteClusterTest2()1567 public void deleteClusterTest2() throws Exception { 1568 Operation expectedResponse = 1569 Operation.newBuilder() 1570 .setName("name3373707") 1571 .setZone("zone3744684") 1572 .setDetail("detail-1335224239") 1573 .setStatusMessage("statusMessage-958704715") 1574 .setSelfLink("selfLink1191800166") 1575 .setTargetLink("targetLink486368555") 1576 .setLocation("location1901043637") 1577 .setStartTime("startTime-2129294769") 1578 .setEndTime("endTime-1607243192") 1579 .setProgress(OperationProgress.newBuilder().build()) 1580 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1581 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1582 .setError(Status.newBuilder().build()) 1583 .build(); 1584 mockClusterManager.addResponse(expectedResponse); 1585 1586 String projectId = "projectId-894832108"; 1587 String zone = "zone3744684"; 1588 String clusterId = "clusterId561939637"; 1589 1590 Operation actualResponse = client.deleteCluster(projectId, zone, clusterId); 1591 Assert.assertEquals(expectedResponse, actualResponse); 1592 1593 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1594 Assert.assertEquals(1, actualRequests.size()); 1595 DeleteClusterRequest actualRequest = ((DeleteClusterRequest) actualRequests.get(0)); 1596 1597 Assert.assertEquals(projectId, actualRequest.getProjectId()); 1598 Assert.assertEquals(zone, actualRequest.getZone()); 1599 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 1600 Assert.assertTrue( 1601 channelProvider.isHeaderSent( 1602 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1603 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1604 } 1605 1606 @Test deleteClusterExceptionTest2()1607 public void deleteClusterExceptionTest2() throws Exception { 1608 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1609 mockClusterManager.addException(exception); 1610 1611 try { 1612 String projectId = "projectId-894832108"; 1613 String zone = "zone3744684"; 1614 String clusterId = "clusterId561939637"; 1615 client.deleteCluster(projectId, zone, clusterId); 1616 Assert.fail("No exception raised"); 1617 } catch (InvalidArgumentException e) { 1618 // Expected exception. 1619 } 1620 } 1621 1622 @Test listOperationsTest()1623 public void listOperationsTest() throws Exception { 1624 ListOperationsResponse expectedResponse = 1625 ListOperationsResponse.newBuilder() 1626 .addAllOperations(new ArrayList<Operation>()) 1627 .addAllMissingZones(new ArrayList<String>()) 1628 .build(); 1629 mockClusterManager.addResponse(expectedResponse); 1630 1631 String projectId = "projectId-894832108"; 1632 String zone = "zone3744684"; 1633 1634 ListOperationsResponse actualResponse = client.listOperations(projectId, zone); 1635 Assert.assertEquals(expectedResponse, actualResponse); 1636 1637 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1638 Assert.assertEquals(1, actualRequests.size()); 1639 ListOperationsRequest actualRequest = ((ListOperationsRequest) actualRequests.get(0)); 1640 1641 Assert.assertEquals(projectId, actualRequest.getProjectId()); 1642 Assert.assertEquals(zone, actualRequest.getZone()); 1643 Assert.assertTrue( 1644 channelProvider.isHeaderSent( 1645 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1646 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1647 } 1648 1649 @Test listOperationsExceptionTest()1650 public void listOperationsExceptionTest() throws Exception { 1651 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1652 mockClusterManager.addException(exception); 1653 1654 try { 1655 String projectId = "projectId-894832108"; 1656 String zone = "zone3744684"; 1657 client.listOperations(projectId, zone); 1658 Assert.fail("No exception raised"); 1659 } catch (InvalidArgumentException e) { 1660 // Expected exception. 1661 } 1662 } 1663 1664 @Test getOperationTest()1665 public void getOperationTest() throws Exception { 1666 Operation expectedResponse = 1667 Operation.newBuilder() 1668 .setName("name3373707") 1669 .setZone("zone3744684") 1670 .setDetail("detail-1335224239") 1671 .setStatusMessage("statusMessage-958704715") 1672 .setSelfLink("selfLink1191800166") 1673 .setTargetLink("targetLink486368555") 1674 .setLocation("location1901043637") 1675 .setStartTime("startTime-2129294769") 1676 .setEndTime("endTime-1607243192") 1677 .setProgress(OperationProgress.newBuilder().build()) 1678 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1679 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1680 .setError(Status.newBuilder().build()) 1681 .build(); 1682 mockClusterManager.addResponse(expectedResponse); 1683 1684 String name = "name3373707"; 1685 1686 Operation actualResponse = client.getOperation(name); 1687 Assert.assertEquals(expectedResponse, actualResponse); 1688 1689 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1690 Assert.assertEquals(1, actualRequests.size()); 1691 GetOperationRequest actualRequest = ((GetOperationRequest) actualRequests.get(0)); 1692 1693 Assert.assertEquals(name, actualRequest.getName()); 1694 Assert.assertTrue( 1695 channelProvider.isHeaderSent( 1696 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1697 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1698 } 1699 1700 @Test getOperationExceptionTest()1701 public void getOperationExceptionTest() throws Exception { 1702 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1703 mockClusterManager.addException(exception); 1704 1705 try { 1706 String name = "name3373707"; 1707 client.getOperation(name); 1708 Assert.fail("No exception raised"); 1709 } catch (InvalidArgumentException e) { 1710 // Expected exception. 1711 } 1712 } 1713 1714 @Test getOperationTest2()1715 public void getOperationTest2() throws Exception { 1716 Operation expectedResponse = 1717 Operation.newBuilder() 1718 .setName("name3373707") 1719 .setZone("zone3744684") 1720 .setDetail("detail-1335224239") 1721 .setStatusMessage("statusMessage-958704715") 1722 .setSelfLink("selfLink1191800166") 1723 .setTargetLink("targetLink486368555") 1724 .setLocation("location1901043637") 1725 .setStartTime("startTime-2129294769") 1726 .setEndTime("endTime-1607243192") 1727 .setProgress(OperationProgress.newBuilder().build()) 1728 .addAllClusterConditions(new ArrayList<StatusCondition>()) 1729 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 1730 .setError(Status.newBuilder().build()) 1731 .build(); 1732 mockClusterManager.addResponse(expectedResponse); 1733 1734 String projectId = "projectId-894832108"; 1735 String zone = "zone3744684"; 1736 String operationId = "operationId129704162"; 1737 1738 Operation actualResponse = client.getOperation(projectId, zone, operationId); 1739 Assert.assertEquals(expectedResponse, actualResponse); 1740 1741 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1742 Assert.assertEquals(1, actualRequests.size()); 1743 GetOperationRequest actualRequest = ((GetOperationRequest) actualRequests.get(0)); 1744 1745 Assert.assertEquals(projectId, actualRequest.getProjectId()); 1746 Assert.assertEquals(zone, actualRequest.getZone()); 1747 Assert.assertEquals(operationId, actualRequest.getOperationId()); 1748 Assert.assertTrue( 1749 channelProvider.isHeaderSent( 1750 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1751 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1752 } 1753 1754 @Test getOperationExceptionTest2()1755 public void getOperationExceptionTest2() throws Exception { 1756 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1757 mockClusterManager.addException(exception); 1758 1759 try { 1760 String projectId = "projectId-894832108"; 1761 String zone = "zone3744684"; 1762 String operationId = "operationId129704162"; 1763 client.getOperation(projectId, zone, operationId); 1764 Assert.fail("No exception raised"); 1765 } catch (InvalidArgumentException e) { 1766 // Expected exception. 1767 } 1768 } 1769 1770 @Test cancelOperationTest()1771 public void cancelOperationTest() throws Exception { 1772 Empty expectedResponse = Empty.newBuilder().build(); 1773 mockClusterManager.addResponse(expectedResponse); 1774 1775 String name = "name3373707"; 1776 1777 client.cancelOperation(name); 1778 1779 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1780 Assert.assertEquals(1, actualRequests.size()); 1781 CancelOperationRequest actualRequest = ((CancelOperationRequest) actualRequests.get(0)); 1782 1783 Assert.assertEquals(name, actualRequest.getName()); 1784 Assert.assertTrue( 1785 channelProvider.isHeaderSent( 1786 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1787 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1788 } 1789 1790 @Test cancelOperationExceptionTest()1791 public void cancelOperationExceptionTest() throws Exception { 1792 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1793 mockClusterManager.addException(exception); 1794 1795 try { 1796 String name = "name3373707"; 1797 client.cancelOperation(name); 1798 Assert.fail("No exception raised"); 1799 } catch (InvalidArgumentException e) { 1800 // Expected exception. 1801 } 1802 } 1803 1804 @Test cancelOperationTest2()1805 public void cancelOperationTest2() throws Exception { 1806 Empty expectedResponse = Empty.newBuilder().build(); 1807 mockClusterManager.addResponse(expectedResponse); 1808 1809 String projectId = "projectId-894832108"; 1810 String zone = "zone3744684"; 1811 String operationId = "operationId129704162"; 1812 1813 client.cancelOperation(projectId, zone, operationId); 1814 1815 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1816 Assert.assertEquals(1, actualRequests.size()); 1817 CancelOperationRequest actualRequest = ((CancelOperationRequest) actualRequests.get(0)); 1818 1819 Assert.assertEquals(projectId, actualRequest.getProjectId()); 1820 Assert.assertEquals(zone, actualRequest.getZone()); 1821 Assert.assertEquals(operationId, actualRequest.getOperationId()); 1822 Assert.assertTrue( 1823 channelProvider.isHeaderSent( 1824 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1825 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1826 } 1827 1828 @Test cancelOperationExceptionTest2()1829 public void cancelOperationExceptionTest2() throws Exception { 1830 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1831 mockClusterManager.addException(exception); 1832 1833 try { 1834 String projectId = "projectId-894832108"; 1835 String zone = "zone3744684"; 1836 String operationId = "operationId129704162"; 1837 client.cancelOperation(projectId, zone, operationId); 1838 Assert.fail("No exception raised"); 1839 } catch (InvalidArgumentException e) { 1840 // Expected exception. 1841 } 1842 } 1843 1844 @Test getServerConfigTest()1845 public void getServerConfigTest() throws Exception { 1846 ServerConfig expectedResponse = 1847 ServerConfig.newBuilder() 1848 .setDefaultClusterVersion("defaultClusterVersion-2007666145") 1849 .addAllValidNodeVersions(new ArrayList<String>()) 1850 .setDefaultImageType("defaultImageType933054964") 1851 .addAllValidImageTypes(new ArrayList<String>()) 1852 .addAllValidMasterVersions(new ArrayList<String>()) 1853 .addAllChannels(new ArrayList<ServerConfig.ReleaseChannelConfig>()) 1854 .build(); 1855 mockClusterManager.addResponse(expectedResponse); 1856 1857 String name = "name3373707"; 1858 1859 ServerConfig actualResponse = client.getServerConfig(name); 1860 Assert.assertEquals(expectedResponse, actualResponse); 1861 1862 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1863 Assert.assertEquals(1, actualRequests.size()); 1864 GetServerConfigRequest actualRequest = ((GetServerConfigRequest) actualRequests.get(0)); 1865 1866 Assert.assertEquals(name, actualRequest.getName()); 1867 Assert.assertTrue( 1868 channelProvider.isHeaderSent( 1869 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1870 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1871 } 1872 1873 @Test getServerConfigExceptionTest()1874 public void getServerConfigExceptionTest() throws Exception { 1875 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1876 mockClusterManager.addException(exception); 1877 1878 try { 1879 String name = "name3373707"; 1880 client.getServerConfig(name); 1881 Assert.fail("No exception raised"); 1882 } catch (InvalidArgumentException e) { 1883 // Expected exception. 1884 } 1885 } 1886 1887 @Test getServerConfigTest2()1888 public void getServerConfigTest2() throws Exception { 1889 ServerConfig expectedResponse = 1890 ServerConfig.newBuilder() 1891 .setDefaultClusterVersion("defaultClusterVersion-2007666145") 1892 .addAllValidNodeVersions(new ArrayList<String>()) 1893 .setDefaultImageType("defaultImageType933054964") 1894 .addAllValidImageTypes(new ArrayList<String>()) 1895 .addAllValidMasterVersions(new ArrayList<String>()) 1896 .addAllChannels(new ArrayList<ServerConfig.ReleaseChannelConfig>()) 1897 .build(); 1898 mockClusterManager.addResponse(expectedResponse); 1899 1900 String projectId = "projectId-894832108"; 1901 String zone = "zone3744684"; 1902 1903 ServerConfig actualResponse = client.getServerConfig(projectId, zone); 1904 Assert.assertEquals(expectedResponse, actualResponse); 1905 1906 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1907 Assert.assertEquals(1, actualRequests.size()); 1908 GetServerConfigRequest actualRequest = ((GetServerConfigRequest) actualRequests.get(0)); 1909 1910 Assert.assertEquals(projectId, actualRequest.getProjectId()); 1911 Assert.assertEquals(zone, actualRequest.getZone()); 1912 Assert.assertTrue( 1913 channelProvider.isHeaderSent( 1914 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1915 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1916 } 1917 1918 @Test getServerConfigExceptionTest2()1919 public void getServerConfigExceptionTest2() throws Exception { 1920 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1921 mockClusterManager.addException(exception); 1922 1923 try { 1924 String projectId = "projectId-894832108"; 1925 String zone = "zone3744684"; 1926 client.getServerConfig(projectId, zone); 1927 Assert.fail("No exception raised"); 1928 } catch (InvalidArgumentException e) { 1929 // Expected exception. 1930 } 1931 } 1932 1933 @Test getJSONWebKeysTest()1934 public void getJSONWebKeysTest() throws Exception { 1935 GetJSONWebKeysResponse expectedResponse = 1936 GetJSONWebKeysResponse.newBuilder().addAllKeys(new ArrayList<Jwk>()).build(); 1937 mockClusterManager.addResponse(expectedResponse); 1938 1939 GetJSONWebKeysRequest request = 1940 GetJSONWebKeysRequest.newBuilder().setParent("parent-995424086").build(); 1941 1942 GetJSONWebKeysResponse actualResponse = client.getJSONWebKeys(request); 1943 Assert.assertEquals(expectedResponse, actualResponse); 1944 1945 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1946 Assert.assertEquals(1, actualRequests.size()); 1947 GetJSONWebKeysRequest actualRequest = ((GetJSONWebKeysRequest) actualRequests.get(0)); 1948 1949 Assert.assertEquals(request.getParent(), actualRequest.getParent()); 1950 Assert.assertTrue( 1951 channelProvider.isHeaderSent( 1952 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1953 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1954 } 1955 1956 @Test getJSONWebKeysExceptionTest()1957 public void getJSONWebKeysExceptionTest() throws Exception { 1958 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1959 mockClusterManager.addException(exception); 1960 1961 try { 1962 GetJSONWebKeysRequest request = 1963 GetJSONWebKeysRequest.newBuilder().setParent("parent-995424086").build(); 1964 client.getJSONWebKeys(request); 1965 Assert.fail("No exception raised"); 1966 } catch (InvalidArgumentException e) { 1967 // Expected exception. 1968 } 1969 } 1970 1971 @Test listNodePoolsTest()1972 public void listNodePoolsTest() throws Exception { 1973 ListNodePoolsResponse expectedResponse = 1974 ListNodePoolsResponse.newBuilder().addAllNodePools(new ArrayList<NodePool>()).build(); 1975 mockClusterManager.addResponse(expectedResponse); 1976 1977 String parent = "parent-995424086"; 1978 1979 ListNodePoolsResponse actualResponse = client.listNodePools(parent); 1980 Assert.assertEquals(expectedResponse, actualResponse); 1981 1982 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 1983 Assert.assertEquals(1, actualRequests.size()); 1984 ListNodePoolsRequest actualRequest = ((ListNodePoolsRequest) actualRequests.get(0)); 1985 1986 Assert.assertEquals(parent, actualRequest.getParent()); 1987 Assert.assertTrue( 1988 channelProvider.isHeaderSent( 1989 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 1990 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 1991 } 1992 1993 @Test listNodePoolsExceptionTest()1994 public void listNodePoolsExceptionTest() throws Exception { 1995 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 1996 mockClusterManager.addException(exception); 1997 1998 try { 1999 String parent = "parent-995424086"; 2000 client.listNodePools(parent); 2001 Assert.fail("No exception raised"); 2002 } catch (InvalidArgumentException e) { 2003 // Expected exception. 2004 } 2005 } 2006 2007 @Test listNodePoolsTest2()2008 public void listNodePoolsTest2() throws Exception { 2009 ListNodePoolsResponse expectedResponse = 2010 ListNodePoolsResponse.newBuilder().addAllNodePools(new ArrayList<NodePool>()).build(); 2011 mockClusterManager.addResponse(expectedResponse); 2012 2013 String projectId = "projectId-894832108"; 2014 String zone = "zone3744684"; 2015 String clusterId = "clusterId561939637"; 2016 2017 ListNodePoolsResponse actualResponse = client.listNodePools(projectId, zone, clusterId); 2018 Assert.assertEquals(expectedResponse, actualResponse); 2019 2020 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2021 Assert.assertEquals(1, actualRequests.size()); 2022 ListNodePoolsRequest actualRequest = ((ListNodePoolsRequest) actualRequests.get(0)); 2023 2024 Assert.assertEquals(projectId, actualRequest.getProjectId()); 2025 Assert.assertEquals(zone, actualRequest.getZone()); 2026 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 2027 Assert.assertTrue( 2028 channelProvider.isHeaderSent( 2029 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2030 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2031 } 2032 2033 @Test listNodePoolsExceptionTest2()2034 public void listNodePoolsExceptionTest2() throws Exception { 2035 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2036 mockClusterManager.addException(exception); 2037 2038 try { 2039 String projectId = "projectId-894832108"; 2040 String zone = "zone3744684"; 2041 String clusterId = "clusterId561939637"; 2042 client.listNodePools(projectId, zone, clusterId); 2043 Assert.fail("No exception raised"); 2044 } catch (InvalidArgumentException e) { 2045 // Expected exception. 2046 } 2047 } 2048 2049 @Test getNodePoolTest()2050 public void getNodePoolTest() throws Exception { 2051 NodePool expectedResponse = 2052 NodePool.newBuilder() 2053 .setName("name3373707") 2054 .setConfig(NodeConfig.newBuilder().build()) 2055 .setInitialNodeCount(1682564205) 2056 .addAllLocations(new ArrayList<String>()) 2057 .setNetworkConfig(NodeNetworkConfig.newBuilder().build()) 2058 .setSelfLink("selfLink1191800166") 2059 .setVersion("version351608024") 2060 .addAllInstanceGroupUrls(new ArrayList<String>()) 2061 .setStatusMessage("statusMessage-958704715") 2062 .setAutoscaling(NodePoolAutoscaling.newBuilder().build()) 2063 .setManagement(NodeManagement.newBuilder().build()) 2064 .setMaxPodsConstraint(MaxPodsConstraint.newBuilder().build()) 2065 .addAllConditions(new ArrayList<StatusCondition>()) 2066 .setPodIpv4CidrSize(1098768716) 2067 .setUpgradeSettings(NodePool.UpgradeSettings.newBuilder().build()) 2068 .setPlacementPolicy(NodePool.PlacementPolicy.newBuilder().build()) 2069 .setUpdateInfo(NodePool.UpdateInfo.newBuilder().build()) 2070 .setEtag("etag3123477") 2071 .build(); 2072 mockClusterManager.addResponse(expectedResponse); 2073 2074 String name = "name3373707"; 2075 2076 NodePool actualResponse = client.getNodePool(name); 2077 Assert.assertEquals(expectedResponse, actualResponse); 2078 2079 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2080 Assert.assertEquals(1, actualRequests.size()); 2081 GetNodePoolRequest actualRequest = ((GetNodePoolRequest) actualRequests.get(0)); 2082 2083 Assert.assertEquals(name, actualRequest.getName()); 2084 Assert.assertTrue( 2085 channelProvider.isHeaderSent( 2086 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2087 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2088 } 2089 2090 @Test getNodePoolExceptionTest()2091 public void getNodePoolExceptionTest() throws Exception { 2092 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2093 mockClusterManager.addException(exception); 2094 2095 try { 2096 String name = "name3373707"; 2097 client.getNodePool(name); 2098 Assert.fail("No exception raised"); 2099 } catch (InvalidArgumentException e) { 2100 // Expected exception. 2101 } 2102 } 2103 2104 @Test getNodePoolTest2()2105 public void getNodePoolTest2() throws Exception { 2106 NodePool expectedResponse = 2107 NodePool.newBuilder() 2108 .setName("name3373707") 2109 .setConfig(NodeConfig.newBuilder().build()) 2110 .setInitialNodeCount(1682564205) 2111 .addAllLocations(new ArrayList<String>()) 2112 .setNetworkConfig(NodeNetworkConfig.newBuilder().build()) 2113 .setSelfLink("selfLink1191800166") 2114 .setVersion("version351608024") 2115 .addAllInstanceGroupUrls(new ArrayList<String>()) 2116 .setStatusMessage("statusMessage-958704715") 2117 .setAutoscaling(NodePoolAutoscaling.newBuilder().build()) 2118 .setManagement(NodeManagement.newBuilder().build()) 2119 .setMaxPodsConstraint(MaxPodsConstraint.newBuilder().build()) 2120 .addAllConditions(new ArrayList<StatusCondition>()) 2121 .setPodIpv4CidrSize(1098768716) 2122 .setUpgradeSettings(NodePool.UpgradeSettings.newBuilder().build()) 2123 .setPlacementPolicy(NodePool.PlacementPolicy.newBuilder().build()) 2124 .setUpdateInfo(NodePool.UpdateInfo.newBuilder().build()) 2125 .setEtag("etag3123477") 2126 .build(); 2127 mockClusterManager.addResponse(expectedResponse); 2128 2129 String projectId = "projectId-894832108"; 2130 String zone = "zone3744684"; 2131 String clusterId = "clusterId561939637"; 2132 String nodePoolId = "nodePoolId1121557241"; 2133 2134 NodePool actualResponse = client.getNodePool(projectId, zone, clusterId, nodePoolId); 2135 Assert.assertEquals(expectedResponse, actualResponse); 2136 2137 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2138 Assert.assertEquals(1, actualRequests.size()); 2139 GetNodePoolRequest actualRequest = ((GetNodePoolRequest) actualRequests.get(0)); 2140 2141 Assert.assertEquals(projectId, actualRequest.getProjectId()); 2142 Assert.assertEquals(zone, actualRequest.getZone()); 2143 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 2144 Assert.assertEquals(nodePoolId, actualRequest.getNodePoolId()); 2145 Assert.assertTrue( 2146 channelProvider.isHeaderSent( 2147 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2148 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2149 } 2150 2151 @Test getNodePoolExceptionTest2()2152 public void getNodePoolExceptionTest2() throws Exception { 2153 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2154 mockClusterManager.addException(exception); 2155 2156 try { 2157 String projectId = "projectId-894832108"; 2158 String zone = "zone3744684"; 2159 String clusterId = "clusterId561939637"; 2160 String nodePoolId = "nodePoolId1121557241"; 2161 client.getNodePool(projectId, zone, clusterId, nodePoolId); 2162 Assert.fail("No exception raised"); 2163 } catch (InvalidArgumentException e) { 2164 // Expected exception. 2165 } 2166 } 2167 2168 @Test createNodePoolTest()2169 public void createNodePoolTest() throws Exception { 2170 Operation expectedResponse = 2171 Operation.newBuilder() 2172 .setName("name3373707") 2173 .setZone("zone3744684") 2174 .setDetail("detail-1335224239") 2175 .setStatusMessage("statusMessage-958704715") 2176 .setSelfLink("selfLink1191800166") 2177 .setTargetLink("targetLink486368555") 2178 .setLocation("location1901043637") 2179 .setStartTime("startTime-2129294769") 2180 .setEndTime("endTime-1607243192") 2181 .setProgress(OperationProgress.newBuilder().build()) 2182 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2183 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2184 .setError(Status.newBuilder().build()) 2185 .build(); 2186 mockClusterManager.addResponse(expectedResponse); 2187 2188 String parent = "parent-995424086"; 2189 NodePool nodePool = NodePool.newBuilder().build(); 2190 2191 Operation actualResponse = client.createNodePool(parent, nodePool); 2192 Assert.assertEquals(expectedResponse, actualResponse); 2193 2194 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2195 Assert.assertEquals(1, actualRequests.size()); 2196 CreateNodePoolRequest actualRequest = ((CreateNodePoolRequest) actualRequests.get(0)); 2197 2198 Assert.assertEquals(parent, actualRequest.getParent()); 2199 Assert.assertEquals(nodePool, actualRequest.getNodePool()); 2200 Assert.assertTrue( 2201 channelProvider.isHeaderSent( 2202 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2203 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2204 } 2205 2206 @Test createNodePoolExceptionTest()2207 public void createNodePoolExceptionTest() throws Exception { 2208 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2209 mockClusterManager.addException(exception); 2210 2211 try { 2212 String parent = "parent-995424086"; 2213 NodePool nodePool = NodePool.newBuilder().build(); 2214 client.createNodePool(parent, nodePool); 2215 Assert.fail("No exception raised"); 2216 } catch (InvalidArgumentException e) { 2217 // Expected exception. 2218 } 2219 } 2220 2221 @Test createNodePoolTest2()2222 public void createNodePoolTest2() throws Exception { 2223 Operation expectedResponse = 2224 Operation.newBuilder() 2225 .setName("name3373707") 2226 .setZone("zone3744684") 2227 .setDetail("detail-1335224239") 2228 .setStatusMessage("statusMessage-958704715") 2229 .setSelfLink("selfLink1191800166") 2230 .setTargetLink("targetLink486368555") 2231 .setLocation("location1901043637") 2232 .setStartTime("startTime-2129294769") 2233 .setEndTime("endTime-1607243192") 2234 .setProgress(OperationProgress.newBuilder().build()) 2235 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2236 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2237 .setError(Status.newBuilder().build()) 2238 .build(); 2239 mockClusterManager.addResponse(expectedResponse); 2240 2241 String projectId = "projectId-894832108"; 2242 String zone = "zone3744684"; 2243 String clusterId = "clusterId561939637"; 2244 NodePool nodePool = NodePool.newBuilder().build(); 2245 2246 Operation actualResponse = client.createNodePool(projectId, zone, clusterId, nodePool); 2247 Assert.assertEquals(expectedResponse, actualResponse); 2248 2249 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2250 Assert.assertEquals(1, actualRequests.size()); 2251 CreateNodePoolRequest actualRequest = ((CreateNodePoolRequest) actualRequests.get(0)); 2252 2253 Assert.assertEquals(projectId, actualRequest.getProjectId()); 2254 Assert.assertEquals(zone, actualRequest.getZone()); 2255 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 2256 Assert.assertEquals(nodePool, actualRequest.getNodePool()); 2257 Assert.assertTrue( 2258 channelProvider.isHeaderSent( 2259 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2260 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2261 } 2262 2263 @Test createNodePoolExceptionTest2()2264 public void createNodePoolExceptionTest2() throws Exception { 2265 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2266 mockClusterManager.addException(exception); 2267 2268 try { 2269 String projectId = "projectId-894832108"; 2270 String zone = "zone3744684"; 2271 String clusterId = "clusterId561939637"; 2272 NodePool nodePool = NodePool.newBuilder().build(); 2273 client.createNodePool(projectId, zone, clusterId, nodePool); 2274 Assert.fail("No exception raised"); 2275 } catch (InvalidArgumentException e) { 2276 // Expected exception. 2277 } 2278 } 2279 2280 @Test deleteNodePoolTest()2281 public void deleteNodePoolTest() throws Exception { 2282 Operation expectedResponse = 2283 Operation.newBuilder() 2284 .setName("name3373707") 2285 .setZone("zone3744684") 2286 .setDetail("detail-1335224239") 2287 .setStatusMessage("statusMessage-958704715") 2288 .setSelfLink("selfLink1191800166") 2289 .setTargetLink("targetLink486368555") 2290 .setLocation("location1901043637") 2291 .setStartTime("startTime-2129294769") 2292 .setEndTime("endTime-1607243192") 2293 .setProgress(OperationProgress.newBuilder().build()) 2294 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2295 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2296 .setError(Status.newBuilder().build()) 2297 .build(); 2298 mockClusterManager.addResponse(expectedResponse); 2299 2300 String name = "name3373707"; 2301 2302 Operation actualResponse = client.deleteNodePool(name); 2303 Assert.assertEquals(expectedResponse, actualResponse); 2304 2305 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2306 Assert.assertEquals(1, actualRequests.size()); 2307 DeleteNodePoolRequest actualRequest = ((DeleteNodePoolRequest) actualRequests.get(0)); 2308 2309 Assert.assertEquals(name, actualRequest.getName()); 2310 Assert.assertTrue( 2311 channelProvider.isHeaderSent( 2312 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2313 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2314 } 2315 2316 @Test deleteNodePoolExceptionTest()2317 public void deleteNodePoolExceptionTest() throws Exception { 2318 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2319 mockClusterManager.addException(exception); 2320 2321 try { 2322 String name = "name3373707"; 2323 client.deleteNodePool(name); 2324 Assert.fail("No exception raised"); 2325 } catch (InvalidArgumentException e) { 2326 // Expected exception. 2327 } 2328 } 2329 2330 @Test deleteNodePoolTest2()2331 public void deleteNodePoolTest2() throws Exception { 2332 Operation expectedResponse = 2333 Operation.newBuilder() 2334 .setName("name3373707") 2335 .setZone("zone3744684") 2336 .setDetail("detail-1335224239") 2337 .setStatusMessage("statusMessage-958704715") 2338 .setSelfLink("selfLink1191800166") 2339 .setTargetLink("targetLink486368555") 2340 .setLocation("location1901043637") 2341 .setStartTime("startTime-2129294769") 2342 .setEndTime("endTime-1607243192") 2343 .setProgress(OperationProgress.newBuilder().build()) 2344 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2345 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2346 .setError(Status.newBuilder().build()) 2347 .build(); 2348 mockClusterManager.addResponse(expectedResponse); 2349 2350 String projectId = "projectId-894832108"; 2351 String zone = "zone3744684"; 2352 String clusterId = "clusterId561939637"; 2353 String nodePoolId = "nodePoolId1121557241"; 2354 2355 Operation actualResponse = client.deleteNodePool(projectId, zone, clusterId, nodePoolId); 2356 Assert.assertEquals(expectedResponse, actualResponse); 2357 2358 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2359 Assert.assertEquals(1, actualRequests.size()); 2360 DeleteNodePoolRequest actualRequest = ((DeleteNodePoolRequest) actualRequests.get(0)); 2361 2362 Assert.assertEquals(projectId, actualRequest.getProjectId()); 2363 Assert.assertEquals(zone, actualRequest.getZone()); 2364 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 2365 Assert.assertEquals(nodePoolId, actualRequest.getNodePoolId()); 2366 Assert.assertTrue( 2367 channelProvider.isHeaderSent( 2368 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2369 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2370 } 2371 2372 @Test deleteNodePoolExceptionTest2()2373 public void deleteNodePoolExceptionTest2() throws Exception { 2374 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2375 mockClusterManager.addException(exception); 2376 2377 try { 2378 String projectId = "projectId-894832108"; 2379 String zone = "zone3744684"; 2380 String clusterId = "clusterId561939637"; 2381 String nodePoolId = "nodePoolId1121557241"; 2382 client.deleteNodePool(projectId, zone, clusterId, nodePoolId); 2383 Assert.fail("No exception raised"); 2384 } catch (InvalidArgumentException e) { 2385 // Expected exception. 2386 } 2387 } 2388 2389 @Test completeNodePoolUpgradeTest()2390 public void completeNodePoolUpgradeTest() throws Exception { 2391 Empty expectedResponse = Empty.newBuilder().build(); 2392 mockClusterManager.addResponse(expectedResponse); 2393 2394 CompleteNodePoolUpgradeRequest request = 2395 CompleteNodePoolUpgradeRequest.newBuilder().setName("name3373707").build(); 2396 2397 client.completeNodePoolUpgrade(request); 2398 2399 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2400 Assert.assertEquals(1, actualRequests.size()); 2401 CompleteNodePoolUpgradeRequest actualRequest = 2402 ((CompleteNodePoolUpgradeRequest) actualRequests.get(0)); 2403 2404 Assert.assertEquals(request.getName(), actualRequest.getName()); 2405 Assert.assertTrue( 2406 channelProvider.isHeaderSent( 2407 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2408 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2409 } 2410 2411 @Test completeNodePoolUpgradeExceptionTest()2412 public void completeNodePoolUpgradeExceptionTest() throws Exception { 2413 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2414 mockClusterManager.addException(exception); 2415 2416 try { 2417 CompleteNodePoolUpgradeRequest request = 2418 CompleteNodePoolUpgradeRequest.newBuilder().setName("name3373707").build(); 2419 client.completeNodePoolUpgrade(request); 2420 Assert.fail("No exception raised"); 2421 } catch (InvalidArgumentException e) { 2422 // Expected exception. 2423 } 2424 } 2425 2426 @Test rollbackNodePoolUpgradeTest()2427 public void rollbackNodePoolUpgradeTest() throws Exception { 2428 Operation expectedResponse = 2429 Operation.newBuilder() 2430 .setName("name3373707") 2431 .setZone("zone3744684") 2432 .setDetail("detail-1335224239") 2433 .setStatusMessage("statusMessage-958704715") 2434 .setSelfLink("selfLink1191800166") 2435 .setTargetLink("targetLink486368555") 2436 .setLocation("location1901043637") 2437 .setStartTime("startTime-2129294769") 2438 .setEndTime("endTime-1607243192") 2439 .setProgress(OperationProgress.newBuilder().build()) 2440 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2441 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2442 .setError(Status.newBuilder().build()) 2443 .build(); 2444 mockClusterManager.addResponse(expectedResponse); 2445 2446 String name = "name3373707"; 2447 2448 Operation actualResponse = client.rollbackNodePoolUpgrade(name); 2449 Assert.assertEquals(expectedResponse, actualResponse); 2450 2451 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2452 Assert.assertEquals(1, actualRequests.size()); 2453 RollbackNodePoolUpgradeRequest actualRequest = 2454 ((RollbackNodePoolUpgradeRequest) actualRequests.get(0)); 2455 2456 Assert.assertEquals(name, actualRequest.getName()); 2457 Assert.assertTrue( 2458 channelProvider.isHeaderSent( 2459 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2460 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2461 } 2462 2463 @Test rollbackNodePoolUpgradeExceptionTest()2464 public void rollbackNodePoolUpgradeExceptionTest() throws Exception { 2465 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2466 mockClusterManager.addException(exception); 2467 2468 try { 2469 String name = "name3373707"; 2470 client.rollbackNodePoolUpgrade(name); 2471 Assert.fail("No exception raised"); 2472 } catch (InvalidArgumentException e) { 2473 // Expected exception. 2474 } 2475 } 2476 2477 @Test rollbackNodePoolUpgradeTest2()2478 public void rollbackNodePoolUpgradeTest2() throws Exception { 2479 Operation expectedResponse = 2480 Operation.newBuilder() 2481 .setName("name3373707") 2482 .setZone("zone3744684") 2483 .setDetail("detail-1335224239") 2484 .setStatusMessage("statusMessage-958704715") 2485 .setSelfLink("selfLink1191800166") 2486 .setTargetLink("targetLink486368555") 2487 .setLocation("location1901043637") 2488 .setStartTime("startTime-2129294769") 2489 .setEndTime("endTime-1607243192") 2490 .setProgress(OperationProgress.newBuilder().build()) 2491 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2492 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2493 .setError(Status.newBuilder().build()) 2494 .build(); 2495 mockClusterManager.addResponse(expectedResponse); 2496 2497 String projectId = "projectId-894832108"; 2498 String zone = "zone3744684"; 2499 String clusterId = "clusterId561939637"; 2500 String nodePoolId = "nodePoolId1121557241"; 2501 2502 Operation actualResponse = 2503 client.rollbackNodePoolUpgrade(projectId, zone, clusterId, nodePoolId); 2504 Assert.assertEquals(expectedResponse, actualResponse); 2505 2506 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2507 Assert.assertEquals(1, actualRequests.size()); 2508 RollbackNodePoolUpgradeRequest actualRequest = 2509 ((RollbackNodePoolUpgradeRequest) actualRequests.get(0)); 2510 2511 Assert.assertEquals(projectId, actualRequest.getProjectId()); 2512 Assert.assertEquals(zone, actualRequest.getZone()); 2513 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 2514 Assert.assertEquals(nodePoolId, actualRequest.getNodePoolId()); 2515 Assert.assertTrue( 2516 channelProvider.isHeaderSent( 2517 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2518 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2519 } 2520 2521 @Test rollbackNodePoolUpgradeExceptionTest2()2522 public void rollbackNodePoolUpgradeExceptionTest2() throws Exception { 2523 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2524 mockClusterManager.addException(exception); 2525 2526 try { 2527 String projectId = "projectId-894832108"; 2528 String zone = "zone3744684"; 2529 String clusterId = "clusterId561939637"; 2530 String nodePoolId = "nodePoolId1121557241"; 2531 client.rollbackNodePoolUpgrade(projectId, zone, clusterId, nodePoolId); 2532 Assert.fail("No exception raised"); 2533 } catch (InvalidArgumentException e) { 2534 // Expected exception. 2535 } 2536 } 2537 2538 @Test setNodePoolManagementTest()2539 public void setNodePoolManagementTest() throws Exception { 2540 Operation expectedResponse = 2541 Operation.newBuilder() 2542 .setName("name3373707") 2543 .setZone("zone3744684") 2544 .setDetail("detail-1335224239") 2545 .setStatusMessage("statusMessage-958704715") 2546 .setSelfLink("selfLink1191800166") 2547 .setTargetLink("targetLink486368555") 2548 .setLocation("location1901043637") 2549 .setStartTime("startTime-2129294769") 2550 .setEndTime("endTime-1607243192") 2551 .setProgress(OperationProgress.newBuilder().build()) 2552 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2553 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2554 .setError(Status.newBuilder().build()) 2555 .build(); 2556 mockClusterManager.addResponse(expectedResponse); 2557 2558 SetNodePoolManagementRequest request = 2559 SetNodePoolManagementRequest.newBuilder() 2560 .setProjectId("projectId-894832108") 2561 .setZone("zone3744684") 2562 .setClusterId("clusterId561939637") 2563 .setNodePoolId("nodePoolId1121557241") 2564 .setManagement(NodeManagement.newBuilder().build()) 2565 .setName("name3373707") 2566 .build(); 2567 2568 Operation actualResponse = client.setNodePoolManagement(request); 2569 Assert.assertEquals(expectedResponse, actualResponse); 2570 2571 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2572 Assert.assertEquals(1, actualRequests.size()); 2573 SetNodePoolManagementRequest actualRequest = 2574 ((SetNodePoolManagementRequest) actualRequests.get(0)); 2575 2576 Assert.assertEquals(request.getProjectId(), actualRequest.getProjectId()); 2577 Assert.assertEquals(request.getZone(), actualRequest.getZone()); 2578 Assert.assertEquals(request.getClusterId(), actualRequest.getClusterId()); 2579 Assert.assertEquals(request.getNodePoolId(), actualRequest.getNodePoolId()); 2580 Assert.assertEquals(request.getManagement(), actualRequest.getManagement()); 2581 Assert.assertEquals(request.getName(), actualRequest.getName()); 2582 Assert.assertTrue( 2583 channelProvider.isHeaderSent( 2584 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2585 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2586 } 2587 2588 @Test setNodePoolManagementExceptionTest()2589 public void setNodePoolManagementExceptionTest() throws Exception { 2590 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2591 mockClusterManager.addException(exception); 2592 2593 try { 2594 SetNodePoolManagementRequest request = 2595 SetNodePoolManagementRequest.newBuilder() 2596 .setProjectId("projectId-894832108") 2597 .setZone("zone3744684") 2598 .setClusterId("clusterId561939637") 2599 .setNodePoolId("nodePoolId1121557241") 2600 .setManagement(NodeManagement.newBuilder().build()) 2601 .setName("name3373707") 2602 .build(); 2603 client.setNodePoolManagement(request); 2604 Assert.fail("No exception raised"); 2605 } catch (InvalidArgumentException e) { 2606 // Expected exception. 2607 } 2608 } 2609 2610 @Test setLabelsTest()2611 public void setLabelsTest() throws Exception { 2612 Operation expectedResponse = 2613 Operation.newBuilder() 2614 .setName("name3373707") 2615 .setZone("zone3744684") 2616 .setDetail("detail-1335224239") 2617 .setStatusMessage("statusMessage-958704715") 2618 .setSelfLink("selfLink1191800166") 2619 .setTargetLink("targetLink486368555") 2620 .setLocation("location1901043637") 2621 .setStartTime("startTime-2129294769") 2622 .setEndTime("endTime-1607243192") 2623 .setProgress(OperationProgress.newBuilder().build()) 2624 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2625 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2626 .setError(Status.newBuilder().build()) 2627 .build(); 2628 mockClusterManager.addResponse(expectedResponse); 2629 2630 SetLabelsRequest request = 2631 SetLabelsRequest.newBuilder() 2632 .setProjectId("projectId-894832108") 2633 .setZone("zone3744684") 2634 .setClusterId("clusterId561939637") 2635 .putAllResourceLabels(new HashMap<String, String>()) 2636 .setLabelFingerprint("labelFingerprint379449680") 2637 .setName("name3373707") 2638 .build(); 2639 2640 Operation actualResponse = client.setLabels(request); 2641 Assert.assertEquals(expectedResponse, actualResponse); 2642 2643 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2644 Assert.assertEquals(1, actualRequests.size()); 2645 SetLabelsRequest actualRequest = ((SetLabelsRequest) actualRequests.get(0)); 2646 2647 Assert.assertEquals(request.getProjectId(), actualRequest.getProjectId()); 2648 Assert.assertEquals(request.getZone(), actualRequest.getZone()); 2649 Assert.assertEquals(request.getClusterId(), actualRequest.getClusterId()); 2650 Assert.assertEquals(request.getResourceLabelsMap(), actualRequest.getResourceLabelsMap()); 2651 Assert.assertEquals(request.getLabelFingerprint(), actualRequest.getLabelFingerprint()); 2652 Assert.assertEquals(request.getName(), actualRequest.getName()); 2653 Assert.assertTrue( 2654 channelProvider.isHeaderSent( 2655 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2656 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2657 } 2658 2659 @Test setLabelsExceptionTest()2660 public void setLabelsExceptionTest() throws Exception { 2661 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2662 mockClusterManager.addException(exception); 2663 2664 try { 2665 SetLabelsRequest request = 2666 SetLabelsRequest.newBuilder() 2667 .setProjectId("projectId-894832108") 2668 .setZone("zone3744684") 2669 .setClusterId("clusterId561939637") 2670 .putAllResourceLabels(new HashMap<String, String>()) 2671 .setLabelFingerprint("labelFingerprint379449680") 2672 .setName("name3373707") 2673 .build(); 2674 client.setLabels(request); 2675 Assert.fail("No exception raised"); 2676 } catch (InvalidArgumentException e) { 2677 // Expected exception. 2678 } 2679 } 2680 2681 @Test setLegacyAbacTest()2682 public void setLegacyAbacTest() throws Exception { 2683 Operation expectedResponse = 2684 Operation.newBuilder() 2685 .setName("name3373707") 2686 .setZone("zone3744684") 2687 .setDetail("detail-1335224239") 2688 .setStatusMessage("statusMessage-958704715") 2689 .setSelfLink("selfLink1191800166") 2690 .setTargetLink("targetLink486368555") 2691 .setLocation("location1901043637") 2692 .setStartTime("startTime-2129294769") 2693 .setEndTime("endTime-1607243192") 2694 .setProgress(OperationProgress.newBuilder().build()) 2695 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2696 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2697 .setError(Status.newBuilder().build()) 2698 .build(); 2699 mockClusterManager.addResponse(expectedResponse); 2700 2701 String name = "name3373707"; 2702 boolean enabled = true; 2703 2704 Operation actualResponse = client.setLegacyAbac(name, enabled); 2705 Assert.assertEquals(expectedResponse, actualResponse); 2706 2707 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2708 Assert.assertEquals(1, actualRequests.size()); 2709 SetLegacyAbacRequest actualRequest = ((SetLegacyAbacRequest) actualRequests.get(0)); 2710 2711 Assert.assertEquals(name, actualRequest.getName()); 2712 Assert.assertEquals(enabled, actualRequest.getEnabled()); 2713 Assert.assertTrue( 2714 channelProvider.isHeaderSent( 2715 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2716 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2717 } 2718 2719 @Test setLegacyAbacExceptionTest()2720 public void setLegacyAbacExceptionTest() throws Exception { 2721 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2722 mockClusterManager.addException(exception); 2723 2724 try { 2725 String name = "name3373707"; 2726 boolean enabled = true; 2727 client.setLegacyAbac(name, enabled); 2728 Assert.fail("No exception raised"); 2729 } catch (InvalidArgumentException e) { 2730 // Expected exception. 2731 } 2732 } 2733 2734 @Test setLegacyAbacTest2()2735 public void setLegacyAbacTest2() throws Exception { 2736 Operation expectedResponse = 2737 Operation.newBuilder() 2738 .setName("name3373707") 2739 .setZone("zone3744684") 2740 .setDetail("detail-1335224239") 2741 .setStatusMessage("statusMessage-958704715") 2742 .setSelfLink("selfLink1191800166") 2743 .setTargetLink("targetLink486368555") 2744 .setLocation("location1901043637") 2745 .setStartTime("startTime-2129294769") 2746 .setEndTime("endTime-1607243192") 2747 .setProgress(OperationProgress.newBuilder().build()) 2748 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2749 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2750 .setError(Status.newBuilder().build()) 2751 .build(); 2752 mockClusterManager.addResponse(expectedResponse); 2753 2754 String projectId = "projectId-894832108"; 2755 String zone = "zone3744684"; 2756 String clusterId = "clusterId561939637"; 2757 boolean enabled = true; 2758 2759 Operation actualResponse = client.setLegacyAbac(projectId, zone, clusterId, enabled); 2760 Assert.assertEquals(expectedResponse, actualResponse); 2761 2762 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2763 Assert.assertEquals(1, actualRequests.size()); 2764 SetLegacyAbacRequest actualRequest = ((SetLegacyAbacRequest) actualRequests.get(0)); 2765 2766 Assert.assertEquals(projectId, actualRequest.getProjectId()); 2767 Assert.assertEquals(zone, actualRequest.getZone()); 2768 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 2769 Assert.assertEquals(enabled, actualRequest.getEnabled()); 2770 Assert.assertTrue( 2771 channelProvider.isHeaderSent( 2772 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2773 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2774 } 2775 2776 @Test setLegacyAbacExceptionTest2()2777 public void setLegacyAbacExceptionTest2() throws Exception { 2778 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2779 mockClusterManager.addException(exception); 2780 2781 try { 2782 String projectId = "projectId-894832108"; 2783 String zone = "zone3744684"; 2784 String clusterId = "clusterId561939637"; 2785 boolean enabled = true; 2786 client.setLegacyAbac(projectId, zone, clusterId, enabled); 2787 Assert.fail("No exception raised"); 2788 } catch (InvalidArgumentException e) { 2789 // Expected exception. 2790 } 2791 } 2792 2793 @Test startIPRotationTest()2794 public void startIPRotationTest() throws Exception { 2795 Operation expectedResponse = 2796 Operation.newBuilder() 2797 .setName("name3373707") 2798 .setZone("zone3744684") 2799 .setDetail("detail-1335224239") 2800 .setStatusMessage("statusMessage-958704715") 2801 .setSelfLink("selfLink1191800166") 2802 .setTargetLink("targetLink486368555") 2803 .setLocation("location1901043637") 2804 .setStartTime("startTime-2129294769") 2805 .setEndTime("endTime-1607243192") 2806 .setProgress(OperationProgress.newBuilder().build()) 2807 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2808 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2809 .setError(Status.newBuilder().build()) 2810 .build(); 2811 mockClusterManager.addResponse(expectedResponse); 2812 2813 String name = "name3373707"; 2814 2815 Operation actualResponse = client.startIPRotation(name); 2816 Assert.assertEquals(expectedResponse, actualResponse); 2817 2818 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2819 Assert.assertEquals(1, actualRequests.size()); 2820 StartIPRotationRequest actualRequest = ((StartIPRotationRequest) actualRequests.get(0)); 2821 2822 Assert.assertEquals(name, actualRequest.getName()); 2823 Assert.assertTrue( 2824 channelProvider.isHeaderSent( 2825 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2826 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2827 } 2828 2829 @Test startIPRotationExceptionTest()2830 public void startIPRotationExceptionTest() throws Exception { 2831 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2832 mockClusterManager.addException(exception); 2833 2834 try { 2835 String name = "name3373707"; 2836 client.startIPRotation(name); 2837 Assert.fail("No exception raised"); 2838 } catch (InvalidArgumentException e) { 2839 // Expected exception. 2840 } 2841 } 2842 2843 @Test startIPRotationTest2()2844 public void startIPRotationTest2() throws Exception { 2845 Operation expectedResponse = 2846 Operation.newBuilder() 2847 .setName("name3373707") 2848 .setZone("zone3744684") 2849 .setDetail("detail-1335224239") 2850 .setStatusMessage("statusMessage-958704715") 2851 .setSelfLink("selfLink1191800166") 2852 .setTargetLink("targetLink486368555") 2853 .setLocation("location1901043637") 2854 .setStartTime("startTime-2129294769") 2855 .setEndTime("endTime-1607243192") 2856 .setProgress(OperationProgress.newBuilder().build()) 2857 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2858 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2859 .setError(Status.newBuilder().build()) 2860 .build(); 2861 mockClusterManager.addResponse(expectedResponse); 2862 2863 String projectId = "projectId-894832108"; 2864 String zone = "zone3744684"; 2865 String clusterId = "clusterId561939637"; 2866 2867 Operation actualResponse = client.startIPRotation(projectId, zone, clusterId); 2868 Assert.assertEquals(expectedResponse, actualResponse); 2869 2870 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2871 Assert.assertEquals(1, actualRequests.size()); 2872 StartIPRotationRequest actualRequest = ((StartIPRotationRequest) actualRequests.get(0)); 2873 2874 Assert.assertEquals(projectId, actualRequest.getProjectId()); 2875 Assert.assertEquals(zone, actualRequest.getZone()); 2876 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 2877 Assert.assertTrue( 2878 channelProvider.isHeaderSent( 2879 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2880 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2881 } 2882 2883 @Test startIPRotationExceptionTest2()2884 public void startIPRotationExceptionTest2() throws Exception { 2885 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2886 mockClusterManager.addException(exception); 2887 2888 try { 2889 String projectId = "projectId-894832108"; 2890 String zone = "zone3744684"; 2891 String clusterId = "clusterId561939637"; 2892 client.startIPRotation(projectId, zone, clusterId); 2893 Assert.fail("No exception raised"); 2894 } catch (InvalidArgumentException e) { 2895 // Expected exception. 2896 } 2897 } 2898 2899 @Test completeIPRotationTest()2900 public void completeIPRotationTest() throws Exception { 2901 Operation expectedResponse = 2902 Operation.newBuilder() 2903 .setName("name3373707") 2904 .setZone("zone3744684") 2905 .setDetail("detail-1335224239") 2906 .setStatusMessage("statusMessage-958704715") 2907 .setSelfLink("selfLink1191800166") 2908 .setTargetLink("targetLink486368555") 2909 .setLocation("location1901043637") 2910 .setStartTime("startTime-2129294769") 2911 .setEndTime("endTime-1607243192") 2912 .setProgress(OperationProgress.newBuilder().build()) 2913 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2914 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2915 .setError(Status.newBuilder().build()) 2916 .build(); 2917 mockClusterManager.addResponse(expectedResponse); 2918 2919 String name = "name3373707"; 2920 2921 Operation actualResponse = client.completeIPRotation(name); 2922 Assert.assertEquals(expectedResponse, actualResponse); 2923 2924 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2925 Assert.assertEquals(1, actualRequests.size()); 2926 CompleteIPRotationRequest actualRequest = ((CompleteIPRotationRequest) actualRequests.get(0)); 2927 2928 Assert.assertEquals(name, actualRequest.getName()); 2929 Assert.assertTrue( 2930 channelProvider.isHeaderSent( 2931 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2932 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2933 } 2934 2935 @Test completeIPRotationExceptionTest()2936 public void completeIPRotationExceptionTest() throws Exception { 2937 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2938 mockClusterManager.addException(exception); 2939 2940 try { 2941 String name = "name3373707"; 2942 client.completeIPRotation(name); 2943 Assert.fail("No exception raised"); 2944 } catch (InvalidArgumentException e) { 2945 // Expected exception. 2946 } 2947 } 2948 2949 @Test completeIPRotationTest2()2950 public void completeIPRotationTest2() throws Exception { 2951 Operation expectedResponse = 2952 Operation.newBuilder() 2953 .setName("name3373707") 2954 .setZone("zone3744684") 2955 .setDetail("detail-1335224239") 2956 .setStatusMessage("statusMessage-958704715") 2957 .setSelfLink("selfLink1191800166") 2958 .setTargetLink("targetLink486368555") 2959 .setLocation("location1901043637") 2960 .setStartTime("startTime-2129294769") 2961 .setEndTime("endTime-1607243192") 2962 .setProgress(OperationProgress.newBuilder().build()) 2963 .addAllClusterConditions(new ArrayList<StatusCondition>()) 2964 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 2965 .setError(Status.newBuilder().build()) 2966 .build(); 2967 mockClusterManager.addResponse(expectedResponse); 2968 2969 String projectId = "projectId-894832108"; 2970 String zone = "zone3744684"; 2971 String clusterId = "clusterId561939637"; 2972 2973 Operation actualResponse = client.completeIPRotation(projectId, zone, clusterId); 2974 Assert.assertEquals(expectedResponse, actualResponse); 2975 2976 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 2977 Assert.assertEquals(1, actualRequests.size()); 2978 CompleteIPRotationRequest actualRequest = ((CompleteIPRotationRequest) actualRequests.get(0)); 2979 2980 Assert.assertEquals(projectId, actualRequest.getProjectId()); 2981 Assert.assertEquals(zone, actualRequest.getZone()); 2982 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 2983 Assert.assertTrue( 2984 channelProvider.isHeaderSent( 2985 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 2986 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 2987 } 2988 2989 @Test completeIPRotationExceptionTest2()2990 public void completeIPRotationExceptionTest2() throws Exception { 2991 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 2992 mockClusterManager.addException(exception); 2993 2994 try { 2995 String projectId = "projectId-894832108"; 2996 String zone = "zone3744684"; 2997 String clusterId = "clusterId561939637"; 2998 client.completeIPRotation(projectId, zone, clusterId); 2999 Assert.fail("No exception raised"); 3000 } catch (InvalidArgumentException e) { 3001 // Expected exception. 3002 } 3003 } 3004 3005 @Test setNodePoolSizeTest()3006 public void setNodePoolSizeTest() throws Exception { 3007 Operation expectedResponse = 3008 Operation.newBuilder() 3009 .setName("name3373707") 3010 .setZone("zone3744684") 3011 .setDetail("detail-1335224239") 3012 .setStatusMessage("statusMessage-958704715") 3013 .setSelfLink("selfLink1191800166") 3014 .setTargetLink("targetLink486368555") 3015 .setLocation("location1901043637") 3016 .setStartTime("startTime-2129294769") 3017 .setEndTime("endTime-1607243192") 3018 .setProgress(OperationProgress.newBuilder().build()) 3019 .addAllClusterConditions(new ArrayList<StatusCondition>()) 3020 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 3021 .setError(Status.newBuilder().build()) 3022 .build(); 3023 mockClusterManager.addResponse(expectedResponse); 3024 3025 SetNodePoolSizeRequest request = 3026 SetNodePoolSizeRequest.newBuilder() 3027 .setProjectId("projectId-894832108") 3028 .setZone("zone3744684") 3029 .setClusterId("clusterId561939637") 3030 .setNodePoolId("nodePoolId1121557241") 3031 .setNodeCount(1539922066) 3032 .setName("name3373707") 3033 .build(); 3034 3035 Operation actualResponse = client.setNodePoolSize(request); 3036 Assert.assertEquals(expectedResponse, actualResponse); 3037 3038 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 3039 Assert.assertEquals(1, actualRequests.size()); 3040 SetNodePoolSizeRequest actualRequest = ((SetNodePoolSizeRequest) actualRequests.get(0)); 3041 3042 Assert.assertEquals(request.getProjectId(), actualRequest.getProjectId()); 3043 Assert.assertEquals(request.getZone(), actualRequest.getZone()); 3044 Assert.assertEquals(request.getClusterId(), actualRequest.getClusterId()); 3045 Assert.assertEquals(request.getNodePoolId(), actualRequest.getNodePoolId()); 3046 Assert.assertEquals(request.getNodeCount(), actualRequest.getNodeCount()); 3047 Assert.assertEquals(request.getName(), actualRequest.getName()); 3048 Assert.assertTrue( 3049 channelProvider.isHeaderSent( 3050 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 3051 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 3052 } 3053 3054 @Test setNodePoolSizeExceptionTest()3055 public void setNodePoolSizeExceptionTest() throws Exception { 3056 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 3057 mockClusterManager.addException(exception); 3058 3059 try { 3060 SetNodePoolSizeRequest request = 3061 SetNodePoolSizeRequest.newBuilder() 3062 .setProjectId("projectId-894832108") 3063 .setZone("zone3744684") 3064 .setClusterId("clusterId561939637") 3065 .setNodePoolId("nodePoolId1121557241") 3066 .setNodeCount(1539922066) 3067 .setName("name3373707") 3068 .build(); 3069 client.setNodePoolSize(request); 3070 Assert.fail("No exception raised"); 3071 } catch (InvalidArgumentException e) { 3072 // Expected exception. 3073 } 3074 } 3075 3076 @Test setNetworkPolicyTest()3077 public void setNetworkPolicyTest() throws Exception { 3078 Operation expectedResponse = 3079 Operation.newBuilder() 3080 .setName("name3373707") 3081 .setZone("zone3744684") 3082 .setDetail("detail-1335224239") 3083 .setStatusMessage("statusMessage-958704715") 3084 .setSelfLink("selfLink1191800166") 3085 .setTargetLink("targetLink486368555") 3086 .setLocation("location1901043637") 3087 .setStartTime("startTime-2129294769") 3088 .setEndTime("endTime-1607243192") 3089 .setProgress(OperationProgress.newBuilder().build()) 3090 .addAllClusterConditions(new ArrayList<StatusCondition>()) 3091 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 3092 .setError(Status.newBuilder().build()) 3093 .build(); 3094 mockClusterManager.addResponse(expectedResponse); 3095 3096 String name = "name3373707"; 3097 NetworkPolicy networkPolicy = NetworkPolicy.newBuilder().build(); 3098 3099 Operation actualResponse = client.setNetworkPolicy(name, networkPolicy); 3100 Assert.assertEquals(expectedResponse, actualResponse); 3101 3102 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 3103 Assert.assertEquals(1, actualRequests.size()); 3104 SetNetworkPolicyRequest actualRequest = ((SetNetworkPolicyRequest) actualRequests.get(0)); 3105 3106 Assert.assertEquals(name, actualRequest.getName()); 3107 Assert.assertEquals(networkPolicy, actualRequest.getNetworkPolicy()); 3108 Assert.assertTrue( 3109 channelProvider.isHeaderSent( 3110 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 3111 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 3112 } 3113 3114 @Test setNetworkPolicyExceptionTest()3115 public void setNetworkPolicyExceptionTest() throws Exception { 3116 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 3117 mockClusterManager.addException(exception); 3118 3119 try { 3120 String name = "name3373707"; 3121 NetworkPolicy networkPolicy = NetworkPolicy.newBuilder().build(); 3122 client.setNetworkPolicy(name, networkPolicy); 3123 Assert.fail("No exception raised"); 3124 } catch (InvalidArgumentException e) { 3125 // Expected exception. 3126 } 3127 } 3128 3129 @Test setNetworkPolicyTest2()3130 public void setNetworkPolicyTest2() throws Exception { 3131 Operation expectedResponse = 3132 Operation.newBuilder() 3133 .setName("name3373707") 3134 .setZone("zone3744684") 3135 .setDetail("detail-1335224239") 3136 .setStatusMessage("statusMessage-958704715") 3137 .setSelfLink("selfLink1191800166") 3138 .setTargetLink("targetLink486368555") 3139 .setLocation("location1901043637") 3140 .setStartTime("startTime-2129294769") 3141 .setEndTime("endTime-1607243192") 3142 .setProgress(OperationProgress.newBuilder().build()) 3143 .addAllClusterConditions(new ArrayList<StatusCondition>()) 3144 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 3145 .setError(Status.newBuilder().build()) 3146 .build(); 3147 mockClusterManager.addResponse(expectedResponse); 3148 3149 String projectId = "projectId-894832108"; 3150 String zone = "zone3744684"; 3151 String clusterId = "clusterId561939637"; 3152 NetworkPolicy networkPolicy = NetworkPolicy.newBuilder().build(); 3153 3154 Operation actualResponse = client.setNetworkPolicy(projectId, zone, clusterId, networkPolicy); 3155 Assert.assertEquals(expectedResponse, actualResponse); 3156 3157 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 3158 Assert.assertEquals(1, actualRequests.size()); 3159 SetNetworkPolicyRequest actualRequest = ((SetNetworkPolicyRequest) actualRequests.get(0)); 3160 3161 Assert.assertEquals(projectId, actualRequest.getProjectId()); 3162 Assert.assertEquals(zone, actualRequest.getZone()); 3163 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 3164 Assert.assertEquals(networkPolicy, actualRequest.getNetworkPolicy()); 3165 Assert.assertTrue( 3166 channelProvider.isHeaderSent( 3167 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 3168 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 3169 } 3170 3171 @Test setNetworkPolicyExceptionTest2()3172 public void setNetworkPolicyExceptionTest2() throws Exception { 3173 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 3174 mockClusterManager.addException(exception); 3175 3176 try { 3177 String projectId = "projectId-894832108"; 3178 String zone = "zone3744684"; 3179 String clusterId = "clusterId561939637"; 3180 NetworkPolicy networkPolicy = NetworkPolicy.newBuilder().build(); 3181 client.setNetworkPolicy(projectId, zone, clusterId, networkPolicy); 3182 Assert.fail("No exception raised"); 3183 } catch (InvalidArgumentException e) { 3184 // Expected exception. 3185 } 3186 } 3187 3188 @Test setMaintenancePolicyTest()3189 public void setMaintenancePolicyTest() throws Exception { 3190 Operation expectedResponse = 3191 Operation.newBuilder() 3192 .setName("name3373707") 3193 .setZone("zone3744684") 3194 .setDetail("detail-1335224239") 3195 .setStatusMessage("statusMessage-958704715") 3196 .setSelfLink("selfLink1191800166") 3197 .setTargetLink("targetLink486368555") 3198 .setLocation("location1901043637") 3199 .setStartTime("startTime-2129294769") 3200 .setEndTime("endTime-1607243192") 3201 .setProgress(OperationProgress.newBuilder().build()) 3202 .addAllClusterConditions(new ArrayList<StatusCondition>()) 3203 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 3204 .setError(Status.newBuilder().build()) 3205 .build(); 3206 mockClusterManager.addResponse(expectedResponse); 3207 3208 String name = "name3373707"; 3209 MaintenancePolicy maintenancePolicy = MaintenancePolicy.newBuilder().build(); 3210 3211 Operation actualResponse = client.setMaintenancePolicy(name, maintenancePolicy); 3212 Assert.assertEquals(expectedResponse, actualResponse); 3213 3214 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 3215 Assert.assertEquals(1, actualRequests.size()); 3216 SetMaintenancePolicyRequest actualRequest = 3217 ((SetMaintenancePolicyRequest) actualRequests.get(0)); 3218 3219 Assert.assertEquals(name, actualRequest.getName()); 3220 Assert.assertEquals(maintenancePolicy, actualRequest.getMaintenancePolicy()); 3221 Assert.assertTrue( 3222 channelProvider.isHeaderSent( 3223 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 3224 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 3225 } 3226 3227 @Test setMaintenancePolicyExceptionTest()3228 public void setMaintenancePolicyExceptionTest() throws Exception { 3229 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 3230 mockClusterManager.addException(exception); 3231 3232 try { 3233 String name = "name3373707"; 3234 MaintenancePolicy maintenancePolicy = MaintenancePolicy.newBuilder().build(); 3235 client.setMaintenancePolicy(name, maintenancePolicy); 3236 Assert.fail("No exception raised"); 3237 } catch (InvalidArgumentException e) { 3238 // Expected exception. 3239 } 3240 } 3241 3242 @Test setMaintenancePolicyTest2()3243 public void setMaintenancePolicyTest2() throws Exception { 3244 Operation expectedResponse = 3245 Operation.newBuilder() 3246 .setName("name3373707") 3247 .setZone("zone3744684") 3248 .setDetail("detail-1335224239") 3249 .setStatusMessage("statusMessage-958704715") 3250 .setSelfLink("selfLink1191800166") 3251 .setTargetLink("targetLink486368555") 3252 .setLocation("location1901043637") 3253 .setStartTime("startTime-2129294769") 3254 .setEndTime("endTime-1607243192") 3255 .setProgress(OperationProgress.newBuilder().build()) 3256 .addAllClusterConditions(new ArrayList<StatusCondition>()) 3257 .addAllNodepoolConditions(new ArrayList<StatusCondition>()) 3258 .setError(Status.newBuilder().build()) 3259 .build(); 3260 mockClusterManager.addResponse(expectedResponse); 3261 3262 String projectId = "projectId-894832108"; 3263 String zone = "zone3744684"; 3264 String clusterId = "clusterId561939637"; 3265 MaintenancePolicy maintenancePolicy = MaintenancePolicy.newBuilder().build(); 3266 3267 Operation actualResponse = 3268 client.setMaintenancePolicy(projectId, zone, clusterId, maintenancePolicy); 3269 Assert.assertEquals(expectedResponse, actualResponse); 3270 3271 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 3272 Assert.assertEquals(1, actualRequests.size()); 3273 SetMaintenancePolicyRequest actualRequest = 3274 ((SetMaintenancePolicyRequest) actualRequests.get(0)); 3275 3276 Assert.assertEquals(projectId, actualRequest.getProjectId()); 3277 Assert.assertEquals(zone, actualRequest.getZone()); 3278 Assert.assertEquals(clusterId, actualRequest.getClusterId()); 3279 Assert.assertEquals(maintenancePolicy, actualRequest.getMaintenancePolicy()); 3280 Assert.assertTrue( 3281 channelProvider.isHeaderSent( 3282 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 3283 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 3284 } 3285 3286 @Test setMaintenancePolicyExceptionTest2()3287 public void setMaintenancePolicyExceptionTest2() throws Exception { 3288 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 3289 mockClusterManager.addException(exception); 3290 3291 try { 3292 String projectId = "projectId-894832108"; 3293 String zone = "zone3744684"; 3294 String clusterId = "clusterId561939637"; 3295 MaintenancePolicy maintenancePolicy = MaintenancePolicy.newBuilder().build(); 3296 client.setMaintenancePolicy(projectId, zone, clusterId, maintenancePolicy); 3297 Assert.fail("No exception raised"); 3298 } catch (InvalidArgumentException e) { 3299 // Expected exception. 3300 } 3301 } 3302 3303 @Test listUsableSubnetworksTest()3304 public void listUsableSubnetworksTest() throws Exception { 3305 UsableSubnetwork responsesElement = UsableSubnetwork.newBuilder().build(); 3306 ListUsableSubnetworksResponse expectedResponse = 3307 ListUsableSubnetworksResponse.newBuilder() 3308 .setNextPageToken("") 3309 .addAllSubnetworks(Arrays.asList(responsesElement)) 3310 .build(); 3311 mockClusterManager.addResponse(expectedResponse); 3312 3313 ListUsableSubnetworksRequest request = 3314 ListUsableSubnetworksRequest.newBuilder() 3315 .setParent("parent-995424086") 3316 .setFilter("filter-1274492040") 3317 .setPageSize(883849137) 3318 .setPageToken("pageToken873572522") 3319 .build(); 3320 3321 ListUsableSubnetworksPagedResponse pagedListResponse = client.listUsableSubnetworks(request); 3322 3323 List<UsableSubnetwork> resources = Lists.newArrayList(pagedListResponse.iterateAll()); 3324 3325 Assert.assertEquals(1, resources.size()); 3326 Assert.assertEquals(expectedResponse.getSubnetworksList().get(0), resources.get(0)); 3327 3328 List<AbstractMessage> actualRequests = mockClusterManager.getRequests(); 3329 Assert.assertEquals(1, actualRequests.size()); 3330 ListUsableSubnetworksRequest actualRequest = 3331 ((ListUsableSubnetworksRequest) actualRequests.get(0)); 3332 3333 Assert.assertEquals(request.getParent(), actualRequest.getParent()); 3334 Assert.assertEquals(request.getFilter(), actualRequest.getFilter()); 3335 Assert.assertEquals(request.getPageSize(), actualRequest.getPageSize()); 3336 Assert.assertEquals(request.getPageToken(), actualRequest.getPageToken()); 3337 Assert.assertTrue( 3338 channelProvider.isHeaderSent( 3339 ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), 3340 GaxGrpcProperties.getDefaultApiClientHeaderPattern())); 3341 } 3342 3343 @Test listUsableSubnetworksExceptionTest()3344 public void listUsableSubnetworksExceptionTest() throws Exception { 3345 StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); 3346 mockClusterManager.addException(exception); 3347 3348 try { 3349 ListUsableSubnetworksRequest request = 3350 ListUsableSubnetworksRequest.newBuilder() 3351 .setParent("parent-995424086") 3352 .setFilter("filter-1274492040") 3353 .setPageSize(883849137) 3354 .setPageToken("pageToken873572522") 3355 .build(); 3356 client.listUsableSubnetworks(request); 3357 Assert.fail("No exception raised"); 3358 } catch (InvalidArgumentException e) { 3359 // Expected exception. 3360 } 3361 } 3362 } 3363