Module: Rukawa

Defined in:

lib/rukawa.rb,
lib/rukawa/cli.rb,
lib/rukawa/dag.rb,
lib/rukawa/job.rb,
lib/rukawa/errors.rb,
lib/rukawa/runner.rb,
lib/rukawa/job_net.rb,
lib/rukawa/version.rb,
lib/rukawa/abstract_job.rb,
lib/rukawa/configuration.rb

Defined Under Namespace

Modules: State Classes: AbstractJob, Cli, Configuration, Dag, DependentJobFailure, Job, JobNet, Runner

Constant Summary

VERSION =

"0.1.0"

Class Method Summary

• .config ⇒ Object
• .configure {|config| ... } ⇒ Object
• .executor ⇒ Object
• .logger ⇒ Object
• .store ⇒ Object

Class Method Details

.config ⇒ Object

# File 'lib/rukawa.rb', line 17

def config
  Configuration.instance
end

.configure {|config| ... } ⇒ Object

Yields:

• (config)

# File 'lib/rukawa.rb', line 13

def configure
  yield config
end

.executor ⇒ Object

# File 'lib/rukawa.rb', line 21

def executor
  @executor ||= Concurrent::FixedThreadPool.new(config.concurrency)
end

.logger ⇒ Object

# File 'lib/rukawa.rb', line 5

def logger
  @logger ||= Logger.new(config.log_file)
end

.store ⇒ Object

# File 'lib/rukawa.rb', line 9

def store
  @store ||= Concurrent::Hash.new
end