Index

A

api (kafka_connect_watcher.cluster.ConnectCluster property)

AutoCorrectRule (class in kafka_connect_watcher.error_rules)

C

cluster (kafka_connect_watcher.cluster.ConnectCluster property) Config (class in kafka_connect_watcher.config)

config (kafka_connect_watcher.config.Config property) config_key (kafka_connect_watcher.error_rules.EvaluationRule attribute) ConnectCluster (class in kafka_connect_watcher.cluster)

D

definition (kafka_connect_watcher.aws_sns.SnsChannel property) (kafka_connect_watcher.notifications.Notifications property)

E

emf_high_resolution() (kafka_connect_watcher.cluster.ConnectCluster method) EmfConfig (class in kafka_connect_watcher.config) evaluate_connector_status() (in module kafka_connect_watcher.connectors_eval)

EvaluationRule (class in kafka_connect_watcher.error_rules) execute() (kafka_connect_watcher.error_rules.EvaluationRule method) exit_gracefully() (kafka_connect_watcher.watcher.Watcher method)

F

filter_out_connector() (kafka_connect_watcher.error_rules.EvaluationRule method)

H

handle_watcher_emf() (in module kafka_connect_watcher.aws_emf)

hostname (kafka_connect_watcher.cluster.ConnectCluster property)

I

import_jinja2_templates() (kafka_connect_watcher.aws_sns.SnsChannel method)

import_regexes() (in module kafka_connect_watcher.tools) init_emf_config() (in module kafka_connect_watcher.aws_emf)

K

kafka_connect_watcher module kafka_connect_watcher.aws_emf module kafka_connect_watcher.aws_sns module kafka_connect_watcher.cli module kafka_connect_watcher.cluster module kafka_connect_watcher.config module kafka_connect_watcher.connectors_eval module

kafka_connect_watcher.error_rules module kafka_connect_watcher.logger module kafka_connect_watcher.notifications module kafka_connect_watcher.threads_settings module kafka_connect_watcher.tools module kafka_connect_watcher.watcher module

M

map_notify_targets() (kafka_connect_watcher.error_rules.AutoCorrectRule method) messages_templates (kafka_connect_watcher.aws_sns.SnsChannel property) module kafka_connect_watcher kafka_connect_watcher.aws_emf kafka_connect_watcher.aws_sns kafka_connect_watcher.cli kafka_connect_watcher.cluster kafka_connect_watcher.config kafka_connect_watcher.connectors_eval kafka_connect_watcher.error_rules kafka_connect_watcher.logger kafka_connect_watcher.notifications kafka_connect_watcher.threads_settings kafka_connect_watcher.tools kafka_connect_watcher.watcher

N

name (kafka_connect_watcher.cluster.ConnectCluster property)

Notifications (class in kafka_connect_watcher.notifications)

O

original_config (kafka_connect_watcher.config.Config property) (kafka_connect_watcher.error_rules.AutoCorrectRule property) (kafka_connect_watcher.error_rules.EvaluationRule property)

P

port (kafka_connect_watcher.cluster.ConnectCluster property) process() (kafka_connect_watcher.error_rules.AutoCorrectRule method) process_cluster() (in module kafka_connect_watcher.watcher) process_error_rules() (in module kafka_connect_watcher.watcher)

publish() (kafka_connect_watcher.aws_sns.SnsChannel method) publish_cluster_metrics() (in module kafka_connect_watcher.aws_emf) publish_clusters_emf() (in module kafka_connect_watcher.aws_emf) publish_connector_metrics() (in module kafka_connect_watcher.aws_emf) publish_watcher_emf_metrics() (in module kafka_connect_watcher.aws_emf)

R

render_message_template() (kafka_connect_watcher.aws_sns.SnsChannel static method)

run() (kafka_connect_watcher.watcher.Watcher method)

S

send_error_notification() (kafka_connect_watcher.aws_sns.SnsChannel method) session (kafka_connect_watcher.aws_sns.SnsChannel property) set_scan_intervals() (kafka_connect_watcher.config.Config method)

setup_logging() (in module kafka_connect_watcher.logger) SnsChannel (class in kafka_connect_watcher.aws_sns) start_watcher() (in module kafka_connect_watcher.cli)

W

Watcher (class in kafka_connect_watcher.watcher)