"""
import re
-import os
-from kubernetes import client, config
+import sys
from kubernetes.client.rest import ApiException
from kubernetes.stream import stream
try:
resp = api_instance.read_namespaced_pod(name=name,
namespace='default')
- except ApiException as e:
- if e.status != 404:
- print("Unknown error: %s" % e)
- exit(1)
+ except ApiException as excep:
+ if excep.status != 404:
+ print("Unknown error: %s" % excep)
+ sys.exit(0)
if not resp:
print("Pod %s does not exist. Creating it..." % name)
return -1
elif 'name' in rout:
names.append(rout[5:])
res = {names[i]: ifs[i] for i in range(len(names))}
+ return res
def start_fowarding_app(api_instance, podname, namespace, appname):
"""
'namespace': namespace}
cmd = [appname, '&']
response = execute_command(api_instance, pinfo, cmd)
+ return response
from conf import settings as S
from pods.pod.pod import IPod
+from pods.papi import k8scmdrun as util
class Papi(IPod):
"""
group = 'k8s.cni.cncf.io'
version = 'v1'
kind_plural = 'network-attachment-definitions'
- api = client.CustomObjectsApi()
+ api = client.CustomObjectsApi()
assert pod_count <= len(pod_manifests)
for nad_filepath in S.getValue('NETWORK_ATTACHMENT_FILEPATH'):
status = response.status.phase
except ApiException as err:
raise Exception from err
- if (status == "Running"
- or status == "Failed"
- or status == "Unknown"):
+ if status in ("Running", "Failed", "Unknown"):
break
- else:
- time.sleep(5)
- count = count + 1
+ time.sleep(5)
+ count = count + 1
# Now Get the Pod-IP
try:
response = api.read_namespaced_pod_status(dep_pod_info['name'],
except ApiException as err:
raise Exception from err
dep_pod_info['namespace'] = namespace
- dep_pod_list.append(dep_pod_info)
cmd = ['cat', '/etc/podnetinfo/annotations']
- execute_command(api, dep_pod_info, cmd)
-
+ output = util.execute_command(api, dep_pod_info, cmd)
+ dep_pod_info['annotations'] = output
+ dep_pod_list.append(dep_pod_info)
+
S.setValue('POD_LIST',dep_pod_list)
return dep_pod_list
Code Review / vineperf.git / commitdiff