Class: Infrastructure

Inherits:

Object

• Object
• Infrastructure

Includes:

Cluster::Logging

Defined in:

lib/cluster/infrastructure.rb

Direct Known Subclasses

Amazon

Constant Summary

@@subsystem =

nil

@@cluster_name =

'cluster'

@@in_cluster =

false

@@machine_sizes =

%w(minimum basic average power super)

@@dns =

nil

Class Method Summary

• .cluster_name ⇒ Object
• .connect(arguments = nil) ⇒ Object
• .current ⇒ Object
• .dns ⇒ Object
• .in_cluster? ⇒ Boolean
• .sizes ⇒ Object (also: machine_sizes)

Instance Method Summary

• #configure ⇒ Object
• #credentials ⇒ Object
• #credentials? ⇒ Boolean
• #current_instance ⇒ Object
• #in_cluster? ⇒ Boolean
• #initialize(arguments = nil) ⇒ Infrastructure constructor

  A new instance of Infrastructure.

• #instances ⇒ Object
• #machines(*filter_groups) ⇒ Object
• #names(*roles) ⇒ Object
• #release_class ⇒ Object
• #services(filter_services) ⇒ Object
• #to_credentials ⇒ Object

Methods included from Cluster::Logging

#logger

Constructor Details

#initialize(arguments = nil) ⇒ Infrastructure

Returns a new instance of Infrastructure.

# File 'lib/cluster/infrastructure.rb', line 11

def initialize(arguments = nil)
  @arguments = arguments
end

Class Method Details

.cluster_name ⇒ Object

# File 'lib/cluster/infrastructure.rb', line 110

def cluster_name
  @@cluster_name
end

.connect(arguments = nil) ⇒ Object

# File 'lib/cluster/infrastructure.rb', line 114

def connect(arguments = nil)
  name = nil
  # removes the infrastructure argument, if given, and processes it
  new_args = arguments.map {|arg|
    case arg
    when /^-i([^=]+)$/, /^--infr[^=]+=(.+)$/
      name = $1
      nil
    when /^-n([^=]+)$/, /^--name[^=]+=(.+)$/
      @@cluster_name = $1
    else
      arg
    end
  }.compact

  name ||= 'amazon'

  begin
    require File.join('cluster', 'infrastructures', name)
  rescue LoadError => err
    STDERR.puts "Subsystem of #{name} either is not included or not available.\n\t#{err.message}\n#{err.backtrace.join("\n\t")}"
    exit 1
  end

  begin
    sub = Object.const_get name.capitalize
  rescue NameError
    STDERR.puts "Subsystem of #{name.capitalize} cannot be initialized."
    exit 1
  end

  sub.new new_args
end

.current ⇒ Object

# File 'lib/cluster/infrastructure.rb', line 106

def current
  @@subsystem
end

.dns ⇒ Object

# File 'lib/cluster/infrastructure.rb', line 148

def dns
  return @@dns unless @@dns.nil?
  ns = ''
  File.open('/etc/resolv.conf').each do |line| ns = $1 if line =~ /nameserver\s+([\d\.]+)/; end

  @@dns = Resolv::DNS.new(:nameserver => ns)
end

.in_cluster? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/cluster/infrastructure.rb', line 156

def in_cluster?
  @@in_cluster
end

.sizes ⇒ Object Also known as: machine_sizes

# File 'lib/cluster/infrastructure.rb', line 101

def sizes
  @@machine_sizes
end

Instance Method Details

#configure ⇒ Object

# File 'lib/cluster/infrastructure.rb', line 15

def configure
  @options = OpenStruct.new
  @options.current_instance_id = nil
  @options.original_services = []

  if credentials?
    cluster = credentials['cluster']
    if cluster
      @options.current_instance_id = cluster['id']
      @options.original_services = cluster['services'].split(',')
    end
  end

  @@subsystem ||= self
end

#credentials ⇒ Object

# File 'lib/cluster/infrastructure.rb', line 50

def credentials
  @credentials
end

#credentials? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/cluster/infrastructure.rb', line 42

def credentials?
  return true if @credentials

  if Cluster::Configuration.credentials?
    @credentials = Cluster::Configuration.credentials
  end
end

#current_instance ⇒ Object

# File 'lib/cluster/infrastructure.rb', line 35

def current_instance
  return nil unless @options.current_instance_id

  instances.detect {|ins| ins.id.eql?(@options.current_instance_id) }
end

#in_cluster? ⇒ Boolean

Returns:

• (Boolean)

Raises:

• (NotImplementedError)

# File 'lib/cluster/infrastructure.rb', line 54

def in_cluster?
  raise NotImplementedError
end

#instances ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/cluster/infrastructure.rb', line 31

def instances
  raise NotImplementedError
end

#machines(*filter_groups) ⇒ Object

# File 'lib/cluster/infrastructure.rb', line 66

def machines(*filter_groups)
  if filter_groups.empty?
    self.instances
  else
    self.instances.select {|i| i.groups.any? {|g| filter_groups.include? g }}
  end
end

#names(*roles) ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/cluster/infrastructure.rb', line 58

def names(*roles)
  raise NotImplementedError
end

#release_class ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/cluster/infrastructure.rb', line 62

def release_class
  raise NotImplementedError
end

#services(filter_services) ⇒ Object

# File 'lib/cluster/infrastructure.rb', line 74

def services(filter_services)
  filter_services = Array(filter_services) unless filter_services.is_a? Array

  if filter_services.empty?
    puts "No services provided to return a list for #{filter_services.join(' ')}"
    exit 1
  else
    self.instances.select {|i|
      i.services.any? {|s| filter_services.include?(s) and !i.disabled_services.include?(s)}
    }
  end
end

#to_credentials ⇒ Object

# File 'lib/cluster/infrastructure.rb', line 87

def to_credentials
  opts = @options.marshal_dump.keys.inject({}) {|m, k| 
    if k.eql? :role
      m
    else
      m.merge k.to_s => @options.send(k)
    end
  }
  {'cluster_name' => self.class.cluster_name,
    self.class.to_s.downcase => opts }
end