Class: MCollective::Registration::Base
- Inherits:
-
Object
- Object
- MCollective::Registration::Base
- Defined in:
- lib/mcollective/registration/base.rb
Overview
This is a base class that other registration plugins can use to handle regular announcements to the mcollective
The configuration file determines how often registration messages gets sent using the registerinterval option, the plugin runs in the background in a thread.
Class Method Summary collapse
-
.inherited(klass) ⇒ Object
Register plugins that inherits base.
Instance Method Summary collapse
- #config ⇒ Object
- #interval ⇒ Object
- #msg_filter ⇒ Object
- #publish(message) ⇒ Object
-
#run(connection) ⇒ Object
Creates a background thread that periodically send a registration notice.
- #target_collective ⇒ Object
Class Method Details
.inherited(klass) ⇒ Object
Register plugins that inherits base
11 12 13 |
# File 'lib/mcollective/registration/base.rb', line 11 def self.inherited(klass) PluginManager << {:type => "registration_plugin", :class => klass.to_s} end |
Instance Method Details
#config ⇒ Object
36 37 38 |
# File 'lib/mcollective/registration/base.rb', line 36 def config Config.instance end |
#interval ⇒ Object
57 58 59 |
# File 'lib/mcollective/registration/base.rb', line 57 def interval config.registerinterval end |
#msg_filter ⇒ Object
40 41 42 |
# File 'lib/mcollective/registration/base.rb', line 40 def msg_filter {"agent" => "registration"} end |
#publish(message) ⇒ Object
61 62 63 64 65 66 67 68 69 70 71 72 |
# File 'lib/mcollective/registration/base.rb', line 61 def publish() unless Log.debug("Skipping registration due to nil body") else req = Message.new(, nil, {:type => :request, :agent => "registration", :collective => target_collective, :filter => msg_filter}) req.encode! Log.debug("Sending registration #{req.requestid} to collective #{req.collective}") req.publish end end |
#run(connection) ⇒ Object
Creates a background thread that periodically send a registration notice.
The actual registration notices comes from the ‘body’ method of the registration plugins.
19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
# File 'lib/mcollective/registration/base.rb', line 19 def run(connection) return false if interval == 0 Thread.new do loop do begin publish(body) sleep interval rescue Exception => e Log.error("Sending registration message failed: #{e}") sleep interval end end end end |
#target_collective ⇒ Object
44 45 46 47 48 49 50 51 52 53 54 55 |
# File 'lib/mcollective/registration/base.rb', line 44 def target_collective main_collective = config.main_collective collective = config.registration_collective || main_collective unless config.collectives.include?(collective) Log.warn("Sending registration to #{main_collective}: #{collective} is not a valid collective") collective = main_collective end return collective end |