initial commit

Author: Shayne Clausson

README.md

@@ -0,0 +1,37 @@
+# ECS Instance Draining on Scale In
+===================================
+
+Heavily inspired by this AWS [blog post](https://aws.amazon.com/blogs/compute/how-to-automate-container-instance-draining-in-amazon-ecs/), this module deploys resources and code to support ECS Instance Draning to ensure that running tasks are not obliterated by ASG scale-in events.
+
+![alt tag](https://s3.amazonaws.com/chrisb/Architecture.png)
+
+Further details about [AutoScaling Lifecyle Hooks](http://docs.aws.amazon.com/autoscaling/latest/userguide/lifecycle-hooks.html) is available.
+
+Module Input Variables
+----------------------
+
+- `autoscaling_group_name` - The Name of the AutoScaling Group used by the ECS Cluster.
+- `hook_heartbeat_timeout` - Amount of time, in seconds, the lifecycle hook should wait before giving up and moving onto the default result. Defaults to 900 (15 mins).
+- `hook_default_result` - Can be one of either ABANDON or CONTINUE. ABANDON stops any remaining actions, such as other lifecycle hooks, while CONTINUE allows any other lifecycle hooks to complete. Default is ABANDON
+- `enabled` - boolean expression. If false, the Lifecycle Hook is removed from the AutoScaling Group. Defaults to `true`.
+
+Usage
+-----
+
+```js
+resource "aws_autoscaling_group" "ecs" {
+  #properties omitted
+}
+
+module "ecs_instance_draining_on_scale_in" {
+  source = "../../../modules/ecs-instance-draining-on-scale-in"
+
+  autoscaling_group_name = "${aws_autoscaling_group.ecs.asg_name}"
+  hook_heartbeat_timeout = 1800
+  hook_default_result    = "ABANDON"
+}
+```
+
+Author
+------
+Created and maintained by [Shayne Clausson](https://github.com/sclausson)

index/_markerlib/__init__.py

@@ -0,0 +1,16 @@
+try:
+    import ast
+    from _markerlib.markers import default_environment, compile, interpret
+except ImportError:
+    if 'ast' in globals():
+        raise
+    def default_environment():
+        return {}
+    def compile(marker):
+        def marker_fn(environment=None, override=None):
+            # 'empty markers are True' heuristic won't install extra deps.
+            return not marker.strip()
+        marker_fn.__doc__ = marker
+        return marker_fn
+    def interpret(marker, environment=None, override=None):
+        return compile(marker)()

index/_markerlib/__init__.pyc

@@ -0,0 +1,119 @@
+# -*- coding: utf-8 -*-
+"""Interpret PEP 345 environment markers.
+
+EXPR [in|==|!=|not in] EXPR [or|and] ...
+
+where EXPR belongs to any of those:
+
+    python_version = '%s.%s' % (sys.version_info[0], sys.version_info[1])
+    python_full_version = sys.version.split()[0]
+    os.name = os.name
+    sys.platform = sys.platform
+    platform.version = platform.version()
+    platform.machine = platform.machine()
+    platform.python_implementation = platform.python_implementation()
+    a free string, like '2.6', or 'win32'
+"""
+
+__all__ = ['default_environment', 'compile', 'interpret']
+
+import ast
+import os
+import platform
+import sys
+import weakref
+
+_builtin_compile = compile
+
+try:
+    from platform import python_implementation
+except ImportError:
+    if os.name == "java":
+        # Jython 2.5 has ast module, but not platform.python_implementation() function.
+        def python_implementation():
+            return "Jython"
+    else:
+        raise
+
+
+# restricted set of variables
+_VARS = {'sys.platform': sys.platform,
+         'python_version': '%s.%s' % sys.version_info[:2],
+         # FIXME parsing sys.platform is not reliable, but there is no other
+         # way to get e.g. 2.7.2+, and the PEP is defined with sys.version
+         'python_full_version': sys.version.split(' ', 1)[0],
+         'os.name': os.name,
+         'platform.version': platform.version(),
+         'platform.machine': platform.machine(),
+         'platform.python_implementation': python_implementation(),
+         'extra': None # wheel extension
+        }
+
+for var in list(_VARS.keys()):
+    if '.' in var:
+        _VARS[var.replace('.', '_')] = _VARS[var]
+
+def default_environment():
+    """Return copy of default PEP 385 globals dictionary."""
+    return dict(_VARS)
+
+class ASTWhitelist(ast.NodeTransformer):
+    def __init__(self, statement):
+        self.statement = statement # for error messages
+
+    ALLOWED = (ast.Compare, ast.BoolOp, ast.Attribute, ast.Name, ast.Load, ast.Str)
+    # Bool operations
+    ALLOWED += (ast.And, ast.Or)
+    # Comparison operations
+    ALLOWED += (ast.Eq, ast.Gt, ast.GtE, ast.In, ast.Is, ast.IsNot, ast.Lt, ast.LtE, ast.NotEq, ast.NotIn)
+
+    def visit(self, node):
+        """Ensure statement only contains allowed nodes."""
+        if not isinstance(node, self.ALLOWED):
+            raise SyntaxError('Not allowed in environment markers.\n%s\n%s' %
+                               (self.statement,
+                               (' ' * node.col_offset) + '^'))
+        return ast.NodeTransformer.visit(self, node)
+
+    def visit_Attribute(self, node):
+        """Flatten one level of attribute access."""
+        new_node = ast.Name("%s.%s" % (node.value.id, node.attr), node.ctx)
+        return ast.copy_location(new_node, node)
+
+def parse_marker(marker):
+    tree = ast.parse(marker, mode='eval')
+    new_tree = ASTWhitelist(marker).generic_visit(tree)
+    return new_tree
+
+def compile_marker(parsed_marker):
+    return _builtin_compile(parsed_marker, '<environment marker>', 'eval',
+                   dont_inherit=True)
+
+_cache = weakref.WeakValueDictionary()
+
+def compile(marker):
+    """Return compiled marker as a function accepting an environment dict."""
+    try:
+        return _cache[marker]
+    except KeyError:
+        pass
+    if not marker.strip():
+        def marker_fn(environment=None, override=None):
+            """"""
+            return True
+    else:
+        compiled_marker = compile_marker(parse_marker(marker))
+        def marker_fn(environment=None, override=None):
+            """override updates environment"""
+            if override is None:
+                override = {}
+            if environment is None:
+                environment = default_environment()
+            environment.update(override)
+            return eval(compiled_marker, environment)
+    marker_fn.__doc__ = marker
+    _cache[marker] = marker_fn
+    return _cache[marker]
+
+def interpret(marker, environment=None):
+    return compile(marker)(environment)

index/_markerlib/markers.py

@@ -0,0 +1,116 @@
+===============================
+Boto 3 - The AWS SDK for Python
+===============================
+
+|Build Status| |Docs| |Version|
+
+Boto3 is the Amazon Web Services (AWS) Software Development Kit (SDK) for
+Python, which allows Python developers to write software that makes use
+of services like Amazon S3 and Amazon EC2. You can find the latest, most
+up to date, documentation at `Read the Docs`_, including a list of
+services that are supported. To see only those features which have been
+released, check out the `stable docs`_.
+
+
+.. _boto: https://docs.pythonboto.org/
+.. _`stable docs`: https://boto3.readthedocs.io/en/stable/
+.. _`Read the Docs`: https://boto3.readthedocs.io/en/latest/
+.. |Build Status| image:: http://img.shields.io/travis/boto/boto3/develop.svg?style=flat
+    :target: https://travis-ci.org/boto/boto3
+    :alt: Build Status
+.. |Docs| image:: https://readthedocs.org/projects/boto3/badge/?version=latest&style=flat
+    :target: https://boto3.readthedocs.io/en/latest/
+    :alt: Read the docs
+.. |Downloads| image:: http://img.shields.io/pypi/dm/boto3.svg?style=flat
+    :target: https://pypi.python.org/pypi/boto3/
+    :alt: Downloads
+.. |Version| image:: http://img.shields.io/pypi/v/boto3.svg?style=flat
+    :target: https://pypi.python.org/pypi/boto3/
+    :alt: Version
+.. |License| image:: http://img.shields.io/pypi/l/boto3.svg?style=flat
+    :target: https://github.com/boto/boto3/blob/develop/LICENSE
+    :alt: License
+
+Quick Start
+-----------
+First, install the library and set a default region:
+
+.. code-block:: sh
+
+    $ pip install boto3
+
+Next, set up credentials (in e.g. ``~/.aws/credentials``):
+
+.. code-block:: ini
+
+    [default]
+    aws_access_key_id = YOUR_KEY
+    aws_secret_access_key = YOUR_SECRET
+
+Then, set up a default region (in e.g. ``~/.aws/config``):
+
+.. code-block:: ini
+
+    [default]
+    region=us-east-1
+
+Then, from a Python interpreter:
+
+.. code-block:: python
+
+    >>> import boto3
+    >>> s3 = boto3.resource('s3')
+    >>> for bucket in s3.buckets.all():
+            print(bucket.name)
+
+Development
+-----------
+
+Getting Started
+~~~~~~~~~~~~~~~
+Assuming that you have Python and ``virtualenv`` installed, set up your
+environment and install the required dependencies like this instead of
+the ``pip install boto3`` defined above:
+
+.. code-block:: sh
+
+    $ git clone https://github.com/boto/boto3.git
+    $ cd boto3
+    $ virtualenv venv
+    ...
+    $ . venv/bin/activate
+    $ pip install -r requirements.txt
+    $ pip install -e .
+
+Running Tests
+~~~~~~~~~~~~~
+You can run tests in all supported Python versions using ``tox``. By default,
+it will run all of the unit tests, but you can also specify your own
+``nosetests`` options. Note that this requires that you have all supported
+versions of Python installed, otherwise you must pass ``-e`` or run the
+``nosetests`` command directly:
+
+.. code-block:: sh
+
+    $ tox
+    $ tox tests/unit/test_session.py
+    $ tox -e py26,py33 tests/integration
+
+You can also run individual tests with your default Python version:
+
+.. code-block:: sh
+
+    $ nosetests tests/unit
+
+Generating Documentation
+~~~~~~~~~~~~~~~~~~~~~~~~
+Sphinx is used for documentation. You can generate HTML locally with the
+following:
+
+.. code-block:: sh
+
+    $ pip install -r requirements-docs.txt
+    $ cd docs
+    $ make html
+
+