Increase verbosity of logging messages (#2)

governor.py

@@ -7,8 +7,9 @@
 from helpers.postgresql import Postgresql
 from helpers.ha import Ha
 
+LOG_LEVEL = logging.DEBUG if os.getenv('DEBUG', None) else logging.INFO
 
-logging.basicConfig(format='%(asctime)s %(levelname)s: %(message)s', level=logging.INFO)
+logging.basicConfig(format='%(asctime)s %(levelname)s: %(message)s', level=LOG_LEVEL)
 
 # load passed config file, or default
 config_file = 'postgres0.yml'
@@ -25,6 +26,9 @@
 if os.getenv('GOVERNOR_POSTGRESQL_NAME'):
     config['postgresql']['name'] = os.getenv('GOVERNOR_POSTGRESQL_NAME')
 
+if os.getenv('GOVERNOR_POSTGRESQL_CONNECT'):
+    config['postgresql']['connect'] = os.getenv('GOVERNOR_POSTGRESQL_CONNECT')
+
 if os.getenv('GOVERNOR_POSTGRESQL_LISTEN'):
     config['postgresql']['listen'] = os.getenv('GOVERNOR_POSTGRESQL_LISTEN')
 
@@ -60,13 +64,15 @@ def stop_postgresql():
     logging.info("Governor Starting up: Empty Data Dir")
     # racing to initialize
     if etcd.race("/initialize", postgresql.name):
+        logging.info("Governor Starting up: Initialisation Race ... WON!!!")
         logging.info("Governor Starting up: Initialise Postgres")
         postgresql.initialize()
         logging.info("Governor Starting up: Initialise Complete")
         etcd.take_leader(postgresql.name)
         logging.info("Governor Starting up: Starting Postgres")
         postgresql.start()
     else:
+        logging.info("Governor Starting up: Initialisation Race ... LOST")
         logging.info("Governor Starting up: Sync Postgres from Leader")
         synced_from_leader = False
         while not synced_from_leader:
@@ -90,10 +96,11 @@ def stop_postgresql():
 
 logging.info("Governor Running: Starting Running Loop")
 while True:
-    logging.info(ha.run_cycle())
+    logging.info("Governor Running: %s" % ha.run_cycle())
 
     # create replication slots
     if postgresql.is_leader():
+        logging.info("Governor Running: I am the Leader")
         for member in etcd.members():
             member =  member['hostname']
             if member != postgresql.name:

helpers/ha.py

@@ -40,6 +40,7 @@ def run_cycle(self):
         try:
             if self.state_handler.is_healthy():
                 if self.is_unlocked():
+                    logging.info("Leader is unlocked - starting election")
                     if self.state_handler.is_healthiest_node(self.etcd):
                         if self.acquire_lock():
                             if not self.state_handler.is_leader():