yatin
553316e40f
After [1] jobs are return false(SUCCESS) status due to wrong EXIT_CODE. After [2] kubernetes client is updated to v4.0.0 and no longer contains ConfiugrationObject so we need create instance of Configuration class. Also don't use local to create variable as local can only be used in a function. [1] https://review.openstack.org/#/c/526618/ [2] https://review.openstack.org/#/c/528406 Change-Id: Ida5aac40b234a358b2a13b2e51a41d0242031ebb
83 lines
2.5 KiB
Python
Executable File
83 lines
2.5 KiB
Python
Executable File
# Copyright 2015 Huawei Technologies Co.,LTD.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
|
|
import tempfile
|
|
|
|
from kubernetes import client as k8s_config
|
|
from kubernetes.client import api_client
|
|
from kubernetes.client.apis import core_v1_api
|
|
from oslo_log import log as logging
|
|
|
|
from magnum.conductor.handlers.common.cert_manager import create_client_files
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
|
|
class K8sAPI(core_v1_api.CoreV1Api):
|
|
|
|
def _create_temp_file_with_content(self, content):
|
|
"""Creates temp file and write content to the file.
|
|
|
|
:param content: file content
|
|
:returns: temp file
|
|
"""
|
|
try:
|
|
tmp = tempfile.NamedTemporaryFile(delete=True)
|
|
tmp.write(content)
|
|
tmp.flush()
|
|
except Exception as err:
|
|
LOG.error("Error while creating temp file: %s", err)
|
|
raise
|
|
return tmp
|
|
|
|
def __init__(self, context, cluster):
|
|
self.ca_file = None
|
|
self.cert_file = None
|
|
self.key_file = None
|
|
|
|
if cluster.magnum_cert_ref:
|
|
(self.ca_file, self.key_file,
|
|
self.cert_file) = create_client_files(cluster, context)
|
|
|
|
config = k8s_config.Configuration()
|
|
config.host = cluster.api_address
|
|
config.ssl_ca_cert = self.ca_file.name
|
|
config.cert_file = self.cert_file.name
|
|
config.key_file = self.key_file.name
|
|
|
|
# build a connection with Kubernetes master
|
|
client = api_client.ApiClient(configuration=config)
|
|
|
|
super(K8sAPI, self).__init__(client)
|
|
|
|
def __del__(self):
|
|
if self.ca_file:
|
|
self.ca_file.close()
|
|
if self.cert_file:
|
|
self.cert_file.close()
|
|
if self.key_file:
|
|
self.key_file.close()
|
|
|
|
|
|
def create_k8s_api(context, cluster):
|
|
"""Create a kubernetes API client
|
|
|
|
Creates connection with Kubernetes master and creates ApivApi instance
|
|
to call Kubernetes APIs.
|
|
|
|
:param context: The security context
|
|
:param cluster: Cluster object
|
|
"""
|
|
return K8sAPI(context, cluster)
|