class Flor::TransientExecutor::TransientUnit
Attributes
archive[RW]
conf[RW]
journal[R]
loader[R]
logger[R]
opts[RW]
Public Class Methods
new(conf)
click to toggle source
# File lib/flor/core/texecutor.rb, line 14 def initialize(conf) @conf = conf @opts = {} @logger = TransientLogger.new(self) @journal = [] @archive = nil end
Public Instance Methods
archive_node(exid, node)
click to toggle source
# File lib/flor/core/texecutor.rb, line 33 def archive_node(exid, node) (@archive[exid] ||= {})[node['nid']] = Flor.dup(node) if @archive end
has_tasker?(exid, tname)
click to toggle source
# File lib/flor/core/texecutor.rb, line 38 def has_tasker?(exid, tname) false end
notify(executor, msg)
click to toggle source
# File lib/flor/core/texecutor.rb, line 23 def notify(executor, msg) return [] if msg['consumed'] @logger.notify(executor, msg) @journal << msg [] end