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