Module: Tengine::Job

Defined in:
lib/tengine/job.rb

Class Method Summary collapse

Class Method Details

.dsl_binder ⇒ Object 



40
41
42
 
# File 'lib/tengine/job.rb', line 40

def dsl_binder
  ::Tengine::Job::Dsl::Binder
end

.dsl_loader ⇒ Object 



36
37
38
 
# File 'lib/tengine/job.rb', line 36

def dsl_loader
  ::Tengine::Job::Dsl::Loader
end

.notify(sender, msg) ⇒ Object

tengine_coreからそのプラグインへ通知を受けるための



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
 
# File 'lib/tengine/job.rb', line 14

def notify(sender, msg)
  Tengine::Core.stdout_logger.debug("*" * 100)
  Dir[File.expand_path("job/runtime/drivers/*.rb", File.dirname(__FILE__))].each do |f|
    Tengine::Core.stdout_logger.debug("#{self.name}.notify  #{f}")
    end
  # if (msg == :before___evaluate__) # だと、最初にtengine/jobがrequireされる前に実行されるのでフックできません

  Tengine::Core::Driveable.module_eval{ include Tengine::Job::Dsl::Binder }

  if (msg == :after___evaluate__)
    Dir[File.expand_path("job/runtime/drivers/*.rb", File.dirname(__FILE__))].each do |f|
      # Tengine::Core.stdout_logger.debug("#{self.name} now evaluating #{f}")
      # sender.instance_eval(File.read(f), f)
      load(f)
    end
  end
  if (msg == :after_load_dsl) && sender.respond_to?(:config)
    # RootJobnetTemplateのdsl_filepathからCategoryを生成します
    Tengine::Job::Structure::Category.update_for(sender.config.dsl_dir_path)
  end
end

.test_harness(idx, msg) ⇒ Object

自動テストで呼び出しをフックするためのメソッド



45
46
 
# File 'lib/tengine/job.rb', line 45

def test_harness(idx, msg)
end

.test_harness_clear ⇒ Object

test_harnessメソッドに渡されるidxを初期化します



49
50
51
52
 
# File 'lib/tengine/job.rb', line 49

def test_harness_clear
  @test_harness_index = 0
  Tengine.logger.debug("#{self.name}.test_harness_clear")
end

.test_harness_hook(msg) ⇒ Object

test_harness呼び出すメソッド。 ライブラリを提供する側が使用します。



56
57
58
59
60
61
 
# File 'lib/tengine/job.rb', line 56

def test_harness_hook(msg)
  @test_harness_index ||= 0
  @test_harness_index += 1
  Tengine.logger.debug("#{self.name}.test_harness(#{@test_harness_index}, #{msg.inspect})")
  test_harness(@test_harness_index, msg)
end