Class: MovableInk::AWS

Inherits:
Object
  • Object
show all
Includes:
ApiGateway, Athena, Autoscaling, EC2, ElastiCache, Metadata, Route53, S3, SNS, SSM
Defined in:
lib/movable_ink/aws.rb,
lib/movable_ink/aws/s3.rb,
lib/movable_ink/aws/ec2.rb,
lib/movable_ink/aws/sns.rb,
lib/movable_ink/aws/ssm.rb,
lib/movable_ink/version.rb,
lib/movable_ink/aws/athena.rb,
lib/movable_ink/aws/errors.rb,
lib/movable_ink/aws/route53.rb,
lib/movable_ink/aws/metadata.rb,
lib/movable_ink/aws/api_gateway.rb,
lib/movable_ink/aws/autoscaling.rb,
lib/movable_ink/aws/elasticache.rb

Defined Under Namespace

Modules: ApiGateway, Athena, Autoscaling, EC2, ElastiCache, Errors, Metadata, Route53, S3, SNS, SSM

Constant Summary collapse

VERSION = 
'1.1.0'

Class Method Summary collapse

Instance Method Summary collapse

Methods included from ApiGateway

#post_signed_gateway_request

Methods included from ElastiCache

#all_elasticache_replicas, #elasticache, #elasticache_primary, #elasticache_replica_in_my_az, #elasticache_replicas, #node_group_members, #node_group_members_in_my_az, #replication_group

Methods included from S3

#directory_exists?, #s3

Methods included from Athena

#athena

Methods included from SSM

#extract_parameters, #get_role_secrets, #get_secret, #run_with_backoff_and_client_fallback, #ssm_client, #ssm_client_failover

Methods included from Route53

#delete_resource_record_sets, #find_health_check_by_tag, #get_health_check_tags, #get_resource_record_sets_by_instance_name, #list_all_r53_resource_record_sets, #list_health_checks, #resource_record_sets, #route53

Methods included from Autoscaling

#autoscaling, #complete_lifecycle_action, #delete_role_tag, #keep_instance_alive, #mark_me_as_healthy, #mark_me_as_unhealthy, #record_lifecycle_action_heartbeat

Methods included from SNS

#notify_and_sleep, #notify_nsq_can_not_be_drained, #notify_pagerduty, #notify_slack, #sns, #sns_pagerduty_topic_arn, #sns_slack_topic_arn

Methods included from EC2

#all_instances, #assign_ip_address, #available_elastic_ips, #default_filter, #ec2, #elastic_ips, #instance_ip_addresses_by_role, #instance_ip_addresses_by_role_ordered, #instance_tags, #instances, #load_all_instances, #load_mi_env, #me, #mi_env, #mi_env_cache_file_path, #private_ip_addresses, #redis_by_role, #statsd_host, #thopter, #thopter_instance, #unassigned_elastic_ips

Methods included from Metadata

#availability_zone, #http, #instance_id, #private_ipv4, #retrieve_metadata

Constructor Details

#initialize(ipv4: nil, environment: nil, global_service: nil, instance_id: nil, availability_zone: nil) ⇒ AWS

Returns a new instance of AWS.



39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/movable_ink/aws.rb', line 39

def initialize(
  ipv4: nil,
  environment: nil,
  global_service: nil,
  instance_id: nil,
  availability_zone: nil
)
  @mi_env = environment
  @ipv4 = ipv4
  @instance_id = instance_id
  @availability_zone = availability_zone

  if global_service
    @availability_zone = 'us-east-1a'
    @instance_id = global_service
    @ipv4 = global_service
  end
end

Class Method Details

.regions ⇒ Object 



29
30
31
32
33
34
35
36
 
# File 'lib/movable_ink/aws.rb', line 29

def regions
  {
    'iad' => 'us-east-1',
    'rld' => 'us-west-2',
    'dub' => 'eu-west-1',
    'ord' => 'us-east-2'
  }
end

Instance Method Details

#datacenter(region: my_region) ⇒ Object 



102
103
104
 
# File 'lib/movable_ink/aws.rb', line 102

def datacenter(region: my_region)
  regions.key(region)
end

#my_region ⇒ Object 



98
99
100
 
# File 'lib/movable_ink/aws.rb', line 98

def my_region
  @my_region ||= availability_zone.chop
end

#regions ⇒ Object 



94
95
96
 
# File 'lib/movable_ink/aws.rb', line 94

def regions
  self.class.regions
end

#run_with_backoff(quiet: false, tries: 9) ⇒ Object

Raises:



58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
 
# File 'lib/movable_ink/aws.rb', line 58

def run_with_backoff(quiet: false, tries: 9)
  tries.times do |num|
    begin
      return yield
    rescue Aws::EC2::Errors::RequestLimitExceeded,
           Aws::EC2::Errors::ResourceAlreadyAssociated,
           Aws::EC2::Errors::Unavailable,
           Aws::SNS::Errors::ThrottledException,
           Aws::AutoScaling::Errors::ThrottledException,
           Aws::S3::Errors::SlowDown,
           Aws::Route53::Errors::Throttling,
           Aws::Route53::Errors::ThrottlingException,
           Aws::Route53::Errors::PriorRequestNotComplete,
           Aws::Route53::Errors::ServiceUnavailable,
           Aws::SSM::Errors::TooManyUpdates,
           Aws::Athena::Errors::ThrottlingException,
           MovableInk::AWS::Errors::NoEnvironmentTagError
      sleep_time = (num+1)**2 + rand(10)
      if quiet
        (num >= tries - 1) ? notify_and_sleep(sleep_time, $!.class) : sleep(sleep_time)
      else
        notify_and_sleep(sleep_time, $!.class)
      end
    rescue Aws::Errors::ServiceError => e
      message = "#{e.class}: #{e.message}\nFrom #{$0}\n```\n#{e.backtrace.first(3).join("\n").gsub("`","'")}\n```"
      notify_slack(subject: 'Unhandled AWS API Error', message: message)
      puts message
      raise MovableInk::AWS::Errors::ServiceError
    end
  end
  message = "From: #{$0}\n```\n#{Thread.current.backtrace.first(3).join("\n").gsub("`","'")}\n```"
  notify_slack(subject: "AWS API failed after #{tries} attempts", message: message)
  puts message
  raise MovableInk::AWS::Errors::FailedWithBackoff
end