ba0ce71d1c
Compat is for compatibility; there are certain things that no longer need help because they're consistent across all OpenStack versions we support (really Queens+ at this point). Remove the compat.py code that supports this and stop using compat in import lines. Also removed some conditional importing that was happening outside of the compatibility layer - which shouldn't happen, but did in odd places. Change-Id: I913b184713a85b05ff97dcc14c9459025cb0c0e5
85 lines
2.8 KiB
Python
85 lines
2.8 KiB
Python
# Copyright (c) 2015 OpenStack Foundation
|
|
# All Rights Reserved.
|
|
#
|
|
# 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 neutron_lib.db import model_base
|
|
|
|
from neutron.objects import base
|
|
|
|
from oslo_versionedobjects import fields as obj_fields
|
|
|
|
import sqlalchemy as sa
|
|
|
|
|
|
class VppEtcdJournal(model_base.BASEV2):
|
|
"""Operations that have been committed to the DB but not implemented"""
|
|
__tablename__ = 'vpp_etcd_journal'
|
|
|
|
# NB(ijw): Note that the incremental nature of the autoincrement ID is used
|
|
# to determine the time order of commits.
|
|
id = sa.Column(sa.Integer,
|
|
primary_key=True,
|
|
autoincrement=True,
|
|
nullable=False)
|
|
k = sa.Column(sa.String(255), nullable=False) # key in etcd to change
|
|
v = sa.Column(sa.PickleType, nullable=True) # null == 'delete this key'
|
|
|
|
# These are stats; they're not essential to operation. Only retry_count
|
|
# is ever updated directly.
|
|
retry_count = sa.Column(sa.Integer, default=0, nullable=False)
|
|
created_at = sa.Column(sa.DateTime,
|
|
server_default=sa.func.now(),
|
|
nullable=False)
|
|
last_retried = sa.Column(sa.DateTime,
|
|
server_default=sa.func.now(),
|
|
onupdate=sa.func.now(),
|
|
nullable=False)
|
|
|
|
|
|
class VppRouterVrf(model_base.BASEV2):
|
|
"""Table to map vrf number to neutron routers."""
|
|
__tablename__ = 'vpp_router_vrfs'
|
|
|
|
router_id = sa.Column(sa.String(36), primary_key=True)
|
|
vrf_id = sa.Column(sa.Integer, nullable=False)
|
|
|
|
|
|
class GpeAllocationModel(model_base.BASEV2):
|
|
|
|
__tablename__ = 'vpp_gpe_allocations'
|
|
|
|
gpe_vni = sa.Column(sa.Integer, nullable=False, primary_key=True,
|
|
autoincrement=False)
|
|
allocated = sa.Column(sa.Boolean, nullable=False, default=False,
|
|
index=True)
|
|
|
|
|
|
# Required by Train and above
|
|
@base.NeutronObjectRegistry.register
|
|
class GpeAllocation(base.NeutronDbObject):
|
|
# Version 1.0: Initial version
|
|
VERSION = '1.0'
|
|
|
|
db_model = GpeAllocationModel
|
|
|
|
primary_keys = ['gpe_vni']
|
|
|
|
fields = {
|
|
'gpe_vni': obj_fields.IntegerField(),
|
|
'allocated': obj_fields.BooleanField(default=False),
|
|
}
|
|
|
|
network_type = 'gpe'
|