elastic_reqwest 0.20.10

A lightweight implementation of the Elasticsearch API based on reqwest.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

//! Elasticsearch Reqwest Client Samples
//!
//! This sample assumes you have a node running on `localhost`.
//!
//! This sample demonstrates a request with a large body.

extern crate elastic_reqwest;

use elastic_reqwest::{Error, SyncElasticClient, SyncFromResponse};
use elastic_reqwest::req::BulkRequest;
use elastic_reqwest::res::{parse, BulkResponse};

// Create a bulk request to index a bunch of docs.
fn get_req() -> String {
    let mut bulk = String::new();
    for i in 1..1000 {
        let header = format!(
            "{{ \"index\" : {{ \"_index\" : \"test\", \"_type\" : \"ty\", \"_id\" : \"{}\" }} }}",
            i
        );
        let body = format!("{{ \"title\" : \"string value {}\" }}", i);

        bulk.push_str(&header);
        bulk.push('\n');
        bulk.push_str(&body);
        bulk.push('\n');
    }

    bulk
}

fn run() -> Result<(), Error> {
    // Get a new default client.
    let (client, params) = elastic_reqwest::sync::default()?;

    // Send the bulk request.
    let http_res = client.elastic_req(&params, BulkRequest::new(get_req()))?;

    let res = parse::<BulkResponse>().from_response(http_res)?;

    println!("{:?}", res);

    Ok(())
}

fn main() {
    run().unwrap();
}