kafka_overwatch package

Subpackages

Submodules

kafka_overwatch.overwatch module

class kafka_overwatch.overwatch. KafkaOverwatchService ( config ) [source]

Bases: object

Main service which starts the prometheus server and the processes for each Kafka cluster to be processed independently.

Upon receiving SIGTERM or SIGINT, it will send a SIGTERM to all child processes

The prometheus dependency is imported at the last minute to make sure it will take the multiprocess folder env var into account.

property config : OverwatchConfig
init_prometheus ( ) [source]

Import prometheus_client.start_http_server at the latest point to make sure the multiprocess folder env var is taken into account.

static multi_clusters_processing ( clusters_jobs , sr_jobs , httpd ) [source]
start ( ) [source]
kafka_overwatch.overwatch. handle_signals ( pid , frame , stop_flag ) [source]

Module contents