Class: Fragile::Pipeline
- Inherits:
-
Object
- Object
- Fragile::Pipeline
- Defined in:
- lib/fragile/pipeline.rb
Instance Attribute Summary collapse
-
#name ⇒ Object
readonly
Returns the value of attribute name.
Instance Method Summary collapse
-
#initialize(name) ⇒ Pipeline
constructor
A new instance of Pipeline.
- #retry_count(count) ⇒ Object
- #run ⇒ Object
- #use(plugin, config = {}) ⇒ Object
Constructor Details
#initialize(name) ⇒ Pipeline
Returns a new instance of Pipeline.
16 17 18 19 20 |
# File 'lib/fragile/pipeline.rb', line 16 def initialize(name) @name = name @retry_count = 3 @plugins = [] end |
Instance Attribute Details
#name ⇒ Object (readonly)
Returns the value of attribute name.
14 15 16 |
# File 'lib/fragile/pipeline.rb', line 14 def name @name end |
Instance Method Details
#retry_count(count) ⇒ Object
22 23 24 |
# File 'lib/fragile/pipeline.rb', line 22 def retry_count(count) @retry_count = count end |
#run ⇒ Object
30 31 32 33 34 35 36 37 |
# File 'lib/fragile/pipeline.rb', line 30 def run data = nil @plugins.each do |plugin| retry_handler do data = plugin.call(data) end end end |
#use(plugin, config = {}) ⇒ Object
26 27 28 |
# File 'lib/fragile/pipeline.rb', line 26 def use(plugin, config={}) @plugins << Fragile.application.create_plugin(plugin, config) end |