cn/kube-stale-resources
1
0
Fork 0
mirror of https://github.com/cmur2/kube-stale-resources.git synced 2024-12-22 02:54:24 +01:00
Code Releases Activity

module: add request timeouts to fix lint warning

Browse Source
This commit is contained in:
cn 2022-09-01 12:26:17 +02:00 committed by Christian Nicolai
parent 18df68d1bf
commit 385cb79323
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
kube-stale-resources.py
View File

@ -50,25 +50,26 @@ def get_live_namespaced_resources(url: str) -> List[K8sResourceIdentifier]:
# merges https://kubernetes.io/docs/reference/using-api/#api-groups # merges https://kubernetes.io/docs/reference/using-api/#api-groups
# legacy API group # legacy API group
apiVersions = requests.get(url + '/api', headers=HEADERS).json()['versions'] apiVersions = requests.get(url + '/api', headers=HEADERS, timeout=10).json()['versions']
for apiVersion in apiVersions: for apiVersion in apiVersions:
apiResources = requests.get(url + '/api/' + apiVersion, headers=HEADERS).json()['resources'] apiResources = requests.get(url + '/api/' + apiVersion, headers=HEADERS, timeout=10).json()['resources']
for apiResource in apiResources: for apiResource in apiResources:
if not ('list' in apiResource['verbs'] and apiResource['namespaced']): if not ('list' in apiResource['verbs'] and apiResource['namespaced']):
continue continue
items = requests.get(url + '/api/' + apiVersion + '/' + apiResource['name'], items = requests.get(url + '/api/' + apiVersion + '/' + apiResource['name'], headers=HEADERS,
headers=HEADERS).json()['items'] timeout=10).json()['items']
for item in items: for item in items:
result.append( result.append(
(item['metadata']['namespace'], apiVersion, apiResource['kind'], item['metadata']['name'])) (item['metadata']['namespace'], apiVersion, apiResource['kind'], item['metadata']['name']))
# named API groups # named API groups
apiGroups = requests.get(url + '/apis', headers=HEADERS).json()['groups'] apiGroups = requests.get(url + '/apis', headers=HEADERS, timeout=10).json()['groups']
for apiGroup in apiGroups: for apiGroup in apiGroups:
apiResources = requests.get(url + '/apis/' + apiGroup['preferredVersion']['groupVersion'], apiResources = requests.get(url + '/apis/' + apiGroup['preferredVersion']['groupVersion'],
headers=HEADERS).json()['resources'] headers=HEADERS,
timeout=10).json()['resources']
for apiResource in apiResources: for apiResource in apiResources:
if not ('list' in apiResource['verbs'] and apiResource['namespaced']): if not ('list' in apiResource['verbs'] and apiResource['namespaced']):
continue continue
@ -80,7 +81,8 @@ def get_live_namespaced_resources(url: str) -> List[K8sResourceIdentifier]:
items = requests.get(url + '/apis/' + apiGroup['preferredVersion']['groupVersion'] + '/' + items = requests.get(url + '/apis/' + apiGroup['preferredVersion']['groupVersion'] + '/' +
apiResource['name'], apiResource['name'],
headers=HEADERS).json()['items'] headers=HEADERS,
timeout=10).json()['items']
for item in items: for item in items:
result.append((item['metadata']['namespace'], apiGroup['preferredVersion']['groupVersion'], result.append((item['metadata']['namespace'], apiGroup['preferredVersion']['groupVersion'],
apiResource['kind'], item['metadata']['name'])) apiResource['kind'], item['metadata']['name']))