     [clojure.tools.cli      :as   cli   ]
     [clojure.tools.logging  :as   log   ]
     [clojure.edn            :as   edn   ]
+    [cheshire.core          :as   ches  ]
     [clojure.core.async     :refer 
       [alts! chan go thread timeout 
        >! >!! <! <!! go-loop]           ]

        json-key        (get-in config [:ok :json-keys (keyword bucket-type)])
        _               (log/debug (str "json-key: " json-key))
        lines           (lazy-lines (:file options))
        ;;              mem leak?
        jsons           (map json/read-str lines)
        ;;              mem leak?
        riak-cluster    (riak-connect2! 
                          (get-in config [:ok :env env :conn-string]))
        _               (.start riak-cluster)

;; limitations under the License.

(ns ^{  :doc "Loading data into Riak"
        :author "Istvan Szukacs"  }
  riak-loader.core
  (:require 
    [clojure.java.io        :as   io    ]
