129 lines
5.6 KiB
Python
129 lines
5.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 paunch.builder import base
|
|
from paunch.utils import common
|
|
|
|
|
|
class ComposeV1Builder(base.BaseBuilder):
|
|
|
|
def __init__(self, config_id, config, runner, labels=None, log=None,
|
|
cleanup=True):
|
|
super(ComposeV1Builder, self).__init__(config_id, config, runner,
|
|
labels, log, cleanup)
|
|
|
|
def container_run_args(self, cmd, container, delegate=None):
|
|
"""Prepare the run command args, from the container configuration.
|
|
|
|
:param cmd: The list of command options to be modified
|
|
:param container: A dict with container configurations
|
|
:delegate: A compatibility parameter for podman, does nothing here
|
|
:returns: True if configuration is valid, otherwise False
|
|
"""
|
|
if delegate and container != delegate:
|
|
self.log.debug("Delegate {} of container {} has no special "
|
|
"meanings for this context and will be "
|
|
"ignored".format(delegate, container))
|
|
cconfig = self.config[container]
|
|
if cconfig.get('detach', True):
|
|
cmd.append('--detach=true')
|
|
self.list_or_string_arg(cconfig, cmd, 'env_file', '--env-file')
|
|
self.list_or_dict_arg(cconfig, cmd, 'environment', '--env')
|
|
self.boolean_arg(cconfig, cmd, 'remove', '--rm')
|
|
self.boolean_arg(cconfig, cmd, 'interactive', '--interactive')
|
|
self.boolean_arg(cconfig, cmd, 'tty', '--tty')
|
|
self.string_arg(cconfig, cmd, 'net', '--net')
|
|
self.string_arg(cconfig, cmd, 'ipc', '--ipc')
|
|
self.string_arg(cconfig, cmd, 'pid', '--pid')
|
|
self.string_arg(cconfig, cmd, 'uts', '--uts')
|
|
# TODO(sbaker): implement ulimits property, deprecate this ulimit
|
|
# property
|
|
for u in cconfig.get('ulimit', []):
|
|
if u:
|
|
cmd.append('--ulimit=%s' % u)
|
|
if 'healthcheck' in cconfig:
|
|
hconfig = cconfig['healthcheck']
|
|
if 'test' in hconfig:
|
|
cmd.append('--health-cmd')
|
|
cmd.append(str(hconfig['test']))
|
|
if 'interval' in hconfig:
|
|
cmd.append('--health-interval=%s' % hconfig['interval'])
|
|
if 'timeout' in hconfig:
|
|
cmd.append('--health-timeout=%s' % hconfig['timeout'])
|
|
if 'retries' in hconfig:
|
|
cmd.append('--health-retries=%s' % hconfig['retries'])
|
|
|
|
self.string_arg(cconfig, cmd, 'privileged', '--privileged', self.lower)
|
|
self.string_arg(cconfig, cmd, 'restart', '--restart')
|
|
self.string_arg(cconfig, cmd, 'user', '--user')
|
|
self.list_arg(cconfig, cmd, 'group_add', '--group-add')
|
|
self.list_arg(cconfig, cmd, 'volumes', '--volume')
|
|
self.list_arg(cconfig, cmd, 'volumes_from', '--volumes-from')
|
|
# TODO(sbaker): deprecate log_tag, implement log_driver, log_opt
|
|
if 'log_tag' in cconfig:
|
|
cmd.append('--log-opt=tag=%s' % cconfig['log_tag'])
|
|
self.string_arg(cconfig, cmd, 'cpu_shares', '--cpu-shares')
|
|
self.string_arg(cconfig, cmd, 'mem_limit', '--memory')
|
|
self.string_arg(cconfig, cmd, 'memswap_limit', '--memory-swap')
|
|
self.string_arg(cconfig, cmd, 'mem_swappiness', '--memory-swappiness')
|
|
self.list_or_string_arg(cconfig, cmd, 'security_opt', '--security-opt')
|
|
self.string_arg(cconfig, cmd, 'stop_signal', '--stop-signal')
|
|
self.string_arg(cconfig, cmd, 'hostname', '--hostname')
|
|
for extra_host in cconfig.get('extra_hosts', []):
|
|
if extra_host:
|
|
cmd.append('--add-host=%s' % extra_host)
|
|
if 'cpuset_cpus' in cconfig:
|
|
# 'all' is a special value to directly configure all CPUs
|
|
# that are available. Without specifying --cpuset-cpus, we'll
|
|
# let the container engine to figure out what CPUs are online.
|
|
# https://bugs.launchpad.net/tripleo/+bug/1868135
|
|
# https://bugzilla.redhat.com/show_bug.cgi?id=1813091
|
|
if cconfig['cpuset_cpus'] != 'all':
|
|
cmd.append('--cpuset-cpus=%s' % cconfig['cpuset_cpus'])
|
|
else:
|
|
cmd.append('--cpuset-cpus=%s' % common.get_cpus_allowed_list())
|
|
|
|
self.string_arg(cconfig, cmd,
|
|
'stop_grace_period', '--stop-timeout',
|
|
self.duration)
|
|
|
|
self.list_arg(cconfig, cmd, 'cap_add', '--cap-add')
|
|
self.list_arg(cconfig, cmd, 'cap_drop', '--cap-drop')
|
|
|
|
# TODO(sbaker): add missing compose v1 properties:
|
|
# cgroup_parent
|
|
# devices
|
|
# dns, dns_search
|
|
# entrypoint
|
|
# expose
|
|
# extra_hosts
|
|
# labels
|
|
# ports
|
|
# stop_signal
|
|
# volume_driver
|
|
# cpu_quota
|
|
# domainname
|
|
# hostname
|
|
# mac_address
|
|
# memory_reservation
|
|
# kernel_memory
|
|
# read_only
|
|
# shm_size
|
|
# stdin_open
|
|
# working_dir
|
|
|
|
cmd.append(cconfig.get('image', ''))
|
|
cmd.extend(self.command_argument(cconfig.get('command')))
|
|
|
|
return self.validate_volumes(cconfig.get('volumes', []))
|