| Apache/2.4.7 (Ubuntu) Linux sman1baleendah 3.13.0-24-generic #46-Ubuntu SMP Thu Apr 10 19:11:08 UTC 2014 x86_64 uid=33(www-data) gid=33(www-data) groups=33(www-data) safemode : OFF MySQL: ON | Perl: ON | cURL: OFF | WGet: ON > / usr / lib / python2.7 / dist-packages / landscape / monitor / | server ip : 104.21.89.46 your ip : 172.69.214.16 H O M E |
| Filename | /usr/lib/python2.7/dist-packages/landscape/monitor/jujuinfo.py |
| Size | 1.14 kb |
| Permission | rw-r--r-- |
| Owner | root : root |
| Create time | 27-Apr-2025 09:56 |
| Last modified | 20-Feb-2014 23:01 |
| Last accessed | 06-Jul-2025 20:10 |
| Actions | edit | rename | delete | download (gzip) |
| View | text | code | image |
import logging
from landscape.lib.juju import get_juju_info
from landscape.monitor.plugin import MonitorPlugin
class JujuInfo(MonitorPlugin):
"""Plugin for reporting Juju information."""
persist_name = "juju-info"
scope = "juju"
def register(self, registry):
super(JujuInfo, self).register(registry)
self.call_on_accepted("juju-info", self.send_juju_message, True)
def exchange(self, urgent=False):
broker = self.registry.broker
broker.call_if_accepted("juju-info", self.send_juju_message, urgent)
def send_juju_message(self, urgent=False):
message = self._create_juju_info_message()
if message:
message["type"] = "juju-info"
logging.info("Queuing message with updated juju info.")
self.registry.broker.send_message(message, self._session_id,
urgent=urgent)
def _create_juju_info_message(self):
message = get_juju_info(self.registry.config)
if message != self._persist.get("juju-info"):
self._persist.set("juju-info", message)
return message
return None
from landscape.lib.juju import get_juju_info
from landscape.monitor.plugin import MonitorPlugin
class JujuInfo(MonitorPlugin):
"""Plugin for reporting Juju information."""
persist_name = "juju-info"
scope = "juju"
def register(self, registry):
super(JujuInfo, self).register(registry)
self.call_on_accepted("juju-info", self.send_juju_message, True)
def exchange(self, urgent=False):
broker = self.registry.broker
broker.call_if_accepted("juju-info", self.send_juju_message, urgent)
def send_juju_message(self, urgent=False):
message = self._create_juju_info_message()
if message:
message["type"] = "juju-info"
logging.info("Queuing message with updated juju info.")
self.registry.broker.send_message(message, self._session_id,
urgent=urgent)
def _create_juju_info_message(self):
message = get_juju_info(self.registry.config)
if message != self._persist.get("juju-info"):
self._persist.set("juju-info", message)
return message
return None