bj/syncthing-monitor
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

added retries to etcd and syncthing http calls

Browse Source
This commit is contained in:
B.J. Dweck 2021-02-07 14:01:59 +02:00
parent ab1434b7a5
commit 0a93abe30f
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
syncthing_monitor/etcd_client.py
View File

@ -1,6 +1,7 @@
import json import json
import etcd3 as etcd3 import etcd3 as etcd3
from retrying import retry
CLUSTER_INFO_KEY = '/syncthing_monitor/cluster_info' CLUSTER_INFO_KEY = '/syncthing_monitor/cluster_info'
@ -10,6 +11,7 @@ class EtcdClient:
self.etcd = etcd3.client(host=host, port=port) self.etcd = etcd3.client(host=host, port=port)
self.key = key self.key = key
@retry(stop_max_delay=60000, wait_fixed=500)
def load_cluster_info(self): def load_cluster_info(self):
print("Retrieving cluster info from etcd...", flush=True) print("Retrieving cluster info from etcd...", flush=True)
raw_value = self.etcd.get(self.key)[0] raw_value = self.etcd.get(self.key)[0]

4
syncthing_monitor/syncthing_client.py
View File

@ -1,6 +1,7 @@
import json import json
import requests import requests
from retrying import retry
class SyncthingClient: class SyncthingClient:
@ -137,11 +138,14 @@ class SyncthingClient:
def make_url(self, endpoint): def make_url(self, endpoint):
return "http://{0}:{1}{2}".format(self.host, self.port, endpoint) return "http://{0}:{1}{2}".format(self.host, self.port, endpoint)
@retry(stop_max_delay=60000, wait_fixed=500)
def get(self, endpoint): def get(self, endpoint):
return requests.get(self.make_url(endpoint), headers=self.headers) return requests.get(self.make_url(endpoint), headers=self.headers)
@retry(stop_max_delay=60000, wait_fixed=500)
def post(self, endpoint, data): def post(self, endpoint, data):
return requests.post(self.make_url(endpoint), headers=self.headers, data=data) return requests.post(self.make_url(endpoint), headers=self.headers, data=data)
@retry(stop_max_delay=60000, wait_fixed=500)
def patch(self, endpoint, data): def patch(self, endpoint, data):
return requests.patch(self.make_url(endpoint), headers=self.headers, data=data) return requests.patch(self.make_url(endpoint), headers=self.headers, data=data)