Module: Resque::JobChain

Defined in:
lib/resque/job_chain.rb,
lib/resque/job_chain/step.rb,
lib/resque/job_chain/chain.rb,
lib/resque/job_chain/builder.rb,
lib/resque/job_chain/context.rb,
lib/resque/job_chain/version.rb,
lib/resque/job_chain/executor.rb,
lib/resque/job_chain/observable.rb,
lib/resque/job_chain/persistence.rb,
lib/resque/job_chain/configuration.rb,
lib/resque/job_chain/strategies/base.rb,
lib/resque/job_chain/strategies/skip.rb,
lib/resque/job_chain/strategies/abort.rb,
lib/resque/job_chain/strategies/retry.rb

Defined Under Namespace

Modules: Context, Observable, Persistence, Strategies Classes: Builder, Chain, Configuration, Executor, Step

Constant Summary collapse

VERSION = 
'0.1.0'.freeze

Class Method Summary collapse

Class Method Details

.active_chains ⇒ Object 



50
51
52
 
# File 'lib/resque/job_chain.rb', line 50

def active_chains
  Persistence.active_chains
end

.build(chain_id, &block) ⇒ Object 



32
33
34
35
36
 
# File 'lib/resque/job_chain.rb', line 32

def build(chain_id, &block)
  builder = Builder.new(chain_id)
  block.call(builder)
  builder.to_chain
end

.configuration ⇒ Object 



20
21
22
 
# File 'lib/resque/job_chain.rb', line 20

def configuration
  @configuration ||= Configuration.new
end

.configure {|configuration| ... } ⇒ Object

Yields:



24
25
26
 
# File 'lib/resque/job_chain.rb', line 24

def configure
  yield(configuration)
end

.context(chain_id) ⇒ Object 



42
43
44
 
# File 'lib/resque/job_chain.rb', line 42

def context(chain_id)
  Persistence.load_context(chain_id)
end

.reset_configuration! ⇒ Object 



28
29
30
 
# File 'lib/resque/job_chain.rb', line 28

def reset_configuration!
  @configuration = Configuration.new
end

.status(chain_id) ⇒ Object 



38
39
40
 
# File 'lib/resque/job_chain.rb', line 38

def status(chain_id)
  Persistence.load_state(chain_id)
end

.update_context(chain_id, **updates) ⇒ Object 



46
47
48
 
# File 'lib/resque/job_chain.rb', line 46

def update_context(chain_id, **updates)
  Persistence.merge_context(chain_id, updates)
end