foo.diff

commit 51e6c792da5e56723faa78d032ce610b3c3e266c
Author: shikhar <shikhar@schmizz.net>
Date:   Mon Jun 2 09:57:48 2014 +0530

    missing client param

diff --git a/elasticsearch/src/jepsen/system/elasticsearch.clj b/elasticsearch/src/jepsen/system/elasticsearch.clj
index 2eb53d6..107ddc0 100644
--- a/elasticsearch/src/jepsen/system/elasticsearch.clj
+++ b/elasticsearch/src/jepsen/system/elasticsearch.clj
@@ -141,9 +141,9 @@
                 (Thread/sleep (* 200 1000))
                 (c/on-many (:nodes test) (wait 200 :green))
                 (info "Recovered; flushing index before read")
-                (esi/flush index-name)
+                (esi/flush client index-name)
                 (assoc op :type :ok
-                       :value (->> (all-results index-name "number")
+                       :value (->> (all-results client index-name "number")
                                    (map (comp :num :_source))
                                    (into (sorted-set))))
                 (catch RuntimeException e
@@ -165,7 +165,7 @@
           client (es/connect (str "http://" (name node) ":9200"))]
         ; Create index
       (try
-        (esi/create index-name
+        (esi/create client index-name
                     :mappings {mapping-type {:properties {}}})
         (catch clojure.lang.ExceptionInfo e
             ; Is this seriously how you're supposed to do idempotent