Disable events persister per default

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

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',

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'],

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',

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: