Class: RFlow

Inherits:
Object
  • Object
show all
Includes:
Log4r
Defined in:
lib/rflow.rb,
lib/rflow/shard.rb,
lib/rflow/broker.rb,
lib/rflow/logger.rb,
lib/rflow/master.rb,
lib/rflow/message.rb,
lib/rflow/version.rb,
lib/rflow/pid_file.rb,
lib/rflow/component.rb,
lib/rflow/connection.rb,
lib/rflow/child_process.rb,
lib/rflow/configuration.rb,
lib/rflow/component/port.rb,
lib/rflow/components/log.rb,
lib/rflow/components/raw.rb,
lib/rflow/daemon_process.rb,
lib/rflow/components/clock.rb,
lib/rflow/components/integer.rb,
lib/rflow/configuration/port.rb,
lib/rflow/configuration/shard.rb,
lib/rflow/components/replicate.rb,
lib/rflow/configuration/setting.rb,
lib/rflow/configuration/ruby_dsl.rb,
lib/rflow/configuration/component.rb,
lib/rflow/configuration/connection.rb,
lib/rflow/configuration/uuid_keyed.rb,
lib/rflow/connections/zmq_connection.rb,
lib/rflow/components/ruby_proc_filter.rb

Defined Under Namespace

Modules: Components, Connections Classes: Avro, Broker, ChildProcess, Component, Configuration, Connection, DaemonProcess, ForwardToInputPort, ForwardToOutputPort, Logger, Master, Message, MessageCollectingConnection, PIDFile, Shard

Constant Summary collapse

VERSION = 
'1.2.0'

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.configuration ⇒ Object (readonly)

Returns the value of attribute configuration.



19
20
21
 
# File 'lib/rflow.rb', line 19

def configuration
  @configuration
end

.logger ⇒ Object

Returns the value of attribute logger.



18
19
20
 
# File 'lib/rflow.rb', line 18

def logger
  @logger
end

.master ⇒ Object (readonly)

Returns the value of attribute master.



19
20
21
 
# File 'lib/rflow.rb', line 19

def master
  @master
end

Class Method Details

.run!(config_database_path = nil, daemonize = false) ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/rflow.rb', line 24

def self.run!(config_database_path = nil, daemonize = false)
  @config_database_path = config_database_path
  @daemonize = daemonize

  establish_configuration
  chdir_application_directory
  setup_logger
  start_master_node
rescue SystemExit => e
  # Do nothing, just prevent a normal exit from causing an unsightly
  # error in the logs
end