Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(9)

Unified Diff: third_party/gsutil/20110627/boto/boto/ec2/instance.py

Issue 10199002: Upgrade gsutil to 3.4 (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Addressed comments Created 8 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/gsutil/20110627/boto/boto/ec2/instance.py
diff --git a/third_party/gsutil/20110627/boto/boto/ec2/instance.py b/third_party/gsutil/20110627/boto/boto/ec2/instance.py
deleted file mode 100644
index 8c21bad0f650f1abf6ebd59d4dfc76134faf4b9a..0000000000000000000000000000000000000000
--- a/third_party/gsutil/20110627/boto/boto/ec2/instance.py
+++ /dev/null
@@ -1,403 +0,0 @@
-# Copyright (c) 2006-2010 Mitch Garnaat http://garnaat.org/
-# Copyright (c) 2010, Eucalyptus Systems, Inc.
-#
-# Permission is hereby granted, free of charge, to any person obtaining a
-# copy of this software and associated documentation files (the
-# "Software"), to deal in the Software without restriction, including
-# without limitation the rights to use, copy, modify, merge, publish, dis-
-# tribute, sublicense, and/or sell copies of the Software, and to permit
-# persons to whom the Software is furnished to do so, subject to the fol-
-# lowing conditions:
-#
-# The above copyright notice and this permission notice shall be included
-# in all copies or substantial portions of the Software.
-#
-# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
-# OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABIL-
-# ITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT
-# SHALL THE AUTHOR BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
-# WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
-# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
-# IN THE SOFTWARE.
-
-"""
-Represents an EC2 Instance
-"""
-import boto
-from boto.ec2.ec2object import EC2Object, TaggedEC2Object
-from boto.resultset import ResultSet
-from boto.ec2.address import Address
-from boto.ec2.blockdevicemapping import BlockDeviceMapping
-from boto.ec2.image import ProductCodes
-import base64
-
-class Reservation(EC2Object):
-
- def __init__(self, connection=None):
- EC2Object.__init__(self, connection)
- self.id = None
- self.owner_id = None
- self.groups = []
- self.instances = []
-
- def __repr__(self):
- return 'Reservation:%s' % self.id
-
- def startElement(self, name, attrs, connection):
- if name == 'instancesSet':
- self.instances = ResultSet([('item', Instance)])
- return self.instances
- elif name == 'groupSet':
- self.groups = ResultSet([('item', Group)])
- return self.groups
- else:
- return None
-
- def endElement(self, name, value, connection):
- if name == 'reservationId':
- self.id = value
- elif name == 'ownerId':
- self.owner_id = value
- else:
- setattr(self, name, value)
-
- def stop_all(self):
- for instance in self.instances:
- instance.stop()
-
-class Instance(TaggedEC2Object):
-
- def __init__(self, connection=None):
- TaggedEC2Object.__init__(self, connection)
- self.id = None
- self.dns_name = None
- self.public_dns_name = None
- self.private_dns_name = None
- self.state = None
- self.state_code = None
- self.key_name = None
- self.shutdown_state = None
- self.previous_state = None
- self.instance_type = None
- self.instance_class = None
- self.launch_time = None
- self.image_id = None
- self.placement = None
- self.kernel = None
- self.ramdisk = None
- self.product_codes = ProductCodes()
- self.ami_launch_index = None
- self.monitored = False
- self.instance_class = None
- self.spot_instance_request_id = None
- self.subnet_id = None
- self.vpc_id = None
- self.private_ip_address = None
- self.ip_address = None
- self.requester_id = None
- self._in_monitoring_element = False
- self.persistent = False
- self.root_device_name = None
- self.root_device_type = None
- self.block_device_mapping = None
- self.state_reason = None
- self.group_name = None
- self.client_token = None
- self.groups = []
-
- def __repr__(self):
- return 'Instance:%s' % self.id
-
- def startElement(self, name, attrs, connection):
- retval = TaggedEC2Object.startElement(self, name, attrs, connection)
- if retval is not None:
- return retval
- if name == 'monitoring':
- self._in_monitoring_element = True
- elif name == 'blockDeviceMapping':
- self.block_device_mapping = BlockDeviceMapping()
- return self.block_device_mapping
- elif name == 'productCodes':
- return self.product_codes
- elif name == 'stateReason':
- self.state_reason = StateReason()
- return self.state_reason
- elif name == 'groupSet':
- self.groups = ResultSet([('item', Group)])
- return self.groups
- return None
-
- def endElement(self, name, value, connection):
- if name == 'instanceId':
- self.id = value
- elif name == 'imageId':
- self.image_id = value
- elif name == 'dnsName' or name == 'publicDnsName':
- self.dns_name = value # backwards compatibility
- self.public_dns_name = value
- elif name == 'privateDnsName':
- self.private_dns_name = value
- elif name == 'keyName':
- self.key_name = value
- elif name == 'amiLaunchIndex':
- self.ami_launch_index = value
- elif name == 'shutdownState':
- self.shutdown_state = value
- elif name == 'previousState':
- self.previous_state = value
- elif name == 'name':
- self.state = value
- elif name == 'code':
- try:
- self.state_code = int(value)
- except ValueError:
- boto.log.warning('Error converting code (%s) to int' % value)
- self.state_code = value
- elif name == 'instanceType':
- self.instance_type = value
- elif name == 'instanceClass':
- self.instance_class = value
- elif name == 'rootDeviceName':
- self.root_device_name = value
- elif name == 'rootDeviceType':
- self.root_device_type = value
- elif name == 'launchTime':
- self.launch_time = value
- elif name == 'availabilityZone':
- self.placement = value
- elif name == 'placement':
- pass
- elif name == 'kernelId':
- self.kernel = value
- elif name == 'ramdiskId':
- self.ramdisk = value
- elif name == 'state':
- if self._in_monitoring_element:
- if value == 'enabled':
- self.monitored = True
- self._in_monitoring_element = False
- elif name == 'instanceClass':
- self.instance_class = value
- elif name == 'spotInstanceRequestId':
- self.spot_instance_request_id = value
- elif name == 'subnetId':
- self.subnet_id = value
- elif name == 'vpcId':
- self.vpc_id = value
- elif name == 'privateIpAddress':
- self.private_ip_address = value
- elif name == 'ipAddress':
- self.ip_address = value
- elif name == 'requesterId':
- self.requester_id = value
- elif name == 'persistent':
- if value == 'true':
- self.persistent = True
- else:
- self.persistent = False
- elif name == 'groupName':
- if self._in_monitoring_element:
- self.group_name = value
- elif name == 'clientToken':
- self.client_token = value
- else:
- setattr(self, name, value)
-
- def _update(self, updated):
- self.__dict__.update(updated.__dict__)
-
- def update(self, validate=False):
- """
- Update the instance's state information by making a call to fetch
- the current instance attributes from the service.
-
- :type validate: bool
- :param validate: By default, if EC2 returns no data about the
- instance the update method returns quietly. If
- the validate param is True, however, it will
- raise a ValueError exception if no data is
- returned from EC2.
- """
- rs = self.connection.get_all_instances([self.id])
- if len(rs) > 0:
- r = rs[0]
- for i in r.instances:
- if i.id == self.id:
- self._update(i)
- elif validate:
- raise ValueError('%s is not a valid Instance ID' % self.id)
- return self.state
-
- def terminate(self):
- """
- Terminate the instance
- """
- rs = self.connection.terminate_instances([self.id])
- self._update(rs[0])
-
- def stop(self, force=False):
- """
- Stop the instance
-
- :type force: bool
- :param force: Forces the instance to stop
-
- :rtype: list
- :return: A list of the instances stopped
- """
- rs = self.connection.stop_instances([self.id])
- self._update(rs[0])
-
- def start(self):
- """
- Start the instance.
- """
- rs = self.connection.start_instances([self.id])
- self._update(rs[0])
-
- def reboot(self):
- return self.connection.reboot_instances([self.id])
-
- def get_console_output(self):
- """
- Retrieves the console output for the instance.
-
- :rtype: :class:`boto.ec2.instance.ConsoleOutput`
- :return: The console output as a ConsoleOutput object
- """
- return self.connection.get_console_output(self.id)
-
- def confirm_product(self, product_code):
- return self.connection.confirm_product_instance(self.id, product_code)
-
- def use_ip(self, ip_address):
- if isinstance(ip_address, Address):
- ip_address = ip_address.public_ip
- return self.connection.associate_address(self.id, ip_address)
-
- def monitor(self):
- return self.connection.monitor_instance(self.id)
-
- def unmonitor(self):
- return self.connection.unmonitor_instance(self.id)
-
- def get_attribute(self, attribute):
- """
- Gets an attribute from this instance.
-
- :type attribute: string
- :param attribute: The attribute you need information about
- Valid choices are:
- instanceType|kernel|ramdisk|userData|
- disableApiTermination|
- instanceInitiatedShutdownBehavior|
- rootDeviceName|blockDeviceMapping
-
- :rtype: :class:`boto.ec2.image.InstanceAttribute`
- :return: An InstanceAttribute object representing the value of the
- attribute requested
- """
- return self.connection.get_instance_attribute(self.id, attribute)
-
- def modify_attribute(self, attribute, value):
- """
- Changes an attribute of this instance
-
- :type attribute: string
- :param attribute: The attribute you wish to change.
- AttributeName - Expected value (default)
- instanceType - A valid instance type (m1.small)
- kernel - Kernel ID (None)
- ramdisk - Ramdisk ID (None)
- userData - Base64 encoded String (None)
- disableApiTermination - Boolean (true)
- instanceInitiatedShutdownBehavior - stop|terminate
- rootDeviceName - device name (None)
-
- :type value: string
- :param value: The new value for the attribute
-
- :rtype: bool
- :return: Whether the operation succeeded or not
- """
- return self.connection.modify_instance_attribute(self.id, attribute,
- value)
-
- def reset_attribute(self, attribute):
- """
- Resets an attribute of this instance to its default value.
-
- :type attribute: string
- :param attribute: The attribute to reset. Valid values are:
- kernel|ramdisk
-
- :rtype: bool
- :return: Whether the operation succeeded or not
- """
- return self.connection.reset_instance_attribute(self.id, attribute)
-
-class Group:
-
- def __init__(self, parent=None):
- self.id = None
- self.name = None
-
- def startElement(self, name, attrs, connection):
- return None
-
- def endElement(self, name, value, connection):
- if name == 'groupId':
- self.id = value
- elif name == 'groupName':
- self.name = value
- else:
- setattr(self, name, value)
-
-class ConsoleOutput:
-
- def __init__(self, parent=None):
- self.parent = parent
- self.instance_id = None
- self.timestamp = None
- self.output = None
-
- def startElement(self, name, attrs, connection):
- return None
-
- def endElement(self, name, value, connection):
- if name == 'instanceId':
- self.instance_id = value
- elif name == 'timestamp':
- self.timestamp = value
- elif name == 'output':
- self.output = base64.b64decode(value)
- else:
- setattr(self, name, value)
-
-class InstanceAttribute(dict):
-
- def __init__(self, parent=None):
- dict.__init__(self)
- self._current_value = None
-
- def startElement(self, name, attrs, connection):
- return None
-
- def endElement(self, name, value, connection):
- if name == 'value':
- self._current_value = value
- else:
- self[name] = self._current_value
-
-class StateReason(dict):
-
- def __init__(self, parent=None):
- dict.__init__(self)
-
- def startElement(self, name, attrs, connection):
- return None
-
- def endElement(self, name, value, connection):
- if name != 'stateReason':
- self[name] = value
-
« no previous file with comments | « third_party/gsutil/20110627/boto/boto/ec2/image.py ('k') | third_party/gsutil/20110627/boto/boto/ec2/instanceinfo.py » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698