353 lines
13 KiB
Python
353 lines
13 KiB
Python
# Copyright 2014 Rackspace
|
|
#
|
|
# 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.
|
|
|
|
'''initial_create
|
|
|
|
Revision ID: 35dee79d5865
|
|
Revises: None
|
|
Create Date: 2014-08-15 11:01:14.897223
|
|
|
|
'''
|
|
|
|
# revision identifiers, used by Alembic.
|
|
revision = '35dee79d5865'
|
|
down_revision = None
|
|
|
|
from alembic import op
|
|
import sqlalchemy as sa
|
|
from sqlalchemy import sql
|
|
|
|
|
|
def upgrade():
|
|
# Create lookup tables
|
|
op.create_table(
|
|
u'health_monitor_type',
|
|
sa.Column(u'name', sa.String(30), primary_key=True),
|
|
sa.Column(u'description', sa.String(255), nullable=True)
|
|
)
|
|
|
|
# Create temporary table for table data seeding
|
|
insert_table = sql.table(
|
|
u'health_monitor_type',
|
|
sql.column(u'name', sa.String),
|
|
sql.column(u'description', sa.String)
|
|
)
|
|
|
|
op.bulk_insert(
|
|
insert_table,
|
|
[
|
|
{'name': 'HTTP'},
|
|
{'name': 'HTTPS'},
|
|
{'name': 'TCP'}
|
|
]
|
|
)
|
|
|
|
op.create_table(
|
|
u'protocol',
|
|
sa.Column(u'name', sa.String(30), primary_key=True),
|
|
sa.Column(u'description', sa.String(255), nullable=True)
|
|
)
|
|
|
|
insert_table = sql.table(
|
|
u'protocol',
|
|
sql.column(u'name', sa.String),
|
|
sql.column(u'description', sa.String)
|
|
)
|
|
|
|
op.bulk_insert(
|
|
insert_table,
|
|
[
|
|
{'name': 'HTTP'},
|
|
{'name': 'HTTPS'},
|
|
{'name': 'TCP'}
|
|
]
|
|
)
|
|
|
|
op.create_table(
|
|
u'algorithm',
|
|
sa.Column(u'name', sa.String(30), primary_key=True),
|
|
sa.Column(u'description', sa.String(255), nullable=True)
|
|
)
|
|
|
|
insert_table = sql.table(
|
|
u'algorithm',
|
|
sql.column(u'name', sa.String),
|
|
sql.column(u'description', sa.String)
|
|
)
|
|
|
|
op.bulk_insert(
|
|
insert_table,
|
|
[
|
|
{'name': 'ROUND_ROBIN'},
|
|
{'name': 'LEAST_CONNECTIONS'},
|
|
{'name': 'SOURCE_IP'}
|
|
]
|
|
)
|
|
|
|
op.create_table(
|
|
u'session_persistence_type',
|
|
sa.Column(u'name', sa.String(30), primary_key=True),
|
|
sa.Column(u'description', sa.String(255), nullable=True)
|
|
)
|
|
|
|
insert_table = sql.table(
|
|
u'session_persistence_type',
|
|
sql.column(u'name', sa.String),
|
|
sql.column(u'description', sa.String)
|
|
)
|
|
|
|
op.bulk_insert(
|
|
insert_table,
|
|
[
|
|
{'name': 'SOURCE_IP'},
|
|
{'name': 'HTTP_COOKIE'},
|
|
{'name': 'APP_COOKIE'}
|
|
]
|
|
)
|
|
|
|
op.create_table(
|
|
u'provisioning_status',
|
|
sa.Column(u'name', sa.String(30), primary_key=True),
|
|
sa.Column(u'description', sa.String(255), nullable=True)
|
|
)
|
|
|
|
insert_table = sql.table(
|
|
u'provisioning_status',
|
|
sql.column(u'name', sa.String),
|
|
sql.column(u'description', sa.String)
|
|
)
|
|
|
|
op.bulk_insert(
|
|
insert_table,
|
|
[
|
|
{'name': 'ACTIVE'},
|
|
{'name': 'PENDING_CREATE'},
|
|
{'name': 'PENDING_UPDATE'},
|
|
{'name': 'PENDING_DELETE'},
|
|
{'name': 'DELETED'},
|
|
{'name': 'ERROR'}
|
|
]
|
|
)
|
|
|
|
op.create_table(
|
|
u'operating_status',
|
|
sa.Column(u'name', sa.String(30), primary_key=True),
|
|
sa.Column(u'description', sa.String(255), nullable=True)
|
|
)
|
|
|
|
insert_table = sql.table(
|
|
u'operating_status',
|
|
sql.column(u'name', sa.String),
|
|
sql.column(u'description', sa.String)
|
|
)
|
|
|
|
op.bulk_insert(
|
|
insert_table,
|
|
[
|
|
{'name': 'ONLINE'},
|
|
{'name': 'OFFLINE'},
|
|
{'name': 'DEGRADED'},
|
|
{'name': 'ERROR'}
|
|
]
|
|
)
|
|
|
|
op.create_table(
|
|
u'pool',
|
|
sa.Column(u'tenant_id', sa.String(255), nullable=True),
|
|
sa.Column(u'id', sa.String(36), nullable=False),
|
|
sa.Column(u'name', sa.String(255), nullable=True),
|
|
sa.Column(u'description', sa.String(255), nullable=True),
|
|
sa.Column(u'protocol', sa.String(16), nullable=False),
|
|
sa.Column(u'lb_algorithm', sa.String(16), nullable=False),
|
|
sa.Column(u'operating_status', sa.String(16), nullable=False),
|
|
sa.Column(u'enabled', sa.Boolean(), nullable=False),
|
|
sa.PrimaryKeyConstraint(u'id'),
|
|
sa.ForeignKeyConstraint([u'protocol'],
|
|
[u'protocol.name'],
|
|
name=u'fk_pool_protocol_name'),
|
|
sa.ForeignKeyConstraint([u'lb_algorithm'],
|
|
[u'algorithm.name'],
|
|
name=u'fk_pool_algorithm_name'),
|
|
sa.ForeignKeyConstraint([u'operating_status'],
|
|
[u'operating_status.name'],
|
|
name=u'fk_pool_operating_status_name')
|
|
)
|
|
|
|
op.create_table(
|
|
u'health_monitor',
|
|
sa.Column(u'pool_id', sa.String(36), nullable=False),
|
|
sa.Column(u'type', sa.String(36), nullable=False),
|
|
sa.Column(u'delay', sa.Integer(), nullable=False),
|
|
sa.Column(u'timeout', sa.Integer(), nullable=False),
|
|
sa.Column(u'fall_threshold', sa.Integer(), nullable=False),
|
|
sa.Column(u'rise_threshold', sa.Integer(), nullable=False),
|
|
sa.Column(u'http_method', sa.String(16), nullable=True),
|
|
sa.Column(u'url_path', sa.String(255), nullable=True),
|
|
sa.Column(u'expected_codes', sa.String(64), nullable=True),
|
|
sa.Column(u'enabled', sa.Boolean(), nullable=False),
|
|
sa.PrimaryKeyConstraint(u'pool_id'),
|
|
sa.ForeignKeyConstraint([u'pool_id'], [u'pool.id'],
|
|
name=u'fk_health_monitor_pool_id'),
|
|
sa.ForeignKeyConstraint(
|
|
[u'type'], [u'health_monitor_type.name'],
|
|
name=u'fk_health_monitor_health_monitor_type_name')
|
|
)
|
|
|
|
op.create_table(
|
|
u'session_persistence',
|
|
sa.Column(u'pool_id', sa.String(36), nullable=False),
|
|
sa.Column(u'type', sa.String(16), nullable=False),
|
|
sa.Column(u'cookie_name', sa.String(255), nullable=True),
|
|
sa.ForeignKeyConstraint(
|
|
[u'type'], [u'session_persistence_type.name'],
|
|
name=u'fk_session_persistence_session_persistence_type_name'),
|
|
sa.ForeignKeyConstraint([u'pool_id'], [u'pool.id'],
|
|
name=u'fk_session_persistence_pool_id'),
|
|
sa.PrimaryKeyConstraint(u'pool_id')
|
|
)
|
|
|
|
op.create_table(
|
|
u'member',
|
|
sa.Column(u'tenant_id', sa.String(255), nullable=True),
|
|
sa.Column(u'id', sa.String(36), nullable=False),
|
|
sa.Column(u'pool_id', sa.String(36), nullable=False),
|
|
sa.Column(u'subnet_id', sa.String(36), nullable=True),
|
|
sa.Column(u'address', sa.String(64), nullable=False),
|
|
sa.Column(u'protocol_port', sa.Integer(), nullable=False),
|
|
sa.Column(u'weight', sa.Integer(), nullable=True),
|
|
sa.Column(u'operating_status', sa.String(16), nullable=False),
|
|
sa.Column(u'enabled', sa.Boolean(), nullable=False),
|
|
sa.PrimaryKeyConstraint(u'id'),
|
|
sa.ForeignKeyConstraint([u'pool_id'], [u'pool.id'],
|
|
name=u'fk_member_pool_id'),
|
|
sa.ForeignKeyConstraint([u'operating_status'],
|
|
[u'operating_status.name'],
|
|
name=u'fk_member_operating_status_name'),
|
|
sa.UniqueConstraint(u'pool_id', u'address', u'protocol_port',
|
|
name=u'uq_member_pool_id_address_protocol_port')
|
|
)
|
|
|
|
op.create_table(
|
|
u'load_balancer',
|
|
sa.Column(u'tenant_id', sa.String(255), nullable=True),
|
|
sa.Column(u'id', sa.String(36), nullable=False),
|
|
sa.Column(u'name', sa.String(255), nullable=True),
|
|
sa.Column(u'description', sa.String(255), nullable=True),
|
|
sa.Column(u'provisioning_status', sa.String(16), nullable=False),
|
|
sa.Column(u'operating_status', sa.String(16), nullable=False),
|
|
sa.Column(u'enabled', sa.Boolean(), nullable=False),
|
|
sa.PrimaryKeyConstraint(u'id'),
|
|
sa.ForeignKeyConstraint(
|
|
[u'provisioning_status'], [u'provisioning_status.name'],
|
|
name=u'fk_load_balancer_provisioning_status_name'),
|
|
sa.ForeignKeyConstraint([u'operating_status'],
|
|
[u'operating_status.name'],
|
|
name=u'fk_load_balancer_operating_status_name')
|
|
)
|
|
|
|
op.create_table(
|
|
u'vip',
|
|
sa.Column(u'load_balancer_id', sa.String(36), nullable=False),
|
|
sa.Column(u'ip_address', sa.String(36), nullable=True),
|
|
sa.Column(u'net_port_id', sa.String(36), nullable=True),
|
|
sa.Column(u'subnet_id', sa.String(36), nullable=True),
|
|
sa.Column(u'floating_ip_id', sa.String(36), nullable=True),
|
|
sa.Column(u'floating_ip_network_id', sa.String(36), nullable=True),
|
|
sa.PrimaryKeyConstraint(u'load_balancer_id'),
|
|
sa.ForeignKeyConstraint([u'load_balancer_id'], [u'load_balancer.id'],
|
|
name=u'fk_vip_load_balancer_id')
|
|
)
|
|
|
|
op.create_table(
|
|
u'listener',
|
|
sa.Column(u'tenant_id', sa.String(255), nullable=True),
|
|
sa.Column(u'id', sa.String(36), nullable=False),
|
|
sa.Column(u'name', sa.String(255), nullable=True),
|
|
sa.Column(u'description', sa.String(255), nullable=True),
|
|
sa.Column(u'protocol', sa.String(16), nullable=False),
|
|
sa.Column(u'protocol_port', sa.Integer(), nullable=False),
|
|
sa.Column(u'connection_limit', sa.Integer(), nullable=True),
|
|
sa.Column(u'load_balancer_id', sa.String(36), nullable=True),
|
|
sa.Column(u'tls_certificate_id', sa.String(36), nullable=True),
|
|
sa.Column(u'default_pool_id', sa.String(36), nullable=True),
|
|
sa.Column(u'provisioning_status', sa.String(16), nullable=False),
|
|
sa.Column(u'operating_status', sa.String(16), nullable=False),
|
|
sa.Column(u'enabled', sa.Boolean(), nullable=False),
|
|
sa.ForeignKeyConstraint([u'load_balancer_id'], [u'load_balancer.id'],
|
|
name=u'fk_listener_load_balancer_id'),
|
|
sa.ForeignKeyConstraint([u'default_pool_id'], [u'pool.id'],
|
|
name=u'fk_listener_pool_id'),
|
|
sa.ForeignKeyConstraint([u'protocol'], [u'protocol.name'],
|
|
name=u'fk_listener_protocol_name'),
|
|
sa.ForeignKeyConstraint([u'provisioning_status'],
|
|
[u'provisioning_status.name'],
|
|
name=u'fk_listener_provisioning_status_name'),
|
|
sa.ForeignKeyConstraint([u'operating_status'],
|
|
[u'operating_status.name'],
|
|
name=u'fk_listener_operating_status_name'),
|
|
sa.UniqueConstraint(u'default_pool_id',
|
|
name=u'uq_listener_default_pool_id'),
|
|
sa.UniqueConstraint(
|
|
u'load_balancer_id', u'protocol_port',
|
|
name=u'uq_listener_load_balancer_id_protocol_port'),
|
|
sa.PrimaryKeyConstraint(u'id')
|
|
)
|
|
|
|
op.create_table(
|
|
u'sni',
|
|
sa.Column(u'listener_id', sa.String(36), nullable=False),
|
|
sa.Column(u'tls_container_id', sa.String(36), nullable=False),
|
|
sa.Column(u'position', sa.Integer, nullable=True),
|
|
sa.ForeignKeyConstraint([u'listener_id'], [u'listener.id'],
|
|
name=u'fk_sni_listener_id'),
|
|
sa.PrimaryKeyConstraint(u'listener_id', u'tls_container_id')
|
|
)
|
|
|
|
op.create_table(
|
|
u'listener_statistics',
|
|
sa.Column(u'listener_id', sa.String(36), nullable=False),
|
|
sa.Column(u'bytes_in', sa.BigInteger(), nullable=False),
|
|
sa.Column(u'bytes_out', sa.BigInteger(), nullable=False),
|
|
sa.Column(u'active_connections', sa.Integer(), nullable=False),
|
|
sa.Column(u'total_connections', sa.BigInteger(), nullable=False),
|
|
sa.PrimaryKeyConstraint(u'listener_id'),
|
|
sa.ForeignKeyConstraint([u'listener_id'], [u'listener.id'],
|
|
name=u'fk_listener_statistics_listener_id')
|
|
)
|
|
|
|
op.create_table(
|
|
u'amphora',
|
|
# id should come from the service providing the amphora (i.e. nova)
|
|
sa.Column(u'id', sa.String(36), nullable=False, autoincrement=False),
|
|
sa.Column(u'host_id', sa.String(36), nullable=False),
|
|
sa.Column(u'status', sa.String(36), nullable=False),
|
|
sa.PrimaryKeyConstraint(u'id'),
|
|
sa.ForeignKeyConstraint(
|
|
[u'status'], [u'provisioning_status.name'],
|
|
name=u'fk_container_provisioning_status_name')
|
|
)
|
|
|
|
op.create_table(
|
|
u'load_balancer_amphora',
|
|
sa.Column(u'amphora_id', sa.String(36), nullable=False),
|
|
sa.Column(u'load_balancer_id', sa.String(36), nullable=False),
|
|
sa.ForeignKeyConstraint(
|
|
[u'load_balancer_id'], [u'load_balancer.id'],
|
|
name=u'fk_load_balancer_amphora_load_balancer_id'),
|
|
sa.ForeignKeyConstraint([u'amphora_id'],
|
|
[u'amphora.id'],
|
|
name=u'fk_load_balancer_amphora_id'),
|
|
sa.PrimaryKeyConstraint(u'amphora_id', u'load_balancer_id')
|
|
)
|