 
 (defn ->ESDatabase [target]
   (map->ElasticSearchDatabase (select-keys (merge target (:db target))
-                                           [:host :port :index :migration-index])))
+                                           [:host :port :index :migration-index :cluster :native-port])))
 
 ;; ============================================================================
 ;; Joplin interface

;; ============================================================================
;; Ragtime interface

(defrecord ElasticSearchDatabase [host port index migration-index]
  Migratable
  (add-migration-id [db id]
    (es-add-migration-id (client db) (get-migration-index db) id))


(defn migrate-data-native
  ([es-client es-native-client old-index mapping-type new-index]
     (migrate-data-native es-client old-index mapping-type new-index identity))
  ([es-client es-native-client old-index mapping-type new-index trans-f]
     (dorun
      (->> (esnd/search es-native-client
