es-utils — lt.tokenmill/es-utils 0.2.3

actual-index-name clj

(actual-index-name es-host index-name)

as-input-stream clj

(as-input-stream index-config)

Given a path returns an input-stream

configure-index clj

(configure-index es-host {:keys [alias conf data] :as index-conf})

confs->host-index clj

(confs->host-index default-es-host es-index-confs)

create-index clj

(create-index es-host index-name index-config)

data->index-name clj

(data->index-name data-file)

delete-all-docs clj

(delete-all-docs es-host es-index-confs)

delete-docs! clj

(delete-docs! es-host indices)

Params:

• es-host: e.g. http://127.0.0.1:9200
• indices: a colection of index names e.g. ["index-1" "index-2"]

es-ready? clj

(es-ready? es-host)

exists? clj

(exists? es-host index-name)

export-docs-for-bulk-via-http clj

(export-docs-for-bulk-via-http es-host index-name query out-file)

Example: (export-docs-for-bulk "http://127.0.0.1:9200" "index" {:query {:match_all {}} :size 1000} "output.json")

import-test-data-to-es clj

(import-test-data-to-es es-host es-index-name input-file)

load-test-data clj

(load-test-data env default-es-host index-confs)

prepare-indices clj

(prepare-indices env es-host es-index-confs)

put-alias clj

(put-alias es-host index-name alias)

service-ready? clj

(service-ready? endpoint)

(service-ready? endpoint service-name)

(service-ready? endpoint service-name timeout-seconds)

(service-ready? endpoint service-name timeout-seconds acceptable-resp?)