4 attr_reader :name, :result, :ddl, :timeout
6 # Register plugins that inherits base
7 def self.inherited(klass)
8 type = klass.to_s.split("::").last.downcase
10 PluginManager << {:type => type, :class => klass.to_s, :single_instance => false}
14 @name = self.class.to_s.split("::").last.downcase
15 @ddl = DDL.new(@name, :data)
16 @result = Result.new(@ddl.dataquery_interface[:output])
17 @timeout = @ddl.meta[:timeout] || 1
25 Log.debug("Doing data query %s for '%s'" % [ @name, what ])
27 Timeout::timeout(@timeout) do
33 # Timeout::Error is a inherited from Interrupt which seems a really
34 # strange choice, making it an equivelant of ^C and such. Catch it
35 # and raise something less critical that will not the runner to just
37 msg = "Data plugin %s timed out on query '%s'" % [@name, what]
39 raise MsgTTLExpired, msg
42 def self.query(&block)
43 self.module_eval { define_method("query_data", &block) }
46 def ddl_validate(what)
47 Data.ddl_validate(@ddl, what)
51 # file.exist?("/usr/bin/puppet")
53 def self.activate_when(&block)
54 (class << self; self; end).instance_eval do
55 define_method("activate?", &block)
59 # Always be active unless a specific block is given with activate_when