json

sidekick.py

@@ -30,6 +30,7 @@
 import time
 import socket
 import sys
+import json
 
 from docker import Client
 from docker.utils import kwargs_from_env
@@ -97,9 +98,9 @@ def announce_services( services, etcd_folder, etcd_client, timeout , ttl, vulcan
                     etcd_client.delete( frontend )
                 else:
                     # Announce this server to ETCD
-                    etcd_client.write( backend, {"Type": value['type']})
-                    etcd_client.write( server, {"URL": "http://{0!s}:{1!s}".format(value['ip'], value['port'])})
-                    etcd_client.write( frontend, {"Type": value['type'], "BackendId": key, "Route": "Host(`{0}`)".format(value['domain'])})
+                    etcd_client.write( backend, json.dumps({"Type": value['type']}), ttl=ttl)
+                    etcd_client.write( server, json.dumps({"URL": "http://{0!s}:{1!s}".format(value['ip'], value['port'])}), ttl=ttl)
+                    etcd_client.write( frontend, json.dumps({"Type": value['type'], "BackendId": key, "Route": "Host(`{0}`)".format(value['domain'])}), ttl=ttl)
             except etcd.EtcdException as e:
                 logging.error( e )