diff options
author | Tom Ritter <tom@ritter.vg> | 2020-09-07 23:52:47 -0400 |
---|---|---|
committer | Tom Ritter <tom@ritter.vg> | 2020-09-07 23:52:47 -0400 |
commit | 4671e0dec5eab28941e598f109dbf77ed551a707 (patch) | |
tree | c1e32edde4d0dceda1df8e79df67ae99f13d2bcb /jobs/HTTPServerChecker.py | |
parent | ee3eea047c10d0032efc5a8b98d9bbdb54fe0a3a (diff) |
Correct line endings
Diffstat (limited to 'jobs/HTTPServerChecker.py')
-rwxr-xr-x | jobs/HTTPServerChecker.py | 102 |
1 files changed, 51 insertions, 51 deletions
diff --git a/jobs/HTTPServerChecker.py b/jobs/HTTPServerChecker.py index 621e7b8..df96c1e 100755 --- a/jobs/HTTPServerChecker.py +++ b/jobs/HTTPServerChecker.py @@ -1,51 +1,51 @@ -#!/usr/bin/env python
-
-import logging
-import requests
-
-import JobBase
-import JobSpawner
-
-class HTTPServerChecker(JobSpawner.JobSpawner):
- servers = [
- #("http://example.com", JobBase.JobFrequency.MINUTE, JobBase.JobFailureNotificationFrequency.EVERYTIME, JobBase.JobFailureCountMinimumBeforeNotification.ONE),
- #("https://exampletwo.com", JobBase.JobFrequency.MINUTE, JobBase.JobFailureNotificationFrequency.EVERYTIME, JobBase.JobFailureCountMinimumBeforeNotification.ONE)
- ]
-
- class ServerChecker(JobBase.JobBase):
- def __init__(self, config, url, frequency, failureNotificationFrequency, failuresBeforeNotification):
- self.config = config
- self.url = url
- self.frequency = frequency
- self.failureNotificationFrequency = failureNotificationFrequency
- self.failuresBeforeNotification = failuresBeforeNotification
- super(HTTPServerChecker.ServerChecker, self).__init__(config, url)
-
- def getName(self):
- return str(self.__class__) + " for " + self.url
- def executeEvery(self):
- return self.frequency
- def notifyOnFailureEvery(self):
- return self.failureNotificationFrequency
- def numberFailuresBeforeNotification(self):
- return self.failuresBeforeNotification
- def execute(self):
- try:
- i = requests.get(self.url)
- if i.status_code != 200:
- self.failuremsg = "Error hitting server " + self.url + " (Code: " + str(i.status_code) + ")"
- else:
- return True
- except:
- self.failuremsg = "Could not hit server " + self.url
- logging.warn(self.failuremsg)
- return False
- def onFailure(self):
- return self.sendEmail(self.failuremsg, "")
- def onStateChangeSuccess(self):
- return self.sendEmail("Successfully hit " + self.url, "")
-
- def get_sub_jobs(self, config):
- for s in self.servers:
- yield self.ServerChecker(config, s[0], s[1], s[2], s[3])
-
+#!/usr/bin/env python + +import logging +import requests + +import JobBase +import JobSpawner + +class HTTPServerChecker(JobSpawner.JobSpawner): + servers = [ + #("http://example.com", JobBase.JobFrequency.MINUTE, JobBase.JobFailureNotificationFrequency.EVERYTIME, JobBase.JobFailureCountMinimumBeforeNotification.ONE), + #("https://exampletwo.com", JobBase.JobFrequency.MINUTE, JobBase.JobFailureNotificationFrequency.EVERYTIME, JobBase.JobFailureCountMinimumBeforeNotification.ONE) + ] + + class ServerChecker(JobBase.JobBase): + def __init__(self, config, url, frequency, failureNotificationFrequency, failuresBeforeNotification): + self.config = config + self.url = url + self.frequency = frequency + self.failureNotificationFrequency = failureNotificationFrequency + self.failuresBeforeNotification = failuresBeforeNotification + super(HTTPServerChecker.ServerChecker, self).__init__(config, url) + + def getName(self): + return str(self.__class__) + " for " + self.url + def executeEvery(self): + return self.frequency + def notifyOnFailureEvery(self): + return self.failureNotificationFrequency + def numberFailuresBeforeNotification(self): + return self.failuresBeforeNotification + def execute(self): + try: + i = requests.get(self.url) + if i.status_code != 200: + self.failuremsg = "Error hitting server " + self.url + " (Code: " + str(i.status_code) + ")" + else: + return True + except: + self.failuremsg = "Could not hit server " + self.url + logging.warn(self.failuremsg) + return False + def onFailure(self): + return self.sendEmail(self.failuremsg, "") + def onStateChangeSuccess(self): + return self.sendEmail("Successfully hit " + self.url, "") + + def get_sub_jobs(self, config): + for s in self.servers: + yield self.ServerChecker(config, s[0], s[1], s[2], s[3]) + |