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

.namespaceObject

Returns the value of attribute namespace


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

def namespace
  @namespace
end

.redisObject

Returns the value of attribute redis


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

def redis
  @redis
end

.resolveObject

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