Lines Matching refs:zone
166 zone=scope_name)
233 def GetMetricQuota(regions_info, zone, metric): argument
246 if region_info["name"] in zone:
250 logger.info("Can't get %s quota info from zone(%s)", metric, zone)
253 def EnoughMetricsInZone(self, zone): argument
266 quota = self.GetMetricQuota(regions_info, zone, metric)
269 "Can't query the metric(%s) in zone(%s)", metric, zone)
273 "The metric(%s) is over limit in zone(%s)", metric, zone)
277 def GetDisk(self, disk_name, zone): argument
289 project=self._project, zone=zone, disk=disk_name)
292 def CheckDiskExists(self, disk_name, zone): argument
303 self.GetDisk(disk_name, zone)
315 zone, argument
338 "type": "projects/%s/zones/%s/diskTypes/%s" % (self._project, zone,
344 zone=zone,
351 scope_name=zone)
354 if self.CheckDiskExists(disk_name, zone):
355 self.DeleteDisk(disk_name, zone)
359 def DeleteDisk(self, disk_name, zone): argument
368 project=self._project, zone=zone, disk=disk_name)
373 scope_name=zone)
376 def DeleteDisks(self, disk_names, zone): argument
397 project=self._project, disk=disk_name, zone=zone)
400 delete_requests, OperationScope.ZONE, scope_name=zone)
402 def ListDisks(self, zone, disk_filter=None): argument
418 zone=zone,
624 def GetInstance(self, instance, zone): argument
636 project=self._project, zone=zone, instance=instance)
639 def AttachAccelerator(self, instance, zone, accelerator_count, argument
661 self.GetAcceleratorUrl(accelerator_type, zone),
667 project=self._project, zone=zone, instance=instance, body=body)
673 scope_name=zone)
680 def AttachDisk(self, instance, zone, **kwargs): argument
726 project=self._project, zone=zone, instance=instance, body=kwargs)
732 scope_name=zone)
738 def DetachDisk(self, instance, zone, disk_name): argument
755 zone=zone,
763 scope_name=zone)
769 def StartInstance(self, instance, zone): argument
780 project=self._project, zone=zone, instance=instance)
786 scope_name=zone)
792 def StartInstances(self, instances, zone): argument
808 self.service.instances().start, project=self._project, zone=zone)
809 return self._BatchExecuteOnInstances(instances, zone, action)
811 def StopInstance(self, instance, zone): argument
822 project=self._project, zone=zone, instance=instance)
828 scope_name=zone)
834 def StopInstances(self, instances, zone): argument
850 self.service.instances().stop, project=self._project, zone=zone)
851 return self._BatchExecuteOnInstances(instances, zone, action)
855 zone, argument
880 project=self._project, zone=zone, instance=instance, body=body)
886 scope_name=zone)
962 zone, argument
996 zone=zone,
998 return self._BatchExecuteOnInstances(instances, zone, action)
1000 def _BatchExecuteOnInstances(self, instances, zone, action): argument
1027 requests, operation_scope=OperationScope.ZONE, scope_name=zone)
1145 def _GetNetworkArgs(self, network, zone, disable_external_ip): argument
1170 network_args["subnetwork"] = self.GetSubnetworkUrl(network, zone)
1201 def _GetExtraDiskArgs(self, extra_disk_name, zone): argument
1214 "source": "projects/%s/zones/%s/disks/%s" % (self._project, zone,
1229 zone, argument
1267 disk_args.extend(self._GetExtraDiskArgs(extra_disk_name, zone))
1275 self._project, zone, disk_type)
1285 "machineType": self.GetMachineType(machine_type, zone)["selfLink"],
1288 self._GetNetworkArgs(network, zone, disable_external_ip)
1303 "acceleratorType": self.GetAcceleratorUrl(gpu, zone),
1316 self._project, zone, body)
1318 project=self._project, zone=zone, body=body)
1321 operation, operation_scope=OperationScope.ZONE, scope_name=zone)
1324 def DeleteInstance(self, instance, zone): argument
1333 project=self._project, zone=zone, instance=instance)
1336 operation, operation_scope=OperationScope.ZONE, scope_name=zone)
1339 def DeleteInstances(self, instances, zone): argument
1353 self.service.instances().delete, project=self._project, zone=zone)
1354 return self._BatchExecuteOnInstances(instances, zone, action)
1356 def ResetInstance(self, instance, zone): argument
1365 project=self._project, zone=zone, instance=instance)
1368 operation, operation_scope=OperationScope.ZONE, scope_name=zone)
1371 def GetMachineType(self, machine_type, zone): argument
1384 project=self._project, zone=zone, machineType=machine_type)
1387 def GetAcceleratorUrl(self, accelerator_type, zone): argument
1401 project=self._project, zone=zone, acceleratorType=accelerator_type)
1421 def GetSubnetworkUrl(self, network, zone): argument
1444 region = zone.rsplit("-", 1)[0]
1451 def CompareMachineSize(self, machine_type_1, machine_type_2, zone): argument
1470 machine_info_1 = self.GetMachineType(machine_type_1, zone)
1471 machine_info_2 = self.GetMachineType(machine_type_2, zone)
1485 def GetSerialPortOutput(self, instance, zone, port=1): argument
1500 project=self._project, zone=zone, instance=instance, port=port)
1532 def GetInstanceIP(self, instance, zone): argument
1542 instance = self.GetInstance(instance, zone)
1546 def SetInstanceMetadata(self, zone, instance, body): argument
1566 project=self._project, zone=zone, instance=instance, body=body)
1569 operation, operation_scope=OperationScope.ZONE, scope_name=zone)
1587 zone = self.GetZoneByInstance(instance)
1588 gce_instance = self.GetInstance(instance, zone)
1591 self.UpdateRsaInMetadata(zone, instance, metadata, entry)
1640 for zone, instance_data in response["items"].items():
1642 zone_match = _ZONE_RE.match(zone)
1661 zone = self.GetZoneByInstance(instance)
1662 if zone in zone_instances:
1663 zone_instances[zone].append(instance)
1665 zone_instances[zone] = [instance]
1690 def UpdateRsaInMetadata(self, zone, instance, metadata, entry): argument
1714 self.SetInstanceMetadata(zone, instance, metadata)
1790 def GetGCEHostName(gce_project, instance, zone): argument