elastictea

Generic Fill Pour Ingredient crate for the rettle ETL.

Data Structures

• FillEsArg: Ingredient params for FillEsTea
• FillEsTea: Wrapper to simplifiy the creation of the Fill Ingredient to be used in the rettle Pot.
• PourEsArg: Ingredient params for PourEsTea
• PourEsTea: Wrapper to simplifiy the creation of the Pour Ingredient to be used in the rettle Pot.

Example

```rust

[derive(Serialize, Deserialize, Debug)]

struct ElasticTea { name: Option, avg: Option, }

impl Tea for ElasticTea { fn as_any(&self) -> &dyn Any { self } }

fn main() { let esclient = Arc::new(EsClient::new("http://localhost:9200")); let testfillesarg = FillEsArg::new( "test-index1", "doc", 200, json!({ "matchall": {} }), Arc::clone(&esclient), );

let test_pour_esarg = PourEsArg::new(
    "test-pour-index2",
    "_doc",
    Arc::clone(&es_client),
);



let brewery = Brewery::new(4, Instant::now());
let mut new_pot = Pot::new();
let fill_elastictea = FillEsTea::new::<ElasticTea>("elastic_tea_test", "test_index", test_fill_esarg);
let pour_elastictea = PourEsTea::new::<ElasticTea>("pour_elastic", test_pour_esarg);

new_pot = new_pot.add_source(fill_elastictea);

// Steep operations of choice

new_pot = new_pot.add_ingredient(pour_elastictea);

new_pot.brew(&brewery);

} ```