//! Send a bulk request.
//!
//! NOTE: This sample expects you have a node running on `localhost:9200`.
//!
//! This sample demonstrates a bulk request.
//! There are a few extra dials you can tweak on bulk requests to get more
//! performance out of them.
//! See the docs for `BulkResponse` for more details.

extern crate elastic;
extern crate env_logger;
#[macro_use]
extern crate serde_json;

use elastic::prelude::*;
use std::error::Error;

fn run() -> Result<(), Box<dyn Error>> {
    // A HTTP client and request parameters
    let client = SyncClient::builder().build()?;

    let ops = (0..1000).into_iter().map(|i| {
        bulk_raw()
            .index(json!({
                "id": i,
                "title": "some string value"
            }))
            .id(i)
    });

    // Execute a bulk request
    let bulk = client
        .bulk()
        .index("bulk_idx")
        .ty("bulk_ty")
        .extend(ops)
        .send()?;

    for op in bulk {
        match op {
            Ok(op) => println!("ok: {:?}", op),
            Err(op) => println!("err: {:?}", op),
        }
    }

    Ok(())
}

fn main() {
    env_logger::init();
    run().unwrap()
}