Class: Yapra::PipelineBase
- Inherits:
-
Object
- Object
- Yapra::PipelineBase
- Defined in:
- lib/yapra/pipeline_base.rb
Direct Known Subclasses
Instance Attribute Summary collapse
-
#context ⇒ Object
readonly
Returns the value of attribute context.
- #logger ⇒ Object
-
#yapra ⇒ Object
readonly
Returns the value of attribute yapra.
Instance Method Summary collapse
-
#initialize(pipeline_name, yapra = Yapra::Runtime.new) ⇒ PipelineBase
constructor
A new instance of PipelineBase.
- #load(command) ⇒ Object
- #name ⇒ Object
Constructor Details
#initialize(pipeline_name, yapra = Yapra::Runtime.new) ⇒ PipelineBase
Returns a new instance of PipelineBase.
9 10 11 12 13 14 15 |
# File 'lib/yapra/pipeline_base.rb', line 9 def initialize pipeline_name, yapra=Yapra::Runtime.new @logger = nil @yapra = yapra @context = { 'pipeline_name' => pipeline_name } @module_name_prefix = construct_module_name_prefix yapra.env end |
Instance Attribute Details
#context ⇒ Object (readonly)
Returns the value of attribute context.
6 7 8 |
# File 'lib/yapra/pipeline_base.rb', line 6 def context @context end |
#logger ⇒ Object
21 22 23 |
# File 'lib/yapra/pipeline_base.rb', line 21 def logger return @logger || Yapra::Runtime.logger end |
#yapra ⇒ Object (readonly)
Returns the value of attribute yapra.
6 7 8 |
# File 'lib/yapra/pipeline_base.rb', line 6 def yapra @yapra end |
Instance Method Details
#load(command) ⇒ Object
25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 |
# File 'lib/yapra/pipeline_base.rb', line 25 def load command plugin_name = command['module'] load_error_stack = [] plugin_class = nil @module_name_prefix.each do |prefix| yapra_module_name = "#{prefix}#{plugin_name}" begin plugin_class = Yapra.load_class_constant(yapra_module_name) break if plugin_class rescue LoadError, NameError => ex load_error_stack << ex end end raise_load_error(load_error_stack, command) unless plugin_class plugin = initialize_plugin( plugin_class ) plugin end |
#name ⇒ Object
17 18 19 |
# File 'lib/yapra/pipeline_base.rb', line 17 def name self.context[ 'pipeline_name' ] end |