| Index: third_party/gsutil/boto/boto/ec2/networkinterface.py
|
| diff --git a/third_party/gsutil/boto/boto/ec2/networkinterface.py b/third_party/gsutil/boto/boto/ec2/networkinterface.py
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..f044add31c2a4c30371ce5f4a65082e7b957eea7
|
| --- /dev/null
|
| +++ b/third_party/gsutil/boto/boto/ec2/networkinterface.py
|
| @@ -0,0 +1,247 @@
|
| +# Copyright (c) 2011 Mitch Garnaat http://garnaat.org/
|
| +# Copyright (c) 2012 Amazon.com, Inc. or its affiliates. All Rights Reserved
|
| +#
|
| +# 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 Elastic Network Interface
|
| +"""
|
| +from boto.ec2.ec2object import TaggedEC2Object
|
| +from boto.resultset import ResultSet
|
| +from boto.ec2.group import Group
|
| +
|
| +
|
| +class Attachment(object):
|
| + """
|
| + :ivar id: The ID of the attachment.
|
| + :ivar instance_id: The ID of the instance.
|
| + :ivar device_index: The index of this device.
|
| + :ivar status: The status of the device.
|
| + :ivar attach_time: The time the device was attached.
|
| + :ivar delete_on_termination: Whether the device will be deleted
|
| + when the instance is terminated.
|
| + """
|
| +
|
| + def __init__(self):
|
| + self.id = None
|
| + self.instance_id = None
|
| + self.instance_owner_id = None
|
| + self.device_index = 0
|
| + self.status = None
|
| + self.attach_time = None
|
| + self.delete_on_termination = False
|
| +
|
| + def __repr__(self):
|
| + return 'Attachment:%s' % self.id
|
| +
|
| + def startElement(self, name, attrs, connection):
|
| + return None
|
| +
|
| + def endElement(self, name, value, connection):
|
| + if name == 'attachmentId':
|
| + self.id = value
|
| + elif name == 'instanceId':
|
| + self.instance_id = value
|
| + elif name == 'instanceOwnerId':
|
| + self.instance_owner_id = value
|
| + elif name == 'status':
|
| + self.status = value
|
| + elif name == 'attachTime':
|
| + self.attach_time = value
|
| + elif name == 'deleteOnTermination':
|
| + if value.lower() == 'true':
|
| + self.delete_on_termination = True
|
| + else:
|
| + self.delete_on_termination = False
|
| + else:
|
| + setattr(self, name, value)
|
| +
|
| +
|
| +class NetworkInterface(TaggedEC2Object):
|
| + """
|
| + An Elastic Network Interface.
|
| +
|
| + :ivar id: The ID of the ENI.
|
| + :ivar subnet_id: The ID of the VPC subnet.
|
| + :ivar vpc_id: The ID of the VPC.
|
| + :ivar description: The description.
|
| + :ivar owner_id: The ID of the owner of the ENI.
|
| + :ivar requester_managed:
|
| + :ivar status: The interface's status (available|in-use).
|
| + :ivar mac_address: The MAC address of the interface.
|
| + :ivar private_ip_address: The IP address of the interface within
|
| + the subnet.
|
| + :ivar source_dest_check: Flag to indicate whether to validate
|
| + network traffic to or from this network interface.
|
| + :ivar groups: List of security groups associated with the interface.
|
| + :ivar attachment: The attachment object.
|
| + :ivar private_ip_addresses: A list of PrivateIPAddress objects.
|
| + """
|
| +
|
| + def __init__(self, connection=None):
|
| + TaggedEC2Object.__init__(self, connection)
|
| + self.id = None
|
| + self.subnet_id = None
|
| + self.vpc_id = None
|
| + self.availability_zone = None
|
| + self.description = None
|
| + self.owner_id = None
|
| + self.requester_managed = False
|
| + self.status = None
|
| + self.mac_address = None
|
| + self.private_ip_address = None
|
| + self.source_dest_check = None
|
| + self.groups = []
|
| + self.attachment = None
|
| + self.private_ip_addresses = []
|
| +
|
| + def __repr__(self):
|
| + return 'NetworkInterface:%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 == 'groupSet':
|
| + self.groups = ResultSet([('item', Group)])
|
| + return self.groups
|
| + elif name == 'attachment':
|
| + self.attachment = Attachment()
|
| + return self.attachment
|
| + elif name == 'privateIpAddressesSet':
|
| + self.private_ip_addresses = ResultSet([('item', PrivateIPAddress)])
|
| + return self.private_ip_addresses
|
| + else:
|
| + return None
|
| +
|
| + def endElement(self, name, value, connection):
|
| + if name == 'networkInterfaceId':
|
| + self.id = value
|
| + elif name == 'subnetId':
|
| + self.subnet_id = value
|
| + elif name == 'vpcId':
|
| + self.vpc_id = value
|
| + elif name == 'availabilityZone':
|
| + self.availability_zone = value
|
| + elif name == 'description':
|
| + self.description = value
|
| + elif name == 'ownerId':
|
| + self.owner_id = value
|
| + elif name == 'requesterManaged':
|
| + if value.lower() == 'true':
|
| + self.requester_managed = True
|
| + else:
|
| + self.requester_managed = False
|
| + elif name == 'status':
|
| + self.status = value
|
| + elif name == 'macAddress':
|
| + self.mac_address = value
|
| + elif name == 'privateIpAddress':
|
| + self.private_ip_address = value
|
| + elif name == 'sourceDestCheck':
|
| + if value.lower() == 'true':
|
| + self.source_dest_check = True
|
| + else:
|
| + self.source_dest_check = False
|
| + else:
|
| + setattr(self, name, value)
|
| +
|
| + def delete(self):
|
| + return self.connection.delete_network_interface(self.id)
|
| +
|
| +
|
| +class PrivateIPAddress(object):
|
| + def __init__(self, connection=None, private_ip_address=None,
|
| + primary=None):
|
| + self.connection = connection
|
| + self.private_ip_address = private_ip_address
|
| + self.primary = primary
|
| +
|
| + def startElement(self, name, attrs, connection):
|
| + pass
|
| +
|
| + def endElement(self, name, value, connection):
|
| + if name == 'privateIpAddress':
|
| + self.private_ip_address = value
|
| + elif name == 'primary':
|
| + self.primary = True if value.lower() == 'true' else False
|
| +
|
| + def __repr__(self):
|
| + return "PrivateIPAddress(%s, primary=%s)" % (self.private_ip_address,
|
| + self.primary)
|
| +
|
| +
|
| +class NetworkInterfaceCollection(list):
|
| + def __init__(self, *interfaces):
|
| + self.extend(interfaces)
|
| +
|
| + def build_list_params(self, params, prefix=''):
|
| + for i, spec in enumerate(self, 1):
|
| + full_prefix = '%sNetworkInterface.%s.' % (prefix, i)
|
| + if spec.network_interface_id is not None:
|
| + params[full_prefix + 'NetworkInterfaceId'] = \
|
| + str(spec.network_interface_id)
|
| + if spec.device_index is not None:
|
| + params[full_prefix + 'DeviceIndex'] = \
|
| + str(spec.device_index)
|
| + if spec.subnet_id is not None:
|
| + params[full_prefix + 'SubnetId'] = str(spec.subnet_id)
|
| + if spec.description is not None:
|
| + params[full_prefix + 'Description'] = str(spec.description)
|
| + if spec.delete_on_termination is not None:
|
| + params[full_prefix + 'DeleteOnTermination'] = \
|
| + 'true' if spec.delete_on_termination else 'false'
|
| + if spec.secondary_private_ip_address_count is not None:
|
| + params[full_prefix + 'SecondaryPrivateIpAddressCount'] = \
|
| + str(spec.secondary_private_ip_address_count)
|
| + if spec.private_ip_address is not None:
|
| + params[full_prefix + 'PrivateIpAddress'] = \
|
| + str(spec.private_ip_address)
|
| + if spec.groups is not None:
|
| + for j, group_id in enumerate(spec.groups, 1):
|
| + query_param_key = '%sSecurityGroupId.%s' % (full_prefix, j)
|
| + params[query_param_key] = str(group_id)
|
| + if spec.private_ip_addresses is not None:
|
| + for k, ip_addr in enumerate(spec.private_ip_addresses, 1):
|
| + query_param_key_prefix = (
|
| + '%sPrivateIpAddresses.%s' % (full_prefix, k))
|
| + params[query_param_key_prefix + '.PrivateIpAddress'] = \
|
| + str(ip_addr.private_ip_address)
|
| + if ip_addr.primary is not None:
|
| + params[query_param_key_prefix + '.Primary'] = \
|
| + 'true' if ip_addr.primary else 'false'
|
| +
|
| +
|
| +class NetworkInterfaceSpecification(object):
|
| + def __init__(self, network_interface_id=None, device_index=None,
|
| + subnet_id=None, description=None, private_ip_address=None,
|
| + groups=None, delete_on_termination=None,
|
| + private_ip_addresses=None,
|
| + secondary_private_ip_address_count=None):
|
| + self.network_interface_id = network_interface_id
|
| + self.device_index = device_index
|
| + self.subnet_id = subnet_id
|
| + self.description = description
|
| + self.private_ip_address = private_ip_address
|
| + self.groups = groups
|
| + self.delete_on_termination = delete_on_termination
|
| + self.private_ip_addresses = private_ip_addresses
|
| + self.secondary_private_ip_address_count = \
|
| + secondary_private_ip_address_count
|
|
|