|
 |
0ed125 |
From 647841dea9d93922779a4aa7d0b5f52f5bc2b4e9 Mon Sep 17 00:00:00 2001
|
|
|
0ed125 |
From: Dan Kenigsberg <danken@redhat.com>
|
|
|
0ed125 |
Date: Thu, 13 Jan 2022 14:57:26 +0200
|
|
|
0ed125 |
Subject: [PATCH] fence_kubevirt: take default namespace from context
|
|
|
0ed125 |
|
|
|
0ed125 |
If --namespace is not provided to kubectl, a default one is taken from
|
|
|
0ed125 |
kubeconfig context. Let fence_kubevirt behave similarly.
|
|
|
0ed125 |
|
|
|
0ed125 |
Signed-off-by: Dan Kenigsberg <danken@redhat.com>
|
|
|
0ed125 |
---
|
|
|
0ed125 |
agents/kubevirt/fence_kubevirt.py | 24 +++++++++++++-----------
|
|
|
0ed125 |
2 files changed, 14 insertions(+), 12 deletions(-)
|
|
|
0ed125 |
|
|
|
0ed125 |
diff --git a/agents/kubevirt/fence_kubevirt.py b/agents/kubevirt/fence_kubevirt.py
|
|
|
0ed125 |
index 8392b75a0..8c27a0334 100755
|
|
|
0ed125 |
--- a/agents/kubevirt/fence_kubevirt.py
|
|
|
0ed125 |
+++ b/agents/kubevirt/fence_kubevirt.py
|
|
|
0ed125 |
@@ -12,12 +12,21 @@
|
|
|
0ed125 |
except ImportError:
|
|
|
0ed125 |
logging.error("Couldn\'t import kubernetes.client.exceptions.ApiException - not found or not accessible")
|
|
|
0ed125 |
|
|
|
0ed125 |
+def _get_namespace(options):
|
|
|
0ed125 |
+ from kubernetes import config
|
|
|
0ed125 |
+
|
|
|
0ed125 |
+ ns = options.get("--namespace")
|
|
|
0ed125 |
+ if ns is None:
|
|
|
0ed125 |
+ ns = config.kube_config.list_kube_config_contexts()[1]['context']['namespace']
|
|
|
0ed125 |
+
|
|
|
0ed125 |
+ return ns
|
|
|
0ed125 |
+
|
|
|
0ed125 |
def get_nodes_list(conn, options):
|
|
|
0ed125 |
logging.debug("Starting list/monitor operation")
|
|
|
0ed125 |
result = {}
|
|
|
0ed125 |
try:
|
|
|
0ed125 |
apiversion = options.get("--apiversion")
|
|
|
0ed125 |
- namespace = options.get("--namespace")
|
|
|
0ed125 |
+ namespace = _get_namespace(options)
|
|
|
0ed125 |
include_uninitialized = True
|
|
|
0ed125 |
vm_api = conn.resources.get(api_version=apiversion, kind='VirtualMachine')
|
|
|
0ed125 |
vm_list = vm_api.get(namespace=namespace)
|
|
|
0ed125 |
@@ -31,7 +40,7 @@ def get_power_status(conn, options):
|
|
|
0ed125 |
logging.debug("Starting get status operation")
|
|
|
0ed125 |
try:
|
|
|
0ed125 |
apiversion = options.get("--apiversion")
|
|
|
0ed125 |
- namespace = options.get("--namespace")
|
|
|
0ed125 |
+ namespace = _get_namespace(options)
|
|
|
0ed125 |
name = options.get("--plug")
|
|
|
0ed125 |
vmi_api = conn.resources.get(api_version=apiversion,
|
|
|
0ed125 |
kind='VirtualMachineInstance')
|
|
|
0ed125 |
@@ -61,7 +70,7 @@ def set_power_status(conn, options):
|
|
|
0ed125 |
logging.debug("Starting set status operation")
|
|
|
0ed125 |
try:
|
|
|
0ed125 |
apiversion= options.get("--apiversion")
|
|
|
0ed125 |
- namespace = options.get("--namespace")
|
|
|
0ed125 |
+ namespace = _get_namespace(options)
|
|
|
0ed125 |
name = options.get("--plug")
|
|
|
0ed125 |
action = 'start' if options["--action"] == "on" else 'stop'
|
|
|
0ed125 |
virtctl_vm_action(conn, action, namespace, name, apiversion)
|
|
|
0ed125 |
@@ -75,7 +84,7 @@ def define_new_opts():
|
|
|
0ed125 |
"longopt" : "namespace",
|
|
|
0ed125 |
"help" : "--namespace=[namespace] Namespace of the KubeVirt machine",
|
|
|
0ed125 |
"shortdesc" : "Namespace of the KubeVirt machine.",
|
|
|
0ed125 |
- "required" : "1",
|
|
|
0ed125 |
+ "required" : "0",
|
|
|
0ed125 |
"order" : 2
|
|
|
0ed125 |
}
|
|
|
0ed125 |
all_opt["kubeconfig"] = {
|
|
|
0ed125 |
@@ -101,11 +110,6 @@ def virtctl_vm_action(conn, action, namespace, name, apiversion):
|
|
|
0ed125 |
path = path.format(api_version=apiversion, namespace=namespace, name=name, action=action)
|
|
|
0ed125 |
return conn.request('put', path, header_params={'accept': '*/*'})
|
|
|
0ed125 |
|
|
|
0ed125 |
-def validate_options(required_options_list, options):
|
|
|
0ed125 |
- for required_option in required_options_list:
|
|
|
0ed125 |
- if required_option not in options:
|
|
|
0ed125 |
- fail_usage("Failed: %s option must be provided" % required_option)
|
|
|
0ed125 |
-
|
|
|
0ed125 |
# Main agent method
|
|
|
0ed125 |
def main():
|
|
|
0ed125 |
conn = None
|
|
|
0ed125 |
@@ -127,8 +131,6 @@ def main():
|
|
|
0ed125 |
|
|
|
0ed125 |
run_delay(options)
|
|
|
0ed125 |
|
|
|
0ed125 |
- validate_options(['--namespace'], options)
|
|
|
0ed125 |
-
|
|
|
0ed125 |
# Disable insecure-certificate-warning message
|
|
|
0ed125 |
if "--ssl-insecure" in options:
|
|
|
0ed125 |
import urllib3
|