Method: OmfCommon.init

Defined in:

lib/omf_common.rb

.init(op_mode, opts = {}, &block) ⇒ Object

Initialise the OMF runtime.

The options here can be customised via EC or RC’s configuration files.

Given the following example EC configuration file (YAML format):

environment: development
communication:
  url: amqp://localhost

OMF runtime will be configured as:

OmfCommon.init(:development, { communication: { url: "amqp://localhost" }})

Examples:

Use AMQP for communication in :development mode

OmfCommon.init(:development, { communication: { url: "amqp://localhost" }})

Change Logging configuration

options = {
  communication: { url: "amqp://localhost" },
  logging: {
    level: { default: 'debug' },
      appenders: {
        stdout: {
          level: :info,
          date_pattern: '%H:%M:%S',
          pattern: '%d %5l %c{2}: %m\n'
        },
        rolling_file: {
          level: :debug,
          log_dir: '/var/tmp',
          size: 1024*1024*50, # max 50mb of each log file
          keep: 5, # keep a 5 logs in total
          date_pattern: '%F %T %z',
          pattern: '[%d] %-5l %c: %m\n'
        },
      }
   }
}

OmfCommon.init(:development, options)

Parameters:

• op_mode (Symbol)
• opts (Hash) (defaults to: {})

See Also:

• _init_logging

# File 'lib/omf_common.rb', line 188

def self.init(op_mode, opts = {}, &block)
  opts = _rec_sym_keys(opts)

  if op_mode && defs = DEFAULTS[op_mode.to_sym]
    opts = _rec_merge(defs, opts)
  end
  if dopts = opts.delete(:daemonize)
    dopts[:app_name] ||= "#{File.basename($0, File.extname($0))}_daemon"
    require 'daemons'
    Daemons.run_proc(dopts[:app_name], dopts) do
      init(nil, opts, &block)
    end
    return
  end

  if lopts = opts[:logging]
    _init_logging(lopts) unless lopts.empty?
  end

  unless copts = opts[:communication]
    raise "Missing :communication description"
  end

  if aopts = opts[:auth]
    require 'omf_common/auth/credential_store'
    OmfCommon::Auth::CredentialStore.init(aopts)
  end

  # Initialise event loop
  eopts = opts[:eventloop]
  Eventloop.init(eopts)
  # start eventloop immediately if we received a run block
  eventloop.run do
    Comm.init(copts)
    block.call(eventloop) if block
  end
end