Class: Oxidized::Node

Inherits:
Object
  • Object
show all
Defined in:
lib/oxidized/node.rb,
lib/oxidized/node/stats.rb

Defined Under Namespace

Classes: Stats

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(opt) ⇒ Node

Returns a new instance of Node.



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

def initialize opt
  Oxidized.logger.debug 'resolving DNS for %s...' % opt[:name]
  # remove the prefix if an IP Address is provided with one as IPAddr converts it to a network address.
  ip_addr, _ = opt[:ip].to_s.split("/")
  Oxidized.logger.debug 'IPADDR %s' % ip_addr.to_s
  @name           = opt[:name]
  @ip             = @name unless Oxidized.config.resolve_dns?
  @ip           ||= IPAddr.new(ip_addr).to_s rescue nil
  @ip           ||= Resolv.new.getaddress @name
  @group          = opt[:group]
  @input          = resolve_input opt
  @output         = resolve_output opt
  @model          = resolve_model opt
  @auth           = resolve_auth opt
  @prompt         = resolve_prompt opt
  @vars           = opt[:vars]
  @stats          = Stats.new
  @retry          = 0
  @repo           = resolve_repo opt

  # model instance needs to access node instance
  @model.node = self
end

Instance Attribute Details

#auth ⇒ Object (readonly)

Returns the value of attribute auth.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def auth
  @auth
end

#email ⇒ Object

Returns the value of attribute email.



9
10
11
 
# File 'lib/oxidized/node.rb', line 9

def email
  @email
end

#from ⇒ Object

Returns the value of attribute from.



9
10
11
 
# File 'lib/oxidized/node.rb', line 9

def from
  @from
end

#group ⇒ Object (readonly)

Returns the value of attribute group.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def group
  @group
end

#input ⇒ Object (readonly)

Returns the value of attribute input.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def input
  @input
end

#ip ⇒ Object (readonly)

Returns the value of attribute ip.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def ip
  @ip
end

#last ⇒ Object

Returns the value of attribute last.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def last
  @last
end

#model ⇒ Object (readonly)

Returns the value of attribute model.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def model
  @model
end

#msg ⇒ Object

Returns the value of attribute msg.



9
10
11
 
# File 'lib/oxidized/node.rb', line 9

def msg
  @msg
end

#name ⇒ Object (readonly)

Returns the value of attribute name.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def name
  @name
end

#output ⇒ Object (readonly)

Returns the value of attribute output.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def output
  @output
end

#prompt ⇒ Object (readonly)

Returns the value of attribute prompt.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def prompt
  @prompt
end

#repo ⇒ Object (readonly)

Returns the value of attribute repo.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def repo
  @repo
end

#retry ⇒ Object

Returns the value of attribute retry.



9
10
11
 
# File 'lib/oxidized/node.rb', line 9

def retry
  @retry
end

#running ⇒ Object Also known as: running?

Returns the value of attribute running.



9
10
11
 
# File 'lib/oxidized/node.rb', line 9

def running
  @running
end

#stats ⇒ Object

Returns the value of attribute stats.



9
10
11
 
# File 'lib/oxidized/node.rb', line 9

def stats
  @stats
end

#user ⇒ Object

Returns the value of attribute user.



9
10
11
 
# File 'lib/oxidized/node.rb', line 9

def user
  @user
end

#vars ⇒ Object (readonly)

Returns the value of attribute vars.



8
9
10
 
# File 'lib/oxidized/node.rb', line 8

def vars
  @vars
end

Instance Method Details

#reset ⇒ Object 



124
125
126
127
 
# File 'lib/oxidized/node.rb', line 124

def reset
  @user = @email = @msg = @from = nil
  @retry = 0
end

#run ⇒ Object 



36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/oxidized/node.rb', line 36

def run
  status, config = :fail, nil
  @input.each do |input|
    # don't try input if model is missing config block, we may need strong config to class_name map
    cfg_name = input.to_s.split('::').last.downcase
    next unless @model.cfg[cfg_name] and not @model.cfg[cfg_name].empty?
    @model.input = input = input.new
    if config = run_input(input)
      Oxidized.logger.debug "lib/oxidized/node.rb: #{input.class.name} ran for #{name} successfully"
      status = :success
      break
    else
      Oxidized.logger.debug "lib/oxidized/node.rb: #{input.class.name} failed for #{name}"
      status = :no_connection
    end
  end
  @model.input = nil
  [status, config]
end

#run_input(input) ⇒ Object 



56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
 
# File 'lib/oxidized/node.rb', line 56

def run_input input
  rescue_fail = {}
  [input.class::RescueFail, input.class.superclass::RescueFail].each do |hash|
    hash.each do |level, errors|
      errors.each do |err|
        rescue_fail[err] = level
      end
    end
  end
  begin
    input.connect(self) and input.get
  rescue *rescue_fail.keys => err
    resc = ''
    if not level = rescue_fail[err.class]
      resc  = err.class.ancestors.find { |e| rescue_fail.keys.include? e }
      level = rescue_fail[resc]
      resc  = " (rescued #{resc})"
    end
    Oxidized.logger.send(level, '%s raised %s%s with msg "%s"' % [self.ip, err.class, resc, err.message])
    return false
  rescue => err
    file = Oxidized::Config::Crash + '.' + self.ip.to_s
    open file, 'w' do |fh|
      fh.puts Time.now.utc
      fh.puts err.message + ' [' + err.class.to_s + ']'
      fh.puts '-' * 50
      fh.puts err.backtrace
    end
    Oxidized.logger.error '%s raised %s with msg "%s", %s saved' % [self.ip, err.class, err.message, file]
    return false
  end
end

#serialize ⇒ Object 



89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
 
# File 'lib/oxidized/node.rb', line 89

def serialize
  h = {
    :name      => @name,
    :full_name => @name,
    :ip        => @ip,
    :group     => @group,
    :model     => @model.class.to_s,
    :last      => nil,
    :vars      => @vars,
  }
  h[:full_name] = [@group, @name].join('/') if @group
  if @last
    h[:last] = {
      :start  => @last.start,
      :end    => @last.end,
      :status => @last.status,
      :time   => @last.time,
    }
  end
  h
end