openstack/monasca-persister
Code Issues Proposed changes

Disable events persister per default

Browse Source 
This change fixes devstack installation which attempts to import
Elasticsearch persister repository.

More intuitive options to control loading of repositories are
introduced:

* kafka_metrics.enabled - default=True
* kafka_alarm_history.enabled - default=True
* kafka_events.enabled - default=False

Change-Id: I78707386f2080f37746f9598ba28f738832d9c86
Story: 2001285
Task: 5833
This commit is contained in:
Witold Bedyk 2017-11-13 11:04:48 +01:00
parent 15203e008b
commit 08126715c9
4 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
monasca_persister/conf/kafka_alarm_history.py
View File

@ -24,6 +24,9 @@ from monasca_persister.conf import types
kafka_alarm_history_group = cfg.OptGroup(name='kafka_alarm_history',
title='kafka_alarm_history')
kafka_alarm_history_opts = [
cfg.BoolOpt('enabled',
help='Enable alarm state history persister',
default=True),
# NOTE(czarneckia) default by reference does not work with ListOpt
cfg.ListOpt('uri',
help='Comma separated list of Kafka broker host:port',

3
monasca_persister/conf/kafka_events.py
View File

@ -23,6 +23,9 @@ from monasca_persister.conf import types
kafka_events_group = cfg.OptGroup(name='kafka_events',
title='kafka_events')
kafka_events_opts = [
cfg.BoolOpt('enabled',
help='Enable event persister',
default=False),
cfg.ListOpt('uri',
help='Comma separated list of Kafka broker host:port',
default=['127.0.0.1:9092'],

3
monasca_persister/conf/kafka_metrics.py
View File

@ -24,6 +24,9 @@ from monasca_persister.conf import types
kafka_metrics_group = cfg.OptGroup(name='kafka_metrics',
title='kafka_metrics')
kafka_metrics_opts = [
cfg.BoolOpt('enabled',
help='Enable metrics persister',
default=True),
# NOTE(czarneckia) default by reference does not work with ListOpt
cfg.ListOpt('uri',
help='Comma separated list of Kafka broker host:port',

12
monasca_persister/persister.py
View File

@ -108,11 +108,17 @@ def main():
config.parse_args()
# Add processors for metrics topic
prepare_processes(cfg.CONF.kafka_metrics, cfg.CONF.repositories.metrics_driver)
if cfg.CONF.kafka_metrics.enabled:
prepare_processes(cfg.CONF.kafka_metrics,
cfg.CONF.repositories.metrics_driver)
# Add processors for alarm history topic
prepare_processes(cfg.CONF.kafka_alarm_history, cfg.CONF.repositories.alarm_state_history_driver)
if cfg.CONF.kafka_alarm_history.enabled:
prepare_processes(cfg.CONF.kafka_alarm_history,
cfg.CONF.repositories.alarm_state_history_driver)
# Add processors for events topic
prepare_processes(cfg.CONF.kafka_events, cfg.CONF.repositories.events_driver)
if cfg.CONF.kafka_events.enabled:
prepare_processes(cfg.CONF.kafka_events,
cfg.CONF.repositories.events_driver)
# Start
try: