1
"""Deployment code for the monitor."""
5
from twisted.python.reflect import namedClass
7
from landscape.deployment import (LandscapeService, Configuration,
9
from landscape.monitor.monitor import (MonitorPluginRegistry,
11
from landscape.broker.remote import (RemoteBroker,
12
DBusSignalToReactorTransmitter)
15
ALL_PLUGINS = ["ActiveProcessInfo", "ComputerInfo", "HardwareInventory",
16
"LoadAverage", "MemoryInfo", "MountInfo", "ProcessorInfo",
17
"Temperature", "PackageMonitor", "UserMonitor",
18
"RebootRequired", "AptPreferences"]
21
class MonitorConfiguration(Configuration):
22
"""Specialized configuration for the Landscape Monitor."""
24
def make_parser(self):
26
Specialize L{Configuration.make_parser}, adding many
27
monitor-specific options.
29
parser = super(MonitorConfiguration, self).make_parser()
31
parser.add_option("--monitor-plugins", metavar="PLUGIN_LIST",
32
help="Comma-delimited list of monitor plugins to "
33
"use. ALL means use all plugins.",
35
parser.add_option("--flush-interval", default=5*60, type="int",
37
help="The number of seconds between flushes "
42
def plugin_factories(self):
43
if self.monitor_plugins == "ALL":
45
return [x.strip() for x in self.monitor_plugins.split(",")]
48
class MonitorService(LandscapeService):
50
The core Twisted Service which creates and runs all necessary monitoring
51
components when started.
54
service_name = "monitor"
56
def __init__(self, config):
57
self.persist_filename = os.path.join(config.data_path,
58
"%s.bpickle" % self.service_name)
59
super(MonitorService, self).__init__(config)
60
self.plugins = self.get_plugins()
62
def get_plugins(self):
63
return [namedClass("landscape.monitor.%s.%s"
64
% (plugin_name.lower(), plugin_name))()
65
for plugin_name in self.config.plugin_factories]
67
def startService(self):
68
super(MonitorService, self).startService()
70
# If this raises ServiceUnknownError, we should do something nice.
71
self.remote_broker = RemoteBroker(self.bus)
73
self.registry = MonitorPluginRegistry(self.remote_broker, self.reactor,
74
self.config, self.bus,
76
self.persist_filename)
77
self.dbus_service = MonitorDBusObject(self.bus, self.registry)
78
DBusSignalToReactorTransmitter(self.bus, self.reactor)
80
for plugin in self.plugins:
81
self.registry.add(plugin)
83
self.flush_call_id = self.reactor.call_every(
84
self.config.flush_interval, self.registry.flush)
87
self.remote_broker.register_plugin(self.dbus_service.bus_name,
88
self.dbus_service.object_path)
89
self.registry.broker_started()
92
self.bus.add_signal_receiver(broker_started, "broker_started")
94
def stopService(self):
97
The monitor is flushed to ensure that things like persist
98
databases get saved to disk.
100
self.registry.flush()
101
if self.flush_call_id:
102
self.reactor.cancel_call(self.flush_call_id)
103
self.flush_call_id = None
104
super(MonitorService, self).stopService()
108
run_landscape_service(MonitorConfiguration, MonitorService, args,
109
MonitorDBusObject.bus_name)
added
removed
landscape/monitor/deployment.py
