Index: tools/telemetry/third_party/gsutil/third_party/boto/boto/ec2/cloudwatch/alarm.py |
diff --git a/tools/telemetry/third_party/gsutil/third_party/boto/boto/ec2/cloudwatch/alarm.py b/tools/telemetry/third_party/gsutil/third_party/boto/boto/ec2/cloudwatch/alarm.py |
deleted file mode 100644 |
index c267ab0332a7d544dddd5df1d72dac0801af6bdf..0000000000000000000000000000000000000000 |
--- a/tools/telemetry/third_party/gsutil/third_party/boto/boto/ec2/cloudwatch/alarm.py |
+++ /dev/null |
@@ -1,323 +0,0 @@ |
-# Copyright (c) 2010 Reza Lotun http://reza.lotun.name |
-# |
-# 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. |
-# |
- |
-from datetime import datetime |
-from boto.ec2.cloudwatch.listelement import ListElement |
-from boto.ec2.cloudwatch.dimension import Dimension |
-from boto.compat import json |
-from boto.compat import six |
- |
- |
-class MetricAlarms(list): |
- def __init__(self, connection=None): |
- """ |
- Parses a list of MetricAlarms. |
- """ |
- list.__init__(self) |
- self.connection = connection |
- |
- def startElement(self, name, attrs, connection): |
- if name == 'member': |
- metric_alarm = MetricAlarm(connection) |
- self.append(metric_alarm) |
- return metric_alarm |
- |
- def endElement(self, name, value, connection): |
- pass |
- |
- |
-class MetricAlarm(object): |
- |
- OK = 'OK' |
- ALARM = 'ALARM' |
- INSUFFICIENT_DATA = 'INSUFFICIENT_DATA' |
- |
- _cmp_map = { |
- '>=': 'GreaterThanOrEqualToThreshold', |
- '>': 'GreaterThanThreshold', |
- '<': 'LessThanThreshold', |
- '<=': 'LessThanOrEqualToThreshold', |
- } |
- _rev_cmp_map = dict((v, k) for (k, v) in six.iteritems(_cmp_map)) |
- |
- def __init__(self, connection=None, name=None, metric=None, |
- namespace=None, statistic=None, comparison=None, |
- threshold=None, period=None, evaluation_periods=None, |
- unit=None, description='', dimensions=None, |
- alarm_actions=None, insufficient_data_actions=None, |
- ok_actions=None): |
- """ |
- Creates a new Alarm. |
- |
- :type name: str |
- :param name: Name of alarm. |
- |
- :type metric: str |
- :param metric: Name of alarm's associated metric. |
- |
- :type namespace: str |
- :param namespace: The namespace for the alarm's metric. |
- |
- :type statistic: str |
- :param statistic: The statistic to apply to the alarm's associated |
- metric. |
- Valid values: SampleCount|Average|Sum|Minimum|Maximum |
- |
- :type comparison: str |
- :param comparison: Comparison used to compare statistic with threshold. |
- Valid values: >= | > | < | <= |
- |
- :type threshold: float |
- :param threshold: The value against which the specified statistic |
- is compared. |
- |
- :type period: int |
- :param period: The period in seconds over which the specified |
- statistic is applied. |
- |
- :type evaluation_periods: int |
- :param evaluation_periods: The number of periods over which data is |
- compared to the specified threshold. |
- |
- :type unit: str |
- :param unit: Allowed Values are: |
- Seconds|Microseconds|Milliseconds, |
- Bytes|Kilobytes|Megabytes|Gigabytes|Terabytes, |
- Bits|Kilobits|Megabits|Gigabits|Terabits, |
- Percent|Count| |
- Bytes/Second|Kilobytes/Second|Megabytes/Second| |
- Gigabytes/Second|Terabytes/Second, |
- Bits/Second|Kilobits/Second|Megabits/Second, |
- Gigabits/Second|Terabits/Second|Count/Second|None |
- |
- :type description: str |
- :param description: Description of MetricAlarm |
- |
- :type dimensions: dict |
- :param dimensions: A dictionary of dimension key/values where |
- the key is the dimension name and the value |
- is either a scalar value or an iterator |
- of values to be associated with that |
- dimension. |
- Example: { |
- 'InstanceId': ['i-0123456', 'i-0123457'], |
- 'LoadBalancerName': 'test-lb' |
- } |
- |
- :type alarm_actions: list of strs |
- :param alarm_actions: A list of the ARNs of the actions to take in |
- ALARM state |
- |
- :type insufficient_data_actions: list of strs |
- :param insufficient_data_actions: A list of the ARNs of the actions to |
- take in INSUFFICIENT_DATA state |
- |
- :type ok_actions: list of strs |
- :param ok_actions: A list of the ARNs of the actions to take in OK state |
- """ |
- self.name = name |
- self.connection = connection |
- self.metric = metric |
- self.namespace = namespace |
- self.statistic = statistic |
- if threshold is not None: |
- self.threshold = float(threshold) |
- else: |
- self.threshold = None |
- self.comparison = self._cmp_map.get(comparison) |
- if period is not None: |
- self.period = int(period) |
- else: |
- self.period = None |
- if evaluation_periods is not None: |
- self.evaluation_periods = int(evaluation_periods) |
- else: |
- self.evaluation_periods = None |
- self.actions_enabled = None |
- self.alarm_arn = None |
- self.last_updated = None |
- self.description = description |
- self.dimensions = dimensions |
- self.state_reason = None |
- self.state_value = None |
- self.unit = unit |
- self.alarm_actions = alarm_actions |
- self.insufficient_data_actions = insufficient_data_actions |
- self.ok_actions = ok_actions |
- |
- def __repr__(self): |
- return 'MetricAlarm:%s[%s(%s) %s %s]' % (self.name, self.metric, |
- self.statistic, |
- self.comparison, |
- self.threshold) |
- |
- def startElement(self, name, attrs, connection): |
- if name == 'AlarmActions': |
- self.alarm_actions = ListElement() |
- return self.alarm_actions |
- elif name == 'InsufficientDataActions': |
- self.insufficient_data_actions = ListElement() |
- return self.insufficient_data_actions |
- elif name == 'OKActions': |
- self.ok_actions = ListElement() |
- return self.ok_actions |
- elif name == 'Dimensions': |
- self.dimensions = Dimension() |
- return self.dimensions |
- else: |
- pass |
- |
- def endElement(self, name, value, connection): |
- if name == 'ActionsEnabled': |
- self.actions_enabled = value |
- elif name == 'AlarmArn': |
- self.alarm_arn = value |
- elif name == 'AlarmConfigurationUpdatedTimestamp': |
- self.last_updated = value |
- elif name == 'AlarmDescription': |
- self.description = value |
- elif name == 'AlarmName': |
- self.name = value |
- elif name == 'ComparisonOperator': |
- setattr(self, 'comparison', self._rev_cmp_map[value]) |
- elif name == 'EvaluationPeriods': |
- self.evaluation_periods = int(value) |
- elif name == 'MetricName': |
- self.metric = value |
- elif name == 'Namespace': |
- self.namespace = value |
- elif name == 'Period': |
- self.period = int(value) |
- elif name == 'StateReason': |
- self.state_reason = value |
- elif name == 'StateValue': |
- self.state_value = value |
- elif name == 'Statistic': |
- self.statistic = value |
- elif name == 'Threshold': |
- self.threshold = float(value) |
- elif name == 'Unit': |
- self.unit = value |
- else: |
- setattr(self, name, value) |
- |
- def set_state(self, value, reason, data=None): |
- """ Temporarily sets the state of an alarm. |
- |
- :type value: str |
- :param value: OK | ALARM | INSUFFICIENT_DATA |
- |
- :type reason: str |
- :param reason: Reason alarm set (human readable). |
- |
- :type data: str |
- :param data: Reason data (will be jsonified). |
- """ |
- return self.connection.set_alarm_state(self.name, reason, value, data) |
- |
- def update(self): |
- return self.connection.update_alarm(self) |
- |
- def enable_actions(self): |
- return self.connection.enable_alarm_actions([self.name]) |
- |
- def disable_actions(self): |
- return self.connection.disable_alarm_actions([self.name]) |
- |
- def describe_history(self, start_date=None, end_date=None, max_records=None, |
- history_item_type=None, next_token=None): |
- return self.connection.describe_alarm_history(self.name, start_date, |
- end_date, max_records, |
- history_item_type, |
- next_token) |
- |
- def add_alarm_action(self, action_arn=None): |
- """ |
- Adds an alarm action, represented as an SNS topic, to this alarm. |
- What do do when alarm is triggered. |
- |
- :type action_arn: str |
- :param action_arn: SNS topics to which notification should be |
- sent if the alarm goes to state ALARM. |
- """ |
- if not action_arn: |
- return # Raise exception instead? |
- self.actions_enabled = 'true' |
- self.alarm_actions.append(action_arn) |
- |
- def add_insufficient_data_action(self, action_arn=None): |
- """ |
- Adds an insufficient_data action, represented as an SNS topic, to |
- this alarm. What to do when the insufficient_data state is reached. |
- |
- :type action_arn: str |
- :param action_arn: SNS topics to which notification should be |
- sent if the alarm goes to state INSUFFICIENT_DATA. |
- """ |
- if not action_arn: |
- return |
- self.actions_enabled = 'true' |
- self.insufficient_data_actions.append(action_arn) |
- |
- def add_ok_action(self, action_arn=None): |
- """ |
- Adds an ok action, represented as an SNS topic, to this alarm. What |
- to do when the ok state is reached. |
- |
- :type action_arn: str |
- :param action_arn: SNS topics to which notification should be |
- sent if the alarm goes to state INSUFFICIENT_DATA. |
- """ |
- if not action_arn: |
- return |
- self.actions_enabled = 'true' |
- self.ok_actions.append(action_arn) |
- |
- def delete(self): |
- self.connection.delete_alarms([self.name]) |
- |
- |
-class AlarmHistoryItem(object): |
- def __init__(self, connection=None): |
- self.connection = connection |
- |
- def __repr__(self): |
- return 'AlarmHistory:%s[%s at %s]' % (self.name, self.summary, self.timestamp) |
- |
- def startElement(self, name, attrs, connection): |
- pass |
- |
- def endElement(self, name, value, connection): |
- if name == 'AlarmName': |
- self.name = value |
- elif name == 'HistoryData': |
- self.data = json.loads(value) |
- elif name == 'HistoryItemType': |
- self.tem_type = value |
- elif name == 'HistorySummary': |
- self.summary = value |
- elif name == 'Timestamp': |
- try: |
- self.timestamp = datetime.strptime(value, |
- '%Y-%m-%dT%H:%M:%S.%fZ') |
- except ValueError: |
- self.timestamp = datetime.strptime(value, '%Y-%m-%dT%H:%M:%SZ') |