kafka_connect_watcher

• kafka_connect_watcher package
  • Subpackages
    • kafka_connect_watcher.aws_sns package
      • Module contents
  • Submodules
  • kafka_connect_watcher.aws_emf module
    • handle_watcher_emf()
    • init_emf_config()
    • publish_cluster_metrics()
    • publish_clusters_emf()
    • publish_connector_metrics()
    • publish_watcher_emf_metrics()
  • kafka_connect_watcher.cli module
    • start_watcher()
  • kafka_connect_watcher.cluster module
    • ConnectCluster
      • ConnectCluster.api
      • ConnectCluster.cluster
      • ConnectCluster.emf_high_resolution()
      • ConnectCluster.hostname
      • ConnectCluster.name
      • ConnectCluster.port
  • kafka_connect_watcher.config module
    • Config
      • Config.config
      • Config.original_config
      • Config.set_scan_intervals()
    • EmfConfig
  • kafka_connect_watcher.connectors_eval module
    • evaluate_connector_status()
  • kafka_connect_watcher.error_rules module
    • AutoCorrectRule
      • AutoCorrectRule.map_notify_targets()
      • AutoCorrectRule.original_config
      • AutoCorrectRule.process()
    • EvaluationRule
      • EvaluationRule.config_key
      • EvaluationRule.execute()
      • EvaluationRule.filter_out_connector()
      • EvaluationRule.original_config
  • kafka_connect_watcher.logger module
    • setup_logging()
  • kafka_connect_watcher.notifications module
    • Notifications
      • Notifications.definition
  • kafka_connect_watcher.threads_settings module
  • kafka_connect_watcher.tools module
    • import_regexes()
  • kafka_connect_watcher.watcher module
    • Watcher
      • Watcher.exit_gracefully()
      • Watcher.run()
    • process_cluster()
    • process_error_rules()
  • Module contents