|
16 | 16 | package com.google.cloud.monitoring.v3;
|
17 | 17 |
|
18 | 18 | import static com.google.cloud.monitoring.v3.UptimeCheckServiceClient.ListUptimeCheckConfigsPagedResponse;
|
| 19 | +import static com.google.cloud.monitoring.v3.UptimeCheckServiceClient.ListUptimeCheckIpsPagedResponse; |
19 | 20 |
|
20 | 21 | import com.google.api.gax.core.NoCredentialsProvider;
|
21 | 22 | import com.google.api.gax.grpc.GaxGrpcProperties;
|
|
30 | 31 | import com.google.monitoring.v3.GetUptimeCheckConfigRequest;
|
31 | 32 | import com.google.monitoring.v3.ListUptimeCheckConfigsRequest;
|
32 | 33 | import com.google.monitoring.v3.ListUptimeCheckConfigsResponse;
|
| 34 | +import com.google.monitoring.v3.ListUptimeCheckIpsRequest; |
| 35 | +import com.google.monitoring.v3.ListUptimeCheckIpsResponse; |
33 | 36 | import com.google.monitoring.v3.ProjectName;
|
34 | 37 | import com.google.monitoring.v3.UpdateUptimeCheckConfigRequest;
|
35 | 38 | import com.google.monitoring.v3.UptimeCheckConfig;
|
36 | 39 | import com.google.monitoring.v3.UptimeCheckConfigName;
|
| 40 | +import com.google.monitoring.v3.UptimeCheckIp; |
37 | 41 | import com.google.protobuf.AbstractMessage;
|
38 | 42 | import com.google.protobuf.Empty;
|
39 | 43 | import io.grpc.Status;
|
@@ -337,4 +341,51 @@ public void deleteUptimeCheckConfigExceptionTest() throws Exception {
|
337 | 341 | // Expected exception
|
338 | 342 | }
|
339 | 343 | }
|
| 344 | + |
| 345 | + @Test |
| 346 | + @SuppressWarnings("all") |
| 347 | + public void listUptimeCheckIpsTest() { |
| 348 | + String nextPageToken = ""; |
| 349 | + UptimeCheckIp uptimeCheckIpsElement = UptimeCheckIp.newBuilder().build(); |
| 350 | + List<UptimeCheckIp> uptimeCheckIps = Arrays.asList(uptimeCheckIpsElement); |
| 351 | + ListUptimeCheckIpsResponse expectedResponse = |
| 352 | + ListUptimeCheckIpsResponse.newBuilder() |
| 353 | + .setNextPageToken(nextPageToken) |
| 354 | + .addAllUptimeCheckIps(uptimeCheckIps) |
| 355 | + .build(); |
| 356 | + mockUptimeCheckService.addResponse(expectedResponse); |
| 357 | + |
| 358 | + ListUptimeCheckIpsRequest request = ListUptimeCheckIpsRequest.newBuilder().build(); |
| 359 | + |
| 360 | + ListUptimeCheckIpsPagedResponse pagedListResponse = client.listUptimeCheckIps(request); |
| 361 | + |
| 362 | + List<UptimeCheckIp> resources = Lists.newArrayList(pagedListResponse.iterateAll()); |
| 363 | + Assert.assertEquals(1, resources.size()); |
| 364 | + Assert.assertEquals(expectedResponse.getUptimeCheckIpsList().get(0), resources.get(0)); |
| 365 | + |
| 366 | + List<AbstractMessage> actualRequests = mockUptimeCheckService.getRequests(); |
| 367 | + Assert.assertEquals(1, actualRequests.size()); |
| 368 | + ListUptimeCheckIpsRequest actualRequest = (ListUptimeCheckIpsRequest) actualRequests.get(0); |
| 369 | + |
| 370 | + Assert.assertTrue( |
| 371 | + channelProvider.isHeaderSent( |
| 372 | + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), |
| 373 | + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); |
| 374 | + } |
| 375 | + |
| 376 | + @Test |
| 377 | + @SuppressWarnings("all") |
| 378 | + public void listUptimeCheckIpsExceptionTest() throws Exception { |
| 379 | + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); |
| 380 | + mockUptimeCheckService.addException(exception); |
| 381 | + |
| 382 | + try { |
| 383 | + ListUptimeCheckIpsRequest request = ListUptimeCheckIpsRequest.newBuilder().build(); |
| 384 | + |
| 385 | + client.listUptimeCheckIps(request); |
| 386 | + Assert.fail("No exception raised"); |
| 387 | + } catch (InvalidArgumentException e) { |
| 388 | + // Expected exception |
| 389 | + } |
| 390 | + } |
340 | 391 | }
|
0 commit comments