Module: Pipes

Defined in:
lib/pipes.rb,
lib/pipes/store.rb,
lib/pipes/utils.rb,
lib/pipes/runner.rb,
lib/pipes/server.rb,
lib/pipes/version.rb,
lib/pipes/resque_hooks.rb,
lib/pipes/stage_parser.rb

Defined Under Namespace

Modules: ResqueHooks, Server, Utils Classes: Runner, StageParser, Store

Constant Summary collapse

VERSION = 
'0.3.0'

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.namespace ⇒ Object

Returns the value of attribute namespace.



8
9
10
 
# File 'lib/pipes.rb', line 8

def namespace
  @namespace
end

.redis ⇒ Object

Returns the value of attribute redis.



7
8
9
 
# File 'lib/pipes.rb', line 7

def redis
  @redis
end

.resolve ⇒ Object

Returns the value of attribute resolve.



8
9
10
 
# File 'lib/pipes.rb', line 8

def resolve
  @resolve
end

Class Method Details

.configure(*args) {|_self| ... } ⇒ Object

Open up the configuration for multiple values.

eg: Pipes.configuration { |config| ... }

Yields:

  • (_self)

Yield Parameters:

  • _self (Pipes) —

    the object that the method was called on



14
15
16
 
# File 'lib/pipes.rb', line 14

def self.configure(*args, &block)
  yield self
end

.enqueue(*args, &block) ⇒ Object

Shortcut to queue up a Pipes job. Designed to look similar to Resque.



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

def self.enqueue(*args, &block)
  Runner.run(*args, &block)
end

.stages(*args, &block) ⇒ Object

Stages, defined in the configuration.



33
34
35
36
37
 
# File 'lib/pipes.rb', line 33

def self.stages(*args, &block)
  Abyss.configure(*args) do
    stages &block
  end
end