Module: RedStorm

Defined in:
lib/red_storm/version.rb,
lib/red_storm/dsl/bolt.rb,
lib/red_storm/loggable.rb,
lib/red_storm/dsl/spout.rb,
lib/red_storm/dsl/tuple.rb,
lib/red_storm/application.rb,
lib/red_storm/environment.rb,
lib/red_storm/configurator.rb,
lib/red_storm/dsl/topology.rb,
lib/red_storm/configuration.rb,
lib/red_storm/dsl/drpc_topology.rb

Defined Under Namespace

Modules: Configuration, DSL, Loggable Classes: Application, Configurator

Constant Summary collapse

VERSION = 
'0.6.6'
SimpleBolt =

for backward compatibility

DSL::Bolt
SimpleSpout =

for backward compatibility

DSL::Spout
CWD = 
Dir.pwd
BASE_PATH = 
CWD
REDSTORM_HOME = 
File.expand_path(launch_path + '/../..')
GEM_PATH = 
"#{BASE_PATH}/target/gems/"
TARGET_DIR = 
"#{CWD}/target"
TARGET_LIB_DIR = 
"#{TARGET_DIR}/lib"
TARGET_SRC_DIR = 
"#{TARGET_DIR}/src"
TARGET_GEM_DIR = 
"#{TARGET_DIR}/gems/gems"
TARGET_SPECS_DIR = 
"#{TARGET_DIR}/gems/specifications"
TARGET_CLASSES_DIR = 
"#{TARGET_DIR}/classes"
TARGET_DEPENDENCY_DIR = 
"#{TARGET_DIR}/dependency"
TARGET_DEPENDENCY_UNPACKED_DIR = 
"#{TARGET_DIR}/dependency-unpacked"
TARGET_CLUSTER_JAR = 
"#{TARGET_DIR}/cluster-topology.jar"
REDSTORM_JAVA_SRC_DIR = 
"#{REDSTORM_HOME}/src/main"
REDSTORM_LIB_DIR = 
"#{REDSTORM_HOME}/lib"
SRC_EXAMPLES = 
"#{REDSTORM_HOME}/examples"
DST_EXAMPLES = 
"#{CWD}/examples"
SRC_IVY_DIR = 
"#{REDSTORM_HOME}/ivy"
DST_IVY_DIR = 
"#{CWD}/ivy"
DEFAULT_IVY_SETTINGS = 
"#{SRC_IVY_DIR}/settings.xml"
CUSTOM_IVY_SETTINGS = 
"#{DST_IVY_DIR}/settings.xml"
DEFAULT_IVY_STORM_DEPENDENCIES = 
"#{SRC_IVY_DIR}/storm_dependencies.xml"
CUSTOM_IVY_STORM_DEPENDENCIES = 
"#{DST_IVY_DIR}/storm_dependencies.xml"
DEFAULT_IVY_TOPOLOGY_DEPENDENCIES = 
"#{SRC_IVY_DIR}/topology_dependencies.xml"
CUSTOM_IVY_TOPOLOGY_DEPENDENCIES = 
"#{DST_IVY_DIR}/topology_dependencies.xml"
DEFAULT_STORM_CONF_FILE = 
File.expand_path("~/.storm/storm.yaml")
SimpleTopology =

for backward compatibility

DSL::Topology
SimpleDRPCTopology =

for backward compatibility

DSL::DRPCTopology

Class Method Summary collapse

Class Method Details

.current_ruby_mode ⇒ Object 



52
53
54
55
56
 
# File 'lib/red_storm/environment.rb', line 52

def current_ruby_mode
  version = RUBY_VERSION[/(\d+\.\d+)(\.\d+)*/, 1]
  raise("unknown Ruby version #{$1}") unless ["1.8", "1.9"].include?(version)
  version
end

.java_runtime_version ⇒ Object 



63
64
65
 
# File 'lib/red_storm/environment.rb', line 63

def java_runtime_version
  System.properties["java.runtime.version"].to_s[/^(\d+\.\d+).[^\s]+$/, 1] || raise("unknown java runtime version #{System.properties["java.runtime.version"].to_s}")
end

.jruby_mode_token(ruby_version = nil) ⇒ Object 



58
59
60
61
 
# File 'lib/red_storm/environment.rb', line 58

def jruby_mode_token(ruby_version = nil)
  version_map = {"1.8" => "RUBY1_8", "--1.8" => "RUBY1_8", "1.9" => "RUBY1_9", "--1.9" => "RUBY1_9"}
  version_map[ruby_version.to_s] || version_map[RedStorm.current_ruby_mode]
end