From 8b38dbd2b55733a6f6bc7fc897538b7987d8c115 Mon Sep 17 00:00:00 2001
From: Alexander Kukushkin <alexander.kukushkin@zalando.de>
Date: Tue, 12 May 2015 13:48:06 +0200
Subject: [PATCH] Put governor code into class and implement sigterm processing
 handler

---
 governor.py | 99 ++++++++++++++++++++++++++++++-----------------------
 1 file changed, 57 insertions(+), 42 deletions(-)

diff --git a/governor.py b/governor.py
index b3b2061f..cafc79b3 100755
--- a/governor.py
+++ b/governor.py
@@ -1,7 +1,8 @@
 #!/usr/bin/env python
 
-import atexit
 import logging
+import os
+import signal
 import sys
 import time
 import yaml
@@ -11,50 +12,64 @@ from helpers.postgresql import Postgresql
 from helpers.ha import Ha
 
 
-logging.basicConfig(format='%(asctime)s %(levelname)s: %(message)s', level=logging.INFO)
-
-f = open(sys.argv[1], "r")
-config = yaml.load(f.read())
-f.close()
-
-etcd = Etcd(config["etcd"])
-postgresql = Postgresql(config["postgresql"])
-ha = Ha(postgresql, etcd)
-
-# stop postgresql on script exit
+def sigterm_handler(signo, stack_frame):
+    sys.exit()
 
 
-def stop_postgresql():
-    postgresql.stop()
-atexit.register(stop_postgresql)
+class Governor:
 
-# wait for etcd to be available
-while not etcd.touch_member(postgresql.name, postgresql.connection_string):
-    logging.info("waiting on etcd")
-    time.sleep(5)
+    def __init__(self, config):
+        self.nap_time = config['loop_wait']
+        self.etcd = Etcd(config['etcd'])
+        self.postgresql = Postgresql(config['postgresql'])
+        self.ha = Ha(self.postgresql, self.etcd)
 
-# is data directory empty?
-if postgresql.data_directory_empty():
-    # racing to initialize
-    if etcd.race("/initialize", postgresql.name):
-        postgresql.initialize()
-        etcd.take_leader(postgresql.name)
-        postgresql.start()
-        postgresql.create_replication_user()
-    else:
-        synced_from_leader = False
-        while not synced_from_leader:
-            leader = etcd.current_leader()
-            if not leader:
-                time.sleep(5)
-                continue
-            if postgresql.sync_from_leader(leader):
-                postgresql.write_recovery_conf(leader)
-                postgresql.start()
-                synced_from_leader = True
+    def initialize(self):
+        # wait for etcd to be available
+        while not self.etcd.touch_member(self.postgresql.name, self.postgresql.connection_string):
+            logging.info('waiting on etcd')
+            time.sleep(5)
+
+        # is data directory empty?
+        if self.postgresql.data_directory_empty():
+            # racing to initialize
+            if self.etcd.race('/initialize', self.postgresql.name):
+                self.postgresql.initialize()
+                self.etcd.take_leader(self.postgresql.name)
+                self.postgresql.start()
+                self.postgresql.create_replication_user()
             else:
-                time.sleep(5)
+                while True:
+                    leader = self.etcd.current_leader()
+                    if leader and self.postgresql.sync_from_leader(leader):
+                        self.postgresql.write_recovery_conf(leader)
+                        self.postgresql.start()
+                        break
+                    time.sleep(5)
 
-while True:
-    logging.info(ha.run_cycle())
-    time.sleep(config["loop_wait"])
+    def run(self):
+        while True:
+            logging.info(self.ha.run_cycle())
+            time.sleep(self.nap_time)
+
+
+def main():
+    if len(sys.argv) < 2 or not os.path.isfile(sys.argv[1]):
+        print('Usage: {} config.yml'.format(sys.argv[0]))
+        return
+
+    with open(sys.argv[1], 'r') as f:
+        config = yaml.load(f)
+
+    governor = Governor(config)
+    try:
+        governor.initialize()
+        governor.run()
+    finally:
+        governor.postgresql.stop()
+
+
+if __name__ == '__main__':
+    logging.basicConfig(format='%(asctime)s %(levelname)s: %(message)s', level=logging.INFO)
+    signal.signal(signal.SIGTERM, sigterm_handler)
+    main()