Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
MEMORY: properties.Schema(
properties.Schema.INTEGER,
_('The container memory size in MiB.'),
update_allowed=True
),
ENVIRONMENT: properties.Schema(
properties.Schema.MAP,
_('The environment variables.'),
),
WORKDIR: properties.Schema(
properties.Schema.STRING,
_('The working directory for commands to run in.'),
),
LABELS: properties.Schema(
properties.Schema.MAP,
_('Adds a map of labels to a container. '
'May be used multiple times.'),
),
IMAGE_PULL_POLICY: properties.Schema(
properties.Schema.STRING,
_('The policy which determines if the image should '
'be pulled prior to starting the container.'),
constraints=[
constraints.AllowedValues(['ifnotpresent', 'always',
'never']),
]
),
RESTART_POLICY: properties.Schema(
properties.Schema.STRING,
_('Restart policy to apply when a container exits. Possible '
'values are "no", "on-failure[:max-retry]", "always", and '
'"unless-stopped".'),
constraints=[
constraints.CustomConstraint('cinder.snapshot')
]
),
BACKUP_ID: properties.Schema(
properties.Schema.STRING,
_('If specified, the backup to create the volume from.')
),
NAME: properties.Schema(
properties.Schema.STRING,
_('A name used to distinguish the volume.'),
update_allowed=True,
),
DESCRIPTION: properties.Schema(
properties.Schema.STRING,
_('A description of the volume.'),
update_allowed=True,
),
VOLUME_TYPE: properties.Schema(
properties.Schema.STRING,
_('If specified, the type of volume to use, mapping to a '
'specific backend.')
),
METADATA: properties.Schema(
properties.Schema.MAP,
_('Key/value pairs to associate with the volume.'),
update_allowed=True,
),
IMAGE_REF: properties.Schema(
properties.Schema.STRING,
_('The ID of the image to create the volume from.'),
support_status=support.SupportStatus(
def validate_with_client(self, client, value):
senlin_client = client.client(CLIENT_NAME)
type_list = senlin_client.profile_types()
names = [pt.name for pt in type_list]
if value not in names:
not_found_message = (
_("Unable to find senlin profile type '%(pt)s', "
"available profile types are %(pts)s.") %
{'pt': value, 'pts': names}
)
raise exception.StackValidationFailed(message=not_found_message)
class HeatServiceHealthCheck(contrail.ContrailResource):
PROPERTIES = (
NAME, SERVICE_INSTANCE, SERVICE_PORT_TAG, MONITOR_TYPE,
DELAY, TIMEOUT, MAX_RETRIES, HTTP_METHOD, URL_PATH,
EXPECTED_CODES, ENABLED
) = (
'name', 'service_instance', 'service_port_tag', 'monitor_type',
'delay', 'timeout', 'max_retries', 'http_method', 'url_path',
'expected_codes', 'enabled'
)
properties_schema = {
NAME: properties.Schema(
properties.Schema.STRING,
_('Service health check name.'),
required=True,
update_allowed=False
),
SERVICE_INSTANCE: properties.Schema(
properties.Schema.STRING,
_('Service instance name.'),
required=True,
update_allowed=False
),
SERVICE_PORT_TAG: properties.Schema(
properties.Schema.STRING,
_('Service port tag.'),
required=True,
update_allowed=False
),
MONITOR_TYPE: properties.Schema(
message=_('Supported versions: keystone v3'))
default_client_name = 'keystone'
entity = 'roles'
PROPERTIES = (
NAME, DOMAIN,
) = (
'name', 'domain',
)
properties_schema = {
NAME: properties.Schema(
properties.Schema.STRING,
_('Name of keystone role.'),
update_allowed=True
),
DOMAIN: properties.Schema(
properties.Schema.STRING,
_('Name or id of keystone domain.'),
default='default',
constraints=[constraints.CustomConstraint('keystone.domain')],
support_status=support.SupportStatus(version='10.0.0')
)
}
def translation_rules(self, properties):
return [
translation.TranslationRule(
properties,
translation.TranslationRule.RESOLVE,
version = get_version(template_data, available_versions)
version_type = version[0]
try:
return _template_classes[version]
except KeyError:
av_list = sorted(
[v for k, v in available_versions if k == version_type])
msg_data = {'version': ': '.join(version),
'version_type': version_type,
'available': ', '.join(v for v in av_list)}
if len(av_list) > 1:
explanation = _('"%(version)s". "%(version_type)s" '
'should be one of: %(available)s') % msg_data
else:
explanation = _('"%(version)s". "%(version_type)s" '
'should be: %(available)s') % msg_data
raise exception.InvalidTemplateVersion(explanation=explanation)
CANONICAL_HOSTED_ZONE_NAME: attributes.Schema(
_("The name of the hosted zone that is associated with the "
"LoadBalancer."),
type=attributes.Schema.STRING
),
CANONICAL_HOSTED_ZONE_NAME_ID: attributes.Schema(
_("The ID of the hosted zone name that is associated with the "
"LoadBalancer."),
type=attributes.Schema.STRING
),
DNS_NAME: attributes.Schema(
_("The DNS name for the LoadBalancer."),
type=attributes.Schema.STRING
),
SOURCE_SECURITY_GROUP_GROUP_NAME: attributes.Schema(
_("The security group that you can use as part of your inbound "
"rules for your LoadBalancer's back-end instances."),
type=attributes.Schema.STRING
),
SOURCE_SECURITY_GROUP_OWNER_ALIAS: attributes.Schema(
_("Owner of the source security group."),
type=attributes.Schema.STRING
),
}
def _haproxy_config_global(self):
return '''
global
daemon
maxconn 256
stats socket /tmp/.haproxy-stats
ENCRYPTED_ATTR, ATTACHMENTS,
) = (
'availability_zone', 'size', 'snapshot_id', 'display_name',
'display_description', 'volume_type', 'metadata',
'source_volid', 'status', 'created_at', 'bootable', 'metadata_values',
'encrypted', 'attachments',
)
properties_schema = {
AVAILABILITY_ZONE: properties.Schema(
properties.Schema.STRING,
_('The availability zone in which the volume will be created.')
),
SIZE: properties.Schema(
properties.Schema.INTEGER,
_('The size of the volume in GB. '
'On update only increase in size is supported.'),
update_allowed=True,
constraints=[
constraints.Range(min=1),
]
),
SNAPSHOT_ID: properties.Schema(
properties.Schema.STRING,
_('If specified, the snapshot to create the volume from.'),
constraints=[
constraints.CustomConstraint('cinder.snapshot')
]
),
BACKUP_ID: properties.Schema(
properties.Schema.STRING,
_('If specified, the backup to create the volume from.')
properties.Schema.STRING,
_('Bus of the device: hypervisor driver chooses a '
'suitable default if omitted.'),
constraints=[
constraints.AllowedValues(['ide', 'lame_bus',
'scsi', 'usb',
'virtio']),
],
),
BLOCK_DEVICE_MAPPING_BOOT_INDEX: properties.Schema(
properties.Schema.INTEGER,
_('Integer used for ordering the boot disks.'),
),
BLOCK_DEVICE_MAPPING_VOLUME_SIZE: properties.Schema(
properties.Schema.INTEGER,
_('Size of the block device in GB. If it is omitted, '
'hypervisor driver calculates size.'),
),
BLOCK_DEVICE_MAPPING_DELETE_ON_TERM: properties.Schema(
properties.Schema.BOOLEAN,
_('Indicate whether the volume should be deleted '
'when the server is terminated.')
),
},
),
support_status=support.SupportStatus(version='2015.1')
),
FLAVOR: properties.Schema(
properties.Schema.STRING,
_('The ID or name of the flavor to boot onto.'),
required=True,
update_allowed=True,
stack_id = getattr(stack_identifier, 'stack_id', '')
stack_name = getattr(stack_identifier, 'stack_name', '')
tenant = getattr(stack_identifier, 'tenant', '')
yield parameters.Parameter(
self.PARAM_STACK_ID,
parameters.Schema(parameters.Schema.STRING, _('Stack ID'),
default=str(stack_id)))
yield parameters.Parameter(
self.PARAM_PROJECT_ID,
parameters.Schema(parameters.Schema.STRING, _('Project ID'),
default=str(tenant)))
if stack_name:
yield parameters.Parameter(
self.PARAM_STACK_NAME,
parameters.Schema(parameters.Schema.STRING, _('Stack Name'),
default=stack_name))