added pointer for hostgroup in service
This commit is contained in:
parent
a1ab1b1661
commit
af093c8f39
2 changed files with 19 additions and 6 deletions
|
|
@ -254,5 +254,8 @@ class FullConfigParser(ConfigParser):
|
||||||
for hg in hostgroups:
|
for hg in hostgroups:
|
||||||
for service in hg.get_services():
|
for service in hg.get_services():
|
||||||
service.set_hostgroup(hg)
|
service.set_hostgroup(hg)
|
||||||
|
core = None
|
||||||
|
if "core" in self.jsonDict:
|
||||||
|
core = self.jsonDict["core"]
|
||||||
|
|
||||||
return layouts
|
return (layouts, core)
|
||||||
20
linspector
20
linspector
|
|
@ -12,6 +12,7 @@ from lib.core.logger import Logger
|
||||||
from lib.config.parser import FullConfigParser
|
from lib.config.parser import FullConfigParser
|
||||||
from apscheduler.scheduler import Scheduler
|
from apscheduler.scheduler import Scheduler
|
||||||
|
|
||||||
|
log = None
|
||||||
|
|
||||||
def parseArgs():
|
def parseArgs():
|
||||||
parser = argparse.ArgumentParser(
|
parser = argparse.ArgumentParser(
|
||||||
|
|
@ -43,7 +44,7 @@ def parseArgs():
|
||||||
|
|
||||||
|
|
||||||
def handleJob(jobInfo):
|
def handleJob(jobInfo):
|
||||||
jobInfo.handleCall()
|
log.w(jobInfo)
|
||||||
|
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
|
|
@ -54,11 +55,20 @@ def main():
|
||||||
|
|
||||||
if args.action == "start":
|
if args.action == "start":
|
||||||
configParser = FullConfigParser(log)
|
configParser = FullConfigParser(log)
|
||||||
config = configParser.parse_config(args.config)
|
layouts, core = configParser.parse_config(args.config)
|
||||||
|
|
||||||
#jobs = []
|
scheduler = Scheduler()
|
||||||
#scheduler = Scheduler()
|
|
||||||
#scheduler.start()
|
|
||||||
|
jobs = []
|
||||||
|
for layout in layouts:
|
||||||
|
if layout.is_enabled():
|
||||||
|
for hg in layout.get_hostgroups():
|
||||||
|
for services in hg.get_services():
|
||||||
|
for service in services:
|
||||||
|
for period in service.get_periods():
|
||||||
|
jobs.append(period.createJob(scheduler, service, handleJob))
|
||||||
|
scheduler.start()
|
||||||
|
|
||||||
#log.i("starting linspector: reading config... (" + args.config + ")")
|
#log.i("starting linspector: reading config... (" + args.config + ")")
|
||||||
#config_parser = ConfigParser(log)
|
#config_parser = ConfigParser(log)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue