parallelvirtualcluster
/
pvc
1
0
Fork 0
Code Issues 11 Pull Requests Projects Releases 111 Wiki Activity

Add logging flag for montioring plugin output

This commit is contained in:
Joshua Boniface 2023-02-13 22:02:21 -05:00
parent a3c31564ca
commit bc88d764b0
3 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
node-daemon/pvcnoded.sample.yaml
View File

@ -152,8 +152,8 @@ pvc:
log_keepalives: True log_keepalives: True
# log_keepalive_cluster_details: Enable or disable node status logging during keepalive # log_keepalive_cluster_details: Enable or disable node status logging during keepalive
log_keepalive_cluster_details: True log_keepalive_cluster_details: True
# log_keepalive_storage_details: Enable or disable node storage logging during keepalive # log_keepalive_plugin_details: Enable or disable node health plugin logging during keepalive
log_keepalive_storage_details: True log_keepalive_plugin_details: True
# console_log_lines: Number of console log lines to store in Zookeeper per VM # console_log_lines: Number of console log lines to store in Zookeeper per VM
console_log_lines: 1000 console_log_lines: 1000
# node_log_lines: Number of node log lines to store in Zookeeper per node # node_log_lines: Number of node log lines to store in Zookeeper per node

20
node-daemon/pvcnoded/objects/MonitoringInstance.py
View File

@ -326,10 +326,11 @@ class MonitoringInstance(object):
def run_plugins(self): def run_plugins(self):
total_health = 100 total_health = 100
self.logger.out( if self.config["log_keepalive_plugin_details"]:
f"Running monitoring plugins: {', '.join([x.plugin_name for x in self.all_plugins])}", self.logger.out(
state="t", f"Running monitoring plugins: {', '.join([x.plugin_name for x in self.all_plugins])}",
) state="t",
)
plugin_results = list() plugin_results = list()
with concurrent.futures.ThreadPoolExecutor(max_workers=99) as executor: with concurrent.futures.ThreadPoolExecutor(max_workers=99) as executor:
to_future_plugin_results = { to_future_plugin_results = {
@ -340,11 +341,12 @@ class MonitoringInstance(object):
plugin_results.append(future.result()) plugin_results.append(future.result())
for result in sorted(plugin_results, key=lambda x: x.plugin_name): for result in sorted(plugin_results, key=lambda x: x.plugin_name):
self.logger.out( if self.config["log_keepalive_plugin_details"]:
result.message, self.logger.out(
state="t", result.message,
prefix=f"{result.plugin_name} ({result.runtime}s)", state="t",
) prefix=f"{result.plugin_name} ({result.runtime}s)",
)
if result is not None: if result is not None:
total_health -= result.health_delta total_health -= result.health_delta

4
node-daemon/pvcnoded/util/config.py
View File

@ -228,8 +228,8 @@ def get_configuration():
"log_keepalive_cluster_details": o_logging.get( "log_keepalive_cluster_details": o_logging.get(
"log_keepalive_cluster_details", False "log_keepalive_cluster_details", False
), ),
"log_keepalive_storage_details": o_logging.get( "log_keepalive_plugin_details": o_logging.get(
"log_keepalive_storage_details", False "log_keepalive_plugin_details", False
), ),
"console_log_lines": o_logging.get("console_log_lines", False), "console_log_lines": o_logging.get("console_log_lines", False),
"node_log_lines": o_logging.get("node_log_lines", False), "node_log_lines": o_logging.get("node_log_lines", False),