Class: Larva::Daemon

Inherits:
Object
  • Object
show all
Defined in:
lib/larva/daemon.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(processors, options = {}) ⇒ Daemon

Allowed Options:

:env - Defaults to development
:meducation_sdk_secret_key - Defauls to looking in config file



13
14
15
16
17
18
19
 
# File 'lib/larva/daemon.rb', line 13

def initialize(processors, options = {})
  @processors = processors
  @options = options
  @config_dir = options.fetch(:config_dir) {raise LarvaError.new("Please provide :config_dir via options")}
  @logfile = options.fetch(:logfile) {raise LarvaError.new("Please provide :logfile via options")}
  @env = options[:env] || "development"
end

Class Method Details

.start(*args) ⇒ Object 



3
4
5
6
7
8
 
# File 'lib/larva/daemon.rb', line 3

def self.start(*args)
  daemon = new(*args)
  daemon.configure
  daemon.start
  daemon
end

Instance Method Details

#configure ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/larva/daemon.rb', line 27

def configure
  Filum.setup(@logfile)
  Filum.logger.info "Configuring Daemon"

  if meducation_sdk_config = parse_config_file('meducation-sdk.yml')
    MeducationSDK.config do |config|
      config.access_id  = meducation_sdk_config[:access_id]
      config.secret_key = @options[:meducation_sdk_secret_key] || meducation_sdk_config[:secret_key]
      config.logger     = Filum.logger
    end
  end

  if propono_config = parse_config_file('propono.yml')
    Propono.config do |config|
      config.use_iam_profile  = propono_config[:use_iam_profile]
      config.access_key       = propono_config[:access_key]
      config.secret_key       = propono_config[:secret_key]
      config.queue_region     = propono_config[:region]
      config.application_name = propono_config[:application_name]
      config.queue_suffix     = propono_config[:queue_suffix]
      config.udp_host         = "pergo.meducation.net"
      config.udp_port         = "9732"
      config.logger           = Filum.logger
    end
  end
end

#parse_config_file(filename) ⇒ Object 



54
55
56
57
58
59
60
 
# File 'lib/larva/daemon.rb', line 54

def parse_config_file(filename)
  contents = File.read("#{@config_dir}/#{filename}")
  hash = YAML::load(contents)
  hash.stringify_keys[@env].symbolize_keys
rescue
  nil
end

#start ⇒ Object 



21
22
23
24
25
 
# File 'lib/larva/daemon.rb', line 21

def start
  Filum.logger.info "Starting Workerpool"
  Larva::WorkerPool.start(@processors)
  Filum.logger.info "Workerpool Finished"
end