Sha256: c62ed170c8a499422490ec192d80d56ad7792fd339bbfa036a83c280f7797542

Contents?: true

Size: 1010 Bytes

Versions: 6

Compression:

Stored size: 1010 Bytes

Contents

require 'rundock'

module Rundock
  class Node
    attr_reader :name
    attr_reader :operations
    attr_reader :backend
    attr_accessor :hooks

    def initialize(name, backend)
      @name = name
      @backend = backend
      @operations = []
      @hooks = []
    end

    def add_operation(ope)
      @operations = [] unless @operations
      @operations << ope
    end

    def run
      Logger.formatter.onrec = true
      Logger.debug("run node: #{@name}")
      Logger.warn("no operation running: #{@name}") if @operations.blank?

      node_attributes = []

      @operations.each do |ope|
        Logger.debug("run operation: #{ope.class}")
        node_attributes << ope.attributes
        ope.run(@backend, ope.attributes)
      end

      log_buffer = Logger.formatter.flush unless Logger.formatter.buffer.empty?

      @hooks.each do |h|
        Logger.debug("run hook: #{h.name}")
        h.hook(node_attributes, log_buffer)
      end

      Logger.formatter.onrec = false
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
rundock-0.4.15 lib/rundock/node.rb
rundock-0.4.14 lib/rundock/node.rb
rundock-0.4.13 lib/rundock/node.rb
rundock-0.4.12 lib/rundock/node.rb
rundock-0.4.11 lib/rundock/node.rb
rundock-0.4.10 lib/rundock/node.rb