pub async fn update_or_create<T: Serialize>( index: &str, id: &str, source: &T) -> Result<(), ElasticError>
