elastic_responses

A crate to handle parsing and handling Elasticsearch search results which provides convenient iterators to step through the results returned.

Example

Cargo.toml [dependencies] elastic_reqwest = "*" elastic_responses = "*"

Search

Query your Elasticsearch Cluster, then iterate through the results:

``rust // Send a request (omitted, seesamples/basic`, and read the response. let mut res = client.elasticreq(&params, SearchRequest::forindex("_all", body)).unwrap();

// Parse body to JSON let response = parse::>().fromreader(res.status().tou16(), res).unwrap();

// Use hits() or aggs() iterators // Hits for hit in response.hits() { println!("{:?}", hit); }

// Agregations for agg in response.aggs() { println!("{:?}", agg); } ```

Bulk

Bulk response operations are split by whether they succeeded or failed:

``rust // Send a request (omitted, seesamples/bulk`, and read the response. let mut res = client.elastic_req(&params, BulkRequest::new(body)).unwrap();

// Parse body to JSON let response = parse::().fromreader(res.status().tou16(), res).unwrap();

for op in response.into_iter() { match op { Ok(ok) => { // Do something with successful operations println!("ok: {:?}", op); }, Err(err) => { // Do something with failed operations println!("{:?}", op); } } } ```