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

Unified Diff: tools/telemetry/third_party/gsutil/third_party/boto/boto/configservice/layer1.py

Issue 1260493004: Revert "Add gsutil 4.13 to telemetry/third_party" (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 5 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: tools/telemetry/third_party/gsutil/third_party/boto/boto/configservice/layer1.py
diff --git a/tools/telemetry/third_party/gsutil/third_party/boto/boto/configservice/layer1.py b/tools/telemetry/third_party/gsutil/third_party/boto/boto/configservice/layer1.py
deleted file mode 100644
index fe598d98807b23ce6cd2ea02d1ed316da258ada2..0000000000000000000000000000000000000000
--- a/tools/telemetry/third_party/gsutil/third_party/boto/boto/configservice/layer1.py
+++ /dev/null
@@ -1,381 +0,0 @@
-# Copyright (c) 2015 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.
-#
-
-import boto
-from boto.compat import json
-from boto.connection import AWSQueryConnection
-from boto.regioninfo import RegionInfo
-from boto.exception import JSONResponseError
-from boto.configservice import exceptions
-
-
-class ConfigServiceConnection(AWSQueryConnection):
- """
- AWS Config
- AWS Config provides a way to keep track of the configurations of
- all the AWS resources associated with your AWS account. You can
- use AWS Config to get the current and historical configurations of
- each AWS resource and also to get information about the
- relationship between the resources. An AWS resource can be an
- Amazon Compute Cloud (Amazon EC2) instance, an Elastic Block Store
- (EBS) volume, an Elastic network Interface (ENI), or a security
- group. For a complete list of resources currently supported by AWS
- Config, see `Supported AWS Resources`_.
-
- You can access and manage AWS Config through the AWS Management
- Console, the AWS Command Line Interface (AWS CLI), the AWS Config
- API, or the AWS SDKs for AWS Config
-
- This reference guide contains documentation for the AWS Config API
- and the AWS CLI commands that you can use to manage AWS Config.
-
- The AWS Config API uses the Signature Version 4 protocol for
- signing requests. For more information about how to sign a request
- with this protocol, see `Signature Version 4 Signing Process`_.
-
- For detailed information about AWS Config features and their
- associated actions or commands, as well as how to work with AWS
- Management Console, see `What Is AWS Config?`_ in the AWS Config
- Developer Guide .
- """
- APIVersion = "2014-11-12"
- DefaultRegionName = "us-east-1"
- DefaultRegionEndpoint = "config.us-east-1.amazonaws.com"
- ServiceName = "ConfigService"
- TargetPrefix = "StarlingDoveService"
- ResponseError = JSONResponseError
-
- _faults = {
- "InvalidLimitException": exceptions.InvalidLimitException,
- "NoSuchBucketException": exceptions.NoSuchBucketException,
- "InvalidSNSTopicARNException": exceptions.InvalidSNSTopicARNException,
- "ResourceNotDiscoveredException": exceptions.ResourceNotDiscoveredException,
- "MaxNumberOfDeliveryChannelsExceededException": exceptions.MaxNumberOfDeliveryChannelsExceededException,
- "LastDeliveryChannelDeleteFailedException": exceptions.LastDeliveryChannelDeleteFailedException,
- "InsufficientDeliveryPolicyException": exceptions.InsufficientDeliveryPolicyException,
- "InvalidRoleException": exceptions.InvalidRoleException,
- "InvalidTimeRangeException": exceptions.InvalidTimeRangeException,
- "NoSuchDeliveryChannelException": exceptions.NoSuchDeliveryChannelException,
- "NoSuchConfigurationRecorderException": exceptions.NoSuchConfigurationRecorderException,
- "InvalidS3KeyPrefixException": exceptions.InvalidS3KeyPrefixException,
- "InvalidDeliveryChannelNameException": exceptions.InvalidDeliveryChannelNameException,
- "NoRunningConfigurationRecorderException": exceptions.NoRunningConfigurationRecorderException,
- "ValidationException": exceptions.ValidationException,
- "NoAvailableConfigurationRecorderException": exceptions.NoAvailableConfigurationRecorderException,
- "InvalidNextTokenException": exceptions.InvalidNextTokenException,
- "InvalidConfigurationRecorderNameException": exceptions.InvalidConfigurationRecorderNameException,
- "NoAvailableDeliveryChannelException": exceptions.NoAvailableDeliveryChannelException,
- "MaxNumberOfConfigurationRecordersExceededException": exceptions.MaxNumberOfConfigurationRecordersExceededException,
- }
-
-
- def __init__(self, **kwargs):
- region = kwargs.pop('region', None)
- if not region:
- region = RegionInfo(self, self.DefaultRegionName,
- self.DefaultRegionEndpoint)
-
- if 'host' not in kwargs or kwargs['host'] is None:
- kwargs['host'] = region.endpoint
-
- super(ConfigServiceConnection, self).__init__(**kwargs)
- self.region = region
-
- def _required_auth_capability(self):
- return ['hmac-v4']
-
- def delete_delivery_channel(self, delivery_channel_name):
- """
- Deletes the specified delivery channel.
-
- The delivery channel cannot be deleted if it is the only
- delivery channel and the configuration recorder is still
- running. To delete the delivery channel, stop the running
- configuration recorder using the StopConfigurationRecorder
- action.
-
- :type delivery_channel_name: string
- :param delivery_channel_name: The name of the delivery channel to
- delete.
-
- """
- params = {'DeliveryChannelName': delivery_channel_name, }
- return self.make_request(action='DeleteDeliveryChannel',
- body=json.dumps(params))
-
- def deliver_config_snapshot(self, delivery_channel_name):
- """
- Schedules delivery of a configuration snapshot to the Amazon
- S3 bucket in the specified delivery channel. After the
- delivery has started, AWS Config sends following notifications
- using an Amazon SNS topic that you have specified.
-
-
- + Notification of starting the delivery.
- + Notification of delivery completed, if the delivery was
- successfully completed.
- + Notification of delivery failure, if the delivery failed to
- complete.
-
- :type delivery_channel_name: string
- :param delivery_channel_name: The name of the delivery channel through
- which the snapshot is delivered.
-
- """
- params = {'deliveryChannelName': delivery_channel_name, }
- return self.make_request(action='DeliverConfigSnapshot',
- body=json.dumps(params))
-
- def describe_configuration_recorder_status(self,
- configuration_recorder_names=None):
- """
- Returns the current status of the specified configuration
- recorder. If a configuration recorder is not specified, this
- action returns the status of all configuration recorder
- associated with the account.
-
- :type configuration_recorder_names: list
- :param configuration_recorder_names: The name(s) of the configuration
- recorder. If the name is not specified, the action returns the
- current status of all the configuration recorders associated with
- the account.
-
- """
- params = {}
- if configuration_recorder_names is not None:
- params['ConfigurationRecorderNames'] = configuration_recorder_names
- return self.make_request(action='DescribeConfigurationRecorderStatus',
- body=json.dumps(params))
-
- def describe_configuration_recorders(self,
- configuration_recorder_names=None):
- """
- Returns the name of one or more specified configuration
- recorders. If the recorder name is not specified, this action
- returns the names of all the configuration recorders
- associated with the account.
-
- :type configuration_recorder_names: list
- :param configuration_recorder_names: A list of configuration recorder
- names.
-
- """
- params = {}
- if configuration_recorder_names is not None:
- params['ConfigurationRecorderNames'] = configuration_recorder_names
- return self.make_request(action='DescribeConfigurationRecorders',
- body=json.dumps(params))
-
- def describe_delivery_channel_status(self, delivery_channel_names=None):
- """
- Returns the current status of the specified delivery channel.
- If a delivery channel is not specified, this action returns
- the current status of all delivery channels associated with
- the account.
-
- :type delivery_channel_names: list
- :param delivery_channel_names: A list of delivery channel names.
-
- """
- params = {}
- if delivery_channel_names is not None:
- params['DeliveryChannelNames'] = delivery_channel_names
- return self.make_request(action='DescribeDeliveryChannelStatus',
- body=json.dumps(params))
-
- def describe_delivery_channels(self, delivery_channel_names=None):
- """
- Returns details about the specified delivery channel. If a
- delivery channel is not specified, this action returns the
- details of all delivery channels associated with the account.
-
- :type delivery_channel_names: list
- :param delivery_channel_names: A list of delivery channel names.
-
- """
- params = {}
- if delivery_channel_names is not None:
- params['DeliveryChannelNames'] = delivery_channel_names
- return self.make_request(action='DescribeDeliveryChannels',
- body=json.dumps(params))
-
- def get_resource_config_history(self, resource_type, resource_id,
- later_time=None, earlier_time=None,
- chronological_order=None, limit=None,
- next_token=None):
- """
- Returns a list of configuration items for the specified
- resource. The list contains details about each state of the
- resource during the specified time interval. You can specify a
- `limit` on the number of results returned on the page. If a
- limit is specified, a `nextToken` is returned as part of the
- result that you can use to continue this request.
-
- :type resource_type: string
- :param resource_type: The resource type.
-
- :type resource_id: string
- :param resource_id: The ID of the resource (for example., `sg-xxxxxx`).
-
- :type later_time: timestamp
- :param later_time: The time stamp that indicates a later time. If not
- specified, current time is taken.
-
- :type earlier_time: timestamp
- :param earlier_time: The time stamp that indicates an earlier time. If
- not specified, the action returns paginated results that contain
- configuration items that start from when the first configuration
- item was recorded.
-
- :type chronological_order: string
- :param chronological_order: The chronological order for configuration
- items listed. By default the results are listed in reverse
- chronological order.
-
- :type limit: integer
- :param limit: The maximum number of configuration items returned in
- each page. The default is 10. You cannot specify a limit greater
- than 100.
-
- :type next_token: string
- :param next_token: An optional parameter used for pagination of the
- results.
-
- """
- params = {
- 'resourceType': resource_type,
- 'resourceId': resource_id,
- }
- if later_time is not None:
- params['laterTime'] = later_time
- if earlier_time is not None:
- params['earlierTime'] = earlier_time
- if chronological_order is not None:
- params['chronologicalOrder'] = chronological_order
- if limit is not None:
- params['limit'] = limit
- if next_token is not None:
- params['nextToken'] = next_token
- return self.make_request(action='GetResourceConfigHistory',
- body=json.dumps(params))
-
- def put_configuration_recorder(self, configuration_recorder):
- """
- Creates a new configuration recorder to record the resource
- configurations.
-
- You can use this action to change the role ( `roleARN`) of an
- existing recorder. To change the role, call the action on the
- existing configuration recorder and specify a role.
-
- :type configuration_recorder: dict
- :param configuration_recorder: The configuration recorder object that
- records each configuration change made to the resources.
-
- """
- params = {'ConfigurationRecorder': configuration_recorder, }
- return self.make_request(action='PutConfigurationRecorder',
- body=json.dumps(params))
-
- def put_delivery_channel(self, delivery_channel):
- """
- Creates a new delivery channel object to deliver the
- configuration information to an Amazon S3 bucket, and to an
- Amazon SNS topic.
-
- You can use this action to change the Amazon S3 bucket or an
- Amazon SNS topic of the existing delivery channel. To change
- the Amazon S3 bucket or an Amazon SNS topic, call this action
- and specify the changed values for the S3 bucket and the SNS
- topic. If you specify a different value for either the S3
- bucket or the SNS topic, this action will keep the existing
- value for the parameter that is not changed.
-
- :type delivery_channel: dict
- :param delivery_channel: The configuration delivery channel object that
- delivers the configuration information to an Amazon S3 bucket, and
- to an Amazon SNS topic.
-
- """
- params = {'DeliveryChannel': delivery_channel, }
- return self.make_request(action='PutDeliveryChannel',
- body=json.dumps(params))
-
- def start_configuration_recorder(self, configuration_recorder_name):
- """
- Starts recording configurations of all the resources
- associated with the account.
-
- You must have created at least one delivery channel to
- successfully start the configuration recorder.
-
- :type configuration_recorder_name: string
- :param configuration_recorder_name: The name of the recorder object
- that records each configuration change made to the resources.
-
- """
- params = {
- 'ConfigurationRecorderName': configuration_recorder_name,
- }
- return self.make_request(action='StartConfigurationRecorder',
- body=json.dumps(params))
-
- def stop_configuration_recorder(self, configuration_recorder_name):
- """
- Stops recording configurations of all the resources associated
- with the account.
-
- :type configuration_recorder_name: string
- :param configuration_recorder_name: The name of the recorder object
- that records each configuration change made to the resources.
-
- """
- params = {
- 'ConfigurationRecorderName': configuration_recorder_name,
- }
- return self.make_request(action='StopConfigurationRecorder',
- body=json.dumps(params))
-
- def make_request(self, action, body):
- headers = {
- 'X-Amz-Target': '%s.%s' % (self.TargetPrefix, action),
- 'Host': self.region.endpoint,
- 'Content-Type': 'application/x-amz-json-1.1',
- 'Content-Length': str(len(body)),
- }
- http_request = self.build_base_http_request(
- method='POST', path='/', auth_path='/', params={},
- headers=headers, data=body)
- response = self._mexe(http_request, sender=None,
- override_num_retries=10)
- response_body = response.read().decode('utf-8')
- boto.log.debug(response_body)
- if response.status == 200:
- if response_body:
- return json.loads(response_body)
- else:
- json_body = json.loads(response_body)
- fault_name = json_body.get('__type', None)
- exception_class = self._faults.get(fault_name, self.ResponseError)
- raise exception_class(response.status, response.reason,
- body=json_body)
-

Powered by Google App Engine
This is Rietveld 408576698