| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| package org.jclouds.googlecomputeengine.compute; |
| |
| import static com.google.common.collect.Iterables.getOnlyElement; |
| import static org.jclouds.googlecomputeengine.domain.Instance.Status.RUNNING; |
| import static org.testng.Assert.assertEquals; |
| import static org.testng.Assert.assertNotNull; |
| import static org.testng.Assert.assertTrue; |
| |
| import java.io.IOException; |
| import java.util.Set; |
| |
| import org.jclouds.compute.ComputeService; |
| import org.jclouds.compute.domain.ComputeMetadata; |
| import org.jclouds.compute.domain.Hardware; |
| import org.jclouds.compute.domain.NodeMetadata; |
| import org.jclouds.compute.domain.Template; |
| import org.jclouds.domain.Location; |
| import org.jclouds.domain.LocationScope; |
| import org.jclouds.googlecomputeengine.compute.options.GoogleComputeEngineTemplateOptions; |
| import org.jclouds.googlecomputeengine.domain.Instance; |
| import org.jclouds.googlecomputeengine.internal.BaseGoogleComputeEngineApiMockTest; |
| import org.testng.annotations.Test; |
| |
| import com.google.common.collect.ImmutableSet; |
| import com.squareup.okhttp.mockwebserver.MockResponse; |
| |
| @Test(groups = "unit", testName = "GoogleComputeEngineServiceMockTest", singleThreaded = true) |
| public class GoogleComputeEngineServiceMockTest extends BaseGoogleComputeEngineApiMockTest { |
| |
| public void templateMatch() throws Exception { |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/image_list.json")); |
| server.enqueue(jsonResponse("/image_list_debian.json")); // per IMAGE_PROJECTS = "debian-cloud" |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/aggregated_machinetype_list.json")); |
| |
| ComputeService computeService = computeService(); |
| |
| Template template = computeService.templateBuilder().build(); |
| Hardware defaultSize = computeService.templateBuilder().build().getHardware(); |
| |
| Hardware smallest = computeService.templateBuilder().smallest().build().getHardware(); |
| assertEquals(defaultSize, smallest); |
| |
| Hardware fastest = computeService.templateBuilder().fastest().build().getHardware(); |
| assertNotNull(fastest); |
| |
| assertEquals(computeService.listHardwareProfiles().size(), 2); |
| |
| Template toMatch = computeService.templateBuilder().imageId(template.getImage().getId()).build(); |
| assertEquals(toMatch.getImage(), template.getImage()); |
| |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/global/images"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/aggregated/machineTypes"); |
| } |
| |
| public void firewallDeletedWhenAllGroupNodesAreTerminated() throws IOException, InterruptedException { |
| server.enqueue(instanceWithNetworkAndStatus("test-delete-1", "default", RUNNING)); |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/disk_get_with_source_image.json")); |
| server.enqueue(jsonResponse("/image_get_for_source_image.json")); |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/aggregated_machinetype_list.json")); // Why are we getting machineTypes to delete an instance? |
| server.enqueue(jsonResponse("/operation.json")); // instance delete |
| server.enqueue(jsonResponse("/zone_operation.json")); |
| server.enqueue(response404()); // deleted instance no longer exists |
| server.enqueue(aggregatedListInstanceEmpty()); |
| server.enqueue(jsonResponse("/firewall_list_compute.json")); |
| server.enqueue(jsonResponse("/operation.json")); |
| server.enqueue(jsonResponse("/zone_operation.json")); |
| |
| ComputeService computeService = computeService(); |
| computeService.destroyNode(url("/jclouds/zones/us-central1-a/instances/test-delete-1")); |
| |
| assertSent(server, "GET", "/jclouds/zones/us-central1-a/instances/test-delete-1"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/disks/test"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images/debian-7-wheezy-v20140718"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/aggregated/machineTypes"); // Why are we getting machineTypes to delete an instance? |
| assertSent(server, "DELETE", "/jclouds/zones/us-central1-a/instances/test-delete-1"); // instance delete |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/operations/operation-1354084865060"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/instances/test-delete-1"); // get instance |
| assertSent(server, "GET", "/projects/party/aggregated/instances"); |
| assertSent(server, "GET", "/projects/party/global/firewalls"); |
| assertSent(server, "DELETE", "/projects/party/global/firewalls/jclouds-test-delete-34sf"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/operations/operation-1354084865060"); |
| } |
| |
| |
| public void listAssignableLocations() throws Exception { |
| server.enqueue(singleRegionSingleZoneResponse()); |
| |
| ComputeService computeService = computeService(); |
| |
| Set<? extends Location> locations = computeService.listAssignableLocations(); |
| |
| assertNotNull(locations); |
| assertEquals(locations.size(), 1); |
| Location firstZone = locations.iterator().next(); |
| assertEquals(firstZone.getId(), "us-central1-a"); |
| assertEquals(firstZone.getDescription(), url("/projects/party/zones/us-central1-a")); |
| assertEquals(firstZone.getScope(), LocationScope.ZONE); |
| |
| assertEquals(firstZone.getParent().getId(), "us-central1"); |
| assertEquals(firstZone.getParent().getDescription(), url("/projects/party/regions/us-central1")); |
| assertEquals(firstZone.getParent().getScope(), LocationScope.REGION); |
| |
| // Google intentionally does not document locations! |
| assertTrue(firstZone.getIso3166Codes().isEmpty()); |
| assertTrue(firstZone.getParent().getIso3166Codes().isEmpty()); |
| |
| assertSent(server, "GET", "/projects/party/regions"); |
| } |
| |
| public void listNodes() throws Exception { |
| server.enqueue(aggregatedListWithInstanceNetworkAndStatus("test-0", "test-network", RUNNING)); |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/disk_get_with_source_image.json")); |
| server.enqueue(jsonResponse("/image_get_for_source_image.json")); |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/aggregated_machinetype_list.json")); |
| |
| Set<? extends ComputeMetadata> nodes = computeService().listNodes(); |
| assertEquals(nodes.size(), 1); |
| NodeMetadata node = (NodeMetadata) nodes.iterator().next(); |
| assertNotNull(node.getImageId()); |
| |
| assertSent(server, "GET", "/projects/party/aggregated/instances"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/disks/test"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images/debian-7-wheezy-v20140718"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/aggregated/machineTypes"); |
| } |
| |
| |
| public void listNodesWithSnapshotSource() throws Exception { |
| server.enqueue(aggregatedListWithInstanceNetworkAndStatus("test-0", "test-network", RUNNING)); |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/disk_get_with_source_snapshot.json")); |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/aggregated_machinetype_list.json")); |
| |
| Set<? extends ComputeMetadata> nodes = computeService().listNodes(); |
| assertEquals(nodes.size(), 1); |
| NodeMetadata node = (NodeMetadata) nodes.iterator().next(); |
| String imageId = node.getImageId(); |
| assertEquals(imageId, null); |
| assertSent(server, "GET", "/projects/party/aggregated/instances"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/disks/test"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/aggregated/machineTypes"); |
| } |
| |
| |
| |
| public void createNodeWhenFirewallDoesNotExist() throws Exception { |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/image_list.json")); |
| server.enqueue(jsonResponse("/image_list_debian.json")); // per IMAGE_PROJECTS = "debian-cloud" |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/aggregated_machinetype_list.json")); |
| server.enqueue(new MockResponse().setResponseCode(404)); // Get Subnet |
| server.enqueue(jsonResponse("/network_get_default.json")); |
| server.enqueue(new MockResponse().setResponseCode(404)); // Get Firewall |
| server.enqueue(jsonResponse("/operation.json")); // Create Firewall |
| server.enqueue(jsonResponse("/zone_operation.json")); |
| server.enqueue(aggregatedListWithInstanceNetworkAndStatus("test-0", "test-network", RUNNING)); |
| server.enqueue(jsonResponse("/disk_get_with_source_image.json")); |
| server.enqueue(jsonResponse("/image_get_for_source_image.json")); |
| server.enqueue(jsonResponse("/operation.json")); // Create Instance |
| server.enqueue(instanceWithNetworkAndStatus("test-1", "test-network", RUNNING)); |
| |
| ComputeService computeService = computeService(); |
| |
| GoogleComputeEngineTemplateOptions options = computeService.templateOptions() |
| .as(GoogleComputeEngineTemplateOptions.class).autoCreateKeyPair(false) |
| .tags(ImmutableSet.of("aTag")).blockUntilRunning(false); |
| |
| Template template = computeService.templateBuilder().options(options).build(); |
| NodeMetadata node = getOnlyElement(computeService.createNodesInGroup("test", 1, template)); |
| |
| // prove our caching works. |
| assertEquals(node.getImageId(), template.getImage().getId()); |
| |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/global/images"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/aggregated/machineTypes"); |
| assertSent(server, "GET", "/projects/party/regions/us-central1/subnetworks/default"); |
| assertSent(server, "GET", "/projects/party/global/networks/default"); |
| assertSent(server, "GET", "/projects/party/global/firewalls/jclouds-test-65f"); // Get Firewall |
| assertSent(server, "POST", "/projects/party/global/firewalls", // Create Firewall |
| stringFromResource("/firewall_insert_2.json")); |
| |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/operations/operation-1354084865060"); |
| assertSent(server, "GET", "/projects/party/aggregated/instances"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/disks/test"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images/debian-7-wheezy-v20140718"); |
| assertSent(server, "POST", "/projects/party/zones/us-central1-a/instances", |
| String.format(stringFromResource("/instance_insert_2.json"), template.getHardware().getId(), template.getImage().getId())); |
| |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/instances/test-1"); |
| } |
| |
| public void createNodeWithSpecificDiskType() throws Exception { |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/image_list.json")); |
| server.enqueue(jsonResponse("/image_list_debian.json")); // per IMAGE_PROJECTS = "debian-cloud" |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/aggregated_machinetype_list.json")); |
| server.enqueue(new MockResponse().setResponseCode(404)); // Get Subnet |
| server.enqueue(jsonResponse("/network_get_default.json")); |
| server.enqueue(new MockResponse().setResponseCode(404)); // Get Firewall |
| server.enqueue(jsonResponse("/operation.json")); // Create Firewall |
| server.enqueue(jsonResponse("/zone_operation.json")); |
| server.enqueue(aggregatedListWithInstanceNetworkAndStatus("test-0", "test-network", RUNNING)); |
| server.enqueue(jsonResponse("/disk_get_with_source_image.json")); |
| server.enqueue(jsonResponse("/image_get_for_source_image.json")); |
| server.enqueue(jsonResponse("/disktype_ssd.json")); |
| server.enqueue(jsonResponse("/operation.json")); // Create Instance |
| server.enqueue(instanceWithNetworkAndStatusAndSsd("test-1", "test-network", RUNNING)); |
| |
| ComputeService computeService = computeService(); |
| |
| GoogleComputeEngineTemplateOptions options = computeService.templateOptions() |
| .as(GoogleComputeEngineTemplateOptions.class).autoCreateKeyPair(false) |
| .tags(ImmutableSet.of("aTag")).blockUntilRunning(false) |
| .bootDiskType("pd-ssd"); |
| |
| Template template = computeService.templateBuilder().options(options).build(); |
| NodeMetadata node = getOnlyElement(computeService.createNodesInGroup("test", 1, template)); |
| |
| // prove our caching works. |
| assertEquals(node.getImageId(), template.getImage().getId()); |
| assertEquals(node.getLocation().getId(), template.getLocation().getId()); |
| |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/global/images"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/aggregated/machineTypes"); |
| assertSent(server, "GET", "/projects/party/regions/us-central1/subnetworks/default"); |
| assertSent(server, "GET", "/projects/party/global/networks/default"); |
| assertSent(server, "GET", "/projects/party/global/firewalls/jclouds-test-65f"); // Get Firewall |
| assertSent(server, "POST", "/projects/party/global/firewalls", // Create Firewall |
| stringFromResource("/firewall_insert_2.json")); |
| |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/operations/operation-1354084865060"); |
| assertSent(server, "GET", "/projects/party/aggregated/instances"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/disks/test"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images/debian-7-wheezy-v20140718"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/diskTypes/pd-ssd"); |
| assertSent(server, "POST", "/projects/party/zones/us-central1-a/instances", |
| String.format(stringFromResource("/instance_insert_ssd.json"), template.getHardware().getId(), template.getImage().getId())); |
| |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/instances/test-1"); |
| } |
| |
| public void createNodeWithCustomSubnetwork() throws Exception { |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/image_list.json")); |
| server.enqueue(jsonResponse("/image_list_debian.json")); // per IMAGE_PROJECTS = "debian-cloud" |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/aggregated_machinetype_list.json")); |
| server.enqueue(jsonResponse("/subnetwork_get.json")); |
| server.enqueue(jsonResponse("/network_get.json")); |
| server.enqueue(new MockResponse().setResponseCode(404)); // Get Firewall |
| server.enqueue(jsonResponse("/operation.json")); // Create Firewall |
| server.enqueue(jsonResponse("/zone_operation.json")); |
| server.enqueue(aggregatedListWithInstanceNetworkAndStatus("test-0", "test-network", RUNNING)); |
| server.enqueue(jsonResponse("/disk_get_with_source_image.json")); |
| server.enqueue(jsonResponse("/image_get_for_source_image.json")); |
| server.enqueue(jsonResponse("/disktype_ssd.json")); |
| server.enqueue(jsonResponse("/operation.json")); // Create Instance |
| server.enqueue(instanceWithNetworkAndStatusAndSsd("test-1", "test-network", RUNNING)); |
| |
| ComputeService computeService = computeService(); |
| |
| GoogleComputeEngineTemplateOptions options = computeService.templateOptions() |
| .as(GoogleComputeEngineTemplateOptions.class).autoCreateKeyPair(false) |
| .tags(ImmutableSet.of("aTag")).blockUntilRunning(false) |
| .bootDiskType("pd-ssd").networks("jclouds-test"); |
| |
| Template template = computeService.templateBuilder().options(options).build(); |
| NodeMetadata node = getOnlyElement(computeService.createNodesInGroup("test", 1, template)); |
| |
| // prove our caching works. |
| assertEquals(node.getImageId(), template.getImage().getId()); |
| assertEquals(node.getLocation().getId(), template.getLocation().getId()); |
| |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/global/images"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/aggregated/machineTypes"); |
| assertSent(server, "GET", "/projects/party/regions/us-central1/subnetworks/jclouds-test"); |
| assertSent(server, "GET", "/projects/party/global/networks/mynetwork"); |
| assertSent(server, "GET", "/projects/party/global/firewalls/jclouds-test-65f"); // Get Firewall |
| assertSent(server, "POST", "/projects/party/global/firewalls", // Create Firewall |
| stringFromResource("/firewall_insert_3.json")); |
| |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/operations/operation-1354084865060"); |
| assertSent(server, "GET", "/projects/party/aggregated/instances"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/disks/test"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images/debian-7-wheezy-v20140718"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/diskTypes/pd-ssd"); |
| assertSent(server, "POST", "/projects/party/zones/us-central1-a/instances", |
| String.format(stringFromResource("/instance_insert_subnet.json"), template.getHardware().getId(), template.getImage().getId())); |
| |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/instances/test-1"); |
| } |
| |
| public void createNodeWithoutExternalIp() throws Exception { |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/image_list.json")); |
| server.enqueue(jsonResponse("/image_list_debian.json")); // per IMAGE_PROJECTS = "debian-cloud" |
| server.enqueue(singleRegionSingleZoneResponse()); |
| server.enqueue(jsonResponse("/aggregated_machinetype_list.json")); |
| server.enqueue(jsonResponse("/subnetwork_get.json")); |
| server.enqueue(jsonResponse("/network_get.json")); |
| server.enqueue(new MockResponse().setResponseCode(404)); // Get Firewall |
| server.enqueue(jsonResponse("/operation.json")); // Create Firewall |
| server.enqueue(jsonResponse("/zone_operation.json")); |
| server.enqueue(aggregatedListWithInstanceNetworkAndStatus("test-0", "test-network", RUNNING)); |
| server.enqueue(jsonResponse("/disk_get_with_source_image.json")); |
| server.enqueue(jsonResponse("/image_get_for_source_image.json")); |
| server.enqueue(jsonResponse("/disktype_ssd.json")); |
| server.enqueue(jsonResponse("/operation.json")); // Create Instance |
| server.enqueue(instanceWithNetworkAndStatusAndSsd("test-1", "test-network", RUNNING)); |
| |
| ComputeService computeService = computeService(); |
| |
| GoogleComputeEngineTemplateOptions options = computeService.templateOptions() |
| .as(GoogleComputeEngineTemplateOptions.class).autoCreateKeyPair(false) |
| .tags(ImmutableSet.of("aTag")).blockUntilRunning(false) |
| .bootDiskType("pd-ssd").networks("jclouds-test").assignExternalIp(false); |
| |
| Template template = computeService.templateBuilder().options(options).build(); |
| NodeMetadata node = getOnlyElement(computeService.createNodesInGroup("test", 1, template)); |
| |
| // prove our caching works. |
| assertEquals(node.getImageId(), template.getImage().getId()); |
| assertEquals(node.getLocation().getId(), template.getLocation().getId()); |
| |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/global/images"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images"); |
| assertSent(server, "GET", "/projects/party/regions"); |
| assertSent(server, "GET", "/projects/party/aggregated/machineTypes"); |
| assertSent(server, "GET", "/projects/party/regions/us-central1/subnetworks/jclouds-test"); |
| assertSent(server, "GET", "/projects/party/global/networks/mynetwork"); |
| assertSent(server, "GET", "/projects/party/global/firewalls/jclouds-test-65f"); // Get Firewall |
| assertSent(server, "POST", "/projects/party/global/firewalls", // Create Firewall |
| stringFromResource("/firewall_insert_3.json")); |
| |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/operations/operation-1354084865060"); |
| assertSent(server, "GET", "/projects/party/aggregated/instances"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/disks/test"); |
| assertSent(server, "GET", "/projects/debian-cloud/global/images/debian-7-wheezy-v20140718"); |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/diskTypes/pd-ssd"); |
| assertSent(server, "POST", "/projects/party/zones/us-central1-a/instances", |
| String.format(stringFromResource("/instance_insert_no_ip.json"), template.getHardware().getId(), template.getImage().getId())); |
| |
| assertSent(server, "GET", "/projects/party/zones/us-central1-a/instances/test-1"); |
| } |
| |
| private MockResponse instanceWithNetworkAndStatus(String instanceName, String networkName, Instance.Status status) { |
| return new MockResponse().setBody( |
| stringFromResource("/instance_get.json").replace("test-0", instanceName).replace("default", networkName) |
| .replace("RUNNING", status.toString())); |
| } |
| |
| private MockResponse instanceWithNetworkAndStatusAndSsd(String instanceName, String networkName, Instance.Status status) { |
| return new MockResponse().setBody( |
| stringFromResource("/instance_get.json").replace("test-0", instanceName).replace("default", networkName) |
| .replace("RUNNING", status.toString()).replace("pd-standard", "pd-ssd")); |
| } |
| |
| private MockResponse aggregatedListWithInstanceNetworkAndStatus(String instanceName, String networkName, |
| Instance.Status status) { |
| return new MockResponse().setBody( |
| stringFromResource("/aggregated_instance_list.json").replace("test-0", instanceName) |
| .replace("default", networkName).replace("RUNNING", status.toString())); |
| } |
| |
| private MockResponse aggregatedListInstanceEmpty() { |
| return new MockResponse().setBody(stringFromResource("/aggregated_instance_list_empty.json")); |
| } |
| } |
| |
