            [com.datastax.driver.core.policies
             LoadBalancingPolicy DCAwareRoundRobinPolicy RoundRobinPolicy TokenAwarePolicy
             LoggingRetryPolicy DefaultRetryPolicy DowngradingConsistencyRetryPolicy FallthroughRetryPolicy
-            RetryPolicy ConstantReconnectionPolicy ExponentialReconnectionPolicy
-            ]))
+            RetryPolicy ConstantReconnectionPolicy ExponentialReconnectionPolicy]))
 
 (def ^:dynamic *default-cluster*)
 (def ^:dynamic *default-session*)


(defn get-hosts
  "Returns all hosts for connected cluster"
  [^Session client]
  (map (fn [^Host host]
         {:datacenter (.getDatacenter host)
          :address    (.getHostAddress (.getAddress host))
          :rack       (.getRack host)})
       (-> client
           (.getCluster)
           (.getMetadata)
           (.getAllHosts))))


;; defn get-replicas
;; defn get-cluster-name


(defn connect!
  "Connects and sets *default-cluster* and *default-session* for default cluster and session, that
   cql/execute is going to use."
  [hosts & {:as options}]
  (let [cluster (-> (Cluster/builder)
                    (copt/set-cluster-options! (assoc options :contact-points hosts))
