
This patch removes hostname and ports attributes, and modifies memory_size as MiB from create dialog. Also, merge environment tab into miscellaneous tab. Since create dialog will be changed widely in following patch, so this patch is provided as hotfix. Change-Id: I63920f7792655cce06d3bcf531ecdce6591cdd44
119 lines
3.6 KiB
Python
119 lines
3.6 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.
|
|
|
|
|
|
from horizon import exceptions
|
|
from horizon.utils.memoized import memoized
|
|
import logging
|
|
from openstack_dashboard.api import base
|
|
from zunclient.v1 import client as zun_client
|
|
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
CONTAINER_CREATE_ATTRS = zun_client.containers.CREATION_ATTRIBUTES
|
|
|
|
|
|
@memoized
|
|
def zunclient(request):
|
|
zun_url = ""
|
|
try:
|
|
zun_url = base.url_for(request, 'container')
|
|
except exceptions.ServiceCatalogException:
|
|
LOG.debug('No Container Management service is configured.')
|
|
return None
|
|
|
|
LOG.debug('zunclient connection created using the token "%s" and url'
|
|
'"%s"' % (request.user.token.id, zun_url))
|
|
c = zun_client.Client(username=request.user.username,
|
|
project_id=request.user.tenant_id,
|
|
input_auth_token=request.user.token.id,
|
|
zun_url=zun_url)
|
|
return c
|
|
|
|
|
|
def container_create(request, **kwargs):
|
|
args = {}
|
|
for (key, value) in kwargs.items():
|
|
if key in CONTAINER_CREATE_ATTRS:
|
|
args[str(key)] = str(value)
|
|
else:
|
|
raise exceptions.BadRequest(
|
|
"Key must be in %s" % ",".join(CONTAINER_CREATE_ATTRS))
|
|
if key == "environment":
|
|
envs = {}
|
|
vals = value.split(",")
|
|
for v in vals:
|
|
kv = v.split("=", 1)
|
|
envs[kv[0]] = kv[1]
|
|
args["environment"] = envs
|
|
elif key == "labels":
|
|
labels = {}
|
|
vals = value.split(",")
|
|
for v in vals:
|
|
kv = v.split("=", 1)
|
|
labels[kv[0]] = kv[1]
|
|
args["labels"] = labels
|
|
return zunclient(request).containers.create(**args)
|
|
|
|
|
|
def container_delete(request, id, force=False):
|
|
# TODO(shu-mutou): force option should be provided by user.
|
|
return zunclient(request).containers.delete(id, force)
|
|
|
|
|
|
def container_list(request, limit=None, marker=None, sort_key=None,
|
|
sort_dir=None, detail=True):
|
|
# TODO(shu-mutou): detail option should be added, if it is
|
|
# implemented in Zun API
|
|
return zunclient(request).containers.list(limit, marker, sort_key,
|
|
sort_dir)
|
|
|
|
|
|
def container_show(request, id):
|
|
return zunclient(request).containers.get(id)
|
|
|
|
|
|
def container_logs(request, id):
|
|
args = {}
|
|
args["stdout"] = True
|
|
args["stderr"] = True
|
|
return zunclient(request).containers.logs(id, **args)
|
|
|
|
|
|
def container_start(request, id):
|
|
return zunclient(request).containers.start(id)
|
|
|
|
|
|
def container_stop(request, id):
|
|
return zunclient(request).containers.stop(id)
|
|
|
|
|
|
def container_reboot(request, id):
|
|
return zunclient(request).containers.reboot(id)
|
|
|
|
|
|
def container_pause(request, id):
|
|
return zunclient(request).containers.pause(id)
|
|
|
|
|
|
def container_unpause(request, id):
|
|
return zunclient(request).containers.unpause(id)
|
|
|
|
|
|
def container_execute(request, id, command):
|
|
return zunclient(request).containers.execute(id, command)
|
|
|
|
|
|
def container_kill(request, id, signal=None):
|
|
return zunclient(request).containers.kill(id, signal)
|