241 lines
9.1 KiB
Python
241 lines
9.1 KiB
Python
# 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 testtools
|
|
|
|
from oslo_utils import encodeutils
|
|
from tempest.lib.common.utils import data_utils
|
|
from tempest.lib import decorators
|
|
from tempest.lib import exceptions as lib_exc
|
|
|
|
from zun_tempest_plugin.tests.tempest.api import clients
|
|
from zun_tempest_plugin.tests.tempest.api.common import datagen
|
|
from zun_tempest_plugin.tests.tempest import base
|
|
from zun_tempest_plugin.tests.tempest import utils
|
|
|
|
|
|
class TestCapsule(base.BaseZunTest):
|
|
|
|
credentials = ['primary', 'admin']
|
|
min_microversion = '1.12'
|
|
|
|
@classmethod
|
|
def get_client_manager(cls, credential_type=None, roles=None,
|
|
force_new=None):
|
|
manager = super(TestCapsule, cls).get_client_manager(
|
|
credential_type=credential_type,
|
|
roles=roles,
|
|
force_new=force_new
|
|
)
|
|
return clients.Manager(manager.credentials)
|
|
|
|
@decorators.idempotent_id('d5c91423-0f83-44f8-8228-e6a28ef7817e')
|
|
@testtools.skip('bug 1941982')
|
|
def test_create_capsule(self):
|
|
self._create_capsule()
|
|
|
|
def _create_capsule(self, **kwargs):
|
|
gen_model = datagen.capsule_data(**kwargs)
|
|
resp, model = self.container_client.post_capsule(gen_model)
|
|
self.addCleanup(self._delete_capsule, model.uuid)
|
|
self.assertEqual(202, resp.status)
|
|
# Wait for container to finish creation
|
|
self.container_client.ensure_capsule_in_desired_state(
|
|
model.uuid, 'Running')
|
|
|
|
# Assert the capsule is created
|
|
resp, model = self.container_client.get_capsule(model.uuid)
|
|
self.assertEqual(200, resp.status)
|
|
self.assertEqual('Running', model.status)
|
|
if self._microversion_atleast('1.34'):
|
|
for container in model.init_containers:
|
|
self.assertEqual('Stopped', container['status'])
|
|
for container in model.containers:
|
|
self.assertEqual('Running', container['status'])
|
|
# TODO(hongbin): verify all containers are running
|
|
return resp, model
|
|
|
|
def _delete_capsule(self, uuid):
|
|
try:
|
|
self.container_client.delete_capsule(uuid)
|
|
self.container_client.ensure_capsule_deleted(uuid)
|
|
except lib_exc.NotFound:
|
|
pass
|
|
|
|
@decorators.idempotent_id('b7e79a0b-c09e-4539-886f-a9f33ae15620')
|
|
@testtools.skip('bug 1941982')
|
|
def test_create_capsule_full(self):
|
|
capsule_data = {
|
|
"template": {
|
|
"capsuleVersion": "beta",
|
|
"kind": "capsule",
|
|
"metadata": {
|
|
"labels": {
|
|
"app": "web",
|
|
"app1": "web1"
|
|
},
|
|
"name": data_utils.rand_name('capsule')
|
|
},
|
|
"spec": {
|
|
"restartPolicy": "Always",
|
|
"containers": [
|
|
{
|
|
"command": [
|
|
"/bin/bash"
|
|
],
|
|
"env": {
|
|
"ENV1": "/usr/local/bin",
|
|
"ENV2": "/usr/bin"
|
|
},
|
|
"image": "ubuntu",
|
|
"ports": [
|
|
{
|
|
"containerPort": 80,
|
|
"hostPort": 80,
|
|
"name": "nginx-port",
|
|
"protocol": "TCP"
|
|
}
|
|
],
|
|
"resources": {
|
|
"requests": {
|
|
"cpu": 1,
|
|
"memory": 256
|
|
}
|
|
},
|
|
"workDir": "/root"
|
|
}
|
|
]
|
|
}
|
|
}
|
|
}
|
|
|
|
self._create_capsule(data=capsule_data)
|
|
|
|
@decorators.idempotent_id('8bb22511-b06f-4ea5-ae8d-9dd529205590')
|
|
@testtools.skip('bug 1941982')
|
|
@utils.requires_microversion('1.32')
|
|
def test_create_capsule_with_volume(self):
|
|
# create a volume in cinder
|
|
volume = self.vol_client.create_volume(
|
|
name=data_utils.rand_name(), size=1)['volume']
|
|
volume_id = volume['id']
|
|
self.addCleanup(self.vol_client.delete_volume, volume_id)
|
|
|
|
capsule_data = {
|
|
'template': {
|
|
'kind': 'capsule',
|
|
'capsuleVersion': 'beta',
|
|
'metadata': {'name': data_utils.rand_name('capsule')},
|
|
'spec': {
|
|
'containers': [
|
|
{
|
|
'image': 'cirros:latest',
|
|
'volumeMounts': [{
|
|
'name': 'test-volume',
|
|
'mountPath': '/test-volume',
|
|
}]
|
|
}
|
|
],
|
|
'volumes': [
|
|
{
|
|
'name': 'test-volume',
|
|
'cinder': {
|
|
'volumeID': volume_id,
|
|
}
|
|
}
|
|
]
|
|
}
|
|
}
|
|
}
|
|
_, model = self._create_capsule(data=capsule_data)
|
|
# assert volume is attached
|
|
volume = self.vol_client.show_volume(volume_id)['volume']
|
|
self.assertEqual('in-use', volume['status'])
|
|
|
|
self._delete_capsule(model.uuid)
|
|
# assert volume is detached
|
|
volume = self.vol_client.show_volume(volume_id)['volume']
|
|
self.assertEqual('available', volume['status'])
|
|
|
|
@decorators.idempotent_id('3534116a-fa85-4da5-b5a3-4ef20f9479b4')
|
|
@testtools.skip('bug 1941982')
|
|
@utils.requires_microversion('1.35')
|
|
def test_create_capsule_with_init_container(self):
|
|
capsule_data = {
|
|
'template': {
|
|
'kind': 'capsule',
|
|
'capsuleVersion': 'beta',
|
|
'metadata': {'name': data_utils.rand_name('capsule')},
|
|
'spec': {
|
|
'initContainers': [
|
|
{
|
|
'image': 'cirros:latest',
|
|
'command': [
|
|
"/bin/sh",
|
|
"-c",
|
|
"echo 'hello' > /work-dir/index.html"
|
|
],
|
|
'volumeMounts': [{
|
|
'name': 'workdir',
|
|
'mountPath': '/work-dir',
|
|
}]
|
|
}
|
|
],
|
|
'containers': [
|
|
{
|
|
'image': 'nginx',
|
|
'volumeMounts': [{
|
|
'name': 'workdir',
|
|
'mountPath': '/usr/share/nginx/html',
|
|
}],
|
|
'ports': [{
|
|
'containerPort': 80,
|
|
'protocol': 'TCP',
|
|
}]
|
|
}
|
|
],
|
|
'volumes': [
|
|
{
|
|
'name': 'workdir',
|
|
'cinder': {
|
|
'size': 1,
|
|
'autoRemove': True,
|
|
}
|
|
}
|
|
]
|
|
}
|
|
}
|
|
}
|
|
_, model = self._create_capsule(data=capsule_data)
|
|
|
|
# run another container to access port 80 and verify the content
|
|
# is 'hello'
|
|
# TODO(hongbin): Use capsule instead of container in here once
|
|
# retrieving capsule's log is supported
|
|
ip_address = None
|
|
for net_id in model.addresses:
|
|
for address in model.addresses[net_id]:
|
|
ip_address = address['addr']
|
|
break
|
|
self.assertIsNotNone(ip_address)
|
|
gen_model = datagen.container_data({
|
|
'image': 'cirros', 'command': ['curl', ip_address]})
|
|
_, m = self.container_client.run_container(gen_model)
|
|
self.container_client.ensure_container_in_desired_state(
|
|
m.uuid, 'Stopped')
|
|
resp, body = self.container_client.logs_container(m.uuid)
|
|
self.assertTrue('hello' in encodeutils.safe_decode(body))
|
|
# TODO(hongbin): Remove this once we switch to capsule
|
|
self.container_client.delete_container(
|
|
m.uuid, params={'stop': True})
|
|
self.container_client.ensure_container_deleted(m.uuid)
|