Move eventlet using commands into own directory
The api server does not need and should not use eventlet since it is now using a multi-process capable web server from Werkzeug so is kept above the eventlet directory where eventlet overriding happens. Partially-Implements: blueprint remove-web-eventlet Change-Id: I377a105a5e53c3c548354877cac477609bf06b63
This commit is contained in:
64
ceilometer/cmd/eventlet/storage.py
Normal file
64
ceilometer/cmd/eventlet/storage.py
Normal file
@@ -0,0 +1,64 @@
|
||||
# -*- encoding: utf-8 -*-
|
||||
#
|
||||
# Copyright 2014 OpenStack Foundation
|
||||
#
|
||||
# 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.
|
||||
|
||||
import logging
|
||||
|
||||
from oslo_config import cfg
|
||||
|
||||
from ceilometer.i18n import _, _LI
|
||||
from ceilometer import service
|
||||
from ceilometer import storage
|
||||
|
||||
|
||||
LOG = logging.getLogger(__name__)
|
||||
|
||||
|
||||
def dbsync():
|
||||
service.prepare_service()
|
||||
storage.get_connection_from_config(cfg.CONF, 'metering').upgrade()
|
||||
storage.get_connection_from_config(cfg.CONF, 'alarm').upgrade()
|
||||
storage.get_connection_from_config(cfg.CONF, 'event').upgrade()
|
||||
|
||||
|
||||
def expirer():
|
||||
service.prepare_service()
|
||||
|
||||
if cfg.CONF.database.metering_time_to_live > 0:
|
||||
LOG.debug(_("Clearing expired metering data"))
|
||||
storage_conn = storage.get_connection_from_config(cfg.CONF, 'metering')
|
||||
storage_conn.clear_expired_metering_data(
|
||||
cfg.CONF.database.metering_time_to_live)
|
||||
else:
|
||||
LOG.info(_LI("Nothing to clean, database metering time to live "
|
||||
"is disabled"))
|
||||
|
||||
if cfg.CONF.database.event_time_to_live > 0:
|
||||
LOG.debug(_("Clearing expired event data"))
|
||||
event_conn = storage.get_connection_from_config(cfg.CONF, 'event')
|
||||
event_conn.clear_expired_event_data(
|
||||
cfg.CONF.database.event_time_to_live)
|
||||
else:
|
||||
LOG.info(_LI("Nothing to clean, database event time to live "
|
||||
"is disabled"))
|
||||
|
||||
if cfg.CONF.database.alarm_history_time_to_live > 0:
|
||||
LOG.debug("Clearing expired alarm history data")
|
||||
storage_conn = storage.get_connection_from_config(cfg.CONF, 'alarm')
|
||||
storage_conn.clear_expired_alarm_history_data(
|
||||
cfg.CONF.database.alarm_history_time_to_live)
|
||||
else:
|
||||
LOG.info(_LI("Nothing to clean, database alarm history time to live "
|
||||
"is disabled"))
|
||||
Reference in New Issue
Block a user