linspector/linspector-old
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

added threshold handling to job.py and config

Browse source
This commit is contained in:
Johannes Findeisen 2013-10-11 02:07:55 +02:00
commit ee5245eccb
2 changed files with 11 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
examples/linspector.json
View file

@ -184,10 +184,12 @@
} }
}, },
"core":{ "core":{
"_documentation": "https://github.com/linspector/linspector/wiki/Configuration-Core",
"instance_name": "Master Monitoring (monitor.example.org)", "instance_name": "Master Monitoring (monitor.example.org)",
"max_logfile_size": 1024000, "max_logfile_size": 1024000,
"max_logfile_count": 4, "max_logfile_count": 4,
"max_worker_threads": 8, "max_worker_threads": 8,
"threshold_handling": "reset",
"members":[ "root" ], "members":[ "root" ],
"backends": { "backends": {
"jsonrpc": { "jsonrpc": {

10
linspector/core/job.py
View file

@ -73,7 +73,15 @@ class Job:
def handle_threshold(self, jobInfo, serviceThreshold, executionSucessful): def handle_threshold(self, jobInfo, serviceThreshold, executionSucessful):
if executionSucessful: if executionSucessful:
if self.jobThreshold > 0: if self.jobThreshold > 0:
self.jobThreshold -= 1 #TODO: maybe set threshold_handling for each service optionally; will override core setting!
if self.core["threshold_handling"] == "reset":
# Reset counter to 0
self.log.debug("Threshold Reset")
self.jobThreshold = 0
else:
# Decrement the counter (default)
self.log.debug("Threshold Decrement")
self.jobThreshold -= 1
else: else:
self.jobThreshold += 1 self.jobThreshold += 1