ongoing client progress

project.clj

@@ -6,4 +6,6 @@
 
   :main clj-druid.validations
   :dependencies [[org.clojure/clojure "1.6.0"]
-                 [prismatic/schema "0.2.6"]])
+                 [prismatic/schema "0.2.6"]
+                 [org.clojure/tools.logging "0.3.0"]
+                 [zookeeper-clj "0.9.1"]])

src/clj_druid/client.clj

@@ -0,0 +1,28 @@
+(ns clj-druid.client
+  (:require [zookeeper :as zk]
+            [clj-druid.schemas :as sch]
+            [clj-druid.validations :as v]
+            [clojure.tools.logging :as log]))
+
+
+(def zk-druid-node-path
+  "/druid/broker")
+
+(defn from-zookeeper
+  [config]
+
+  (let [zk-client (zk/connect (get config :zk-host))
+        zk-druid-data (if (zk/exists zk-client zk-druid-node-path)
+                      (zk/data zk-client zk-druid-node-path) nil)
+
+        zk-druid-nodes (:data zk-druid-data)]
+
+    zk-druid-nodes))
+
+(defn client
+  "Create a druid client"
+  [config]
+
+  (if-not (nil? (get config :zk-host)) (from-zookeeper config)))
+
+

test/clj_druid/client_test.clj

@@ -0,0 +1,8 @@
+(ns clj-druid.client-test
+  (:require [clojure.test :refer :all]
+            [clj-druid.client :refer :all]))
+
+
+(deftest test-connect
+  (println (client {:zk-host "127.0.0.1"})))
+