Struct Bulker 

pub struct Bulker { /* private fields */ }

Bulker is a helper struct to make bulk requests to OpenSearch.

Implementations

impl Bulker

pub fn new( os_client: Arc<OsClient>, bulk_size: u32, max_concurrent_connections: u32, ) -> (JoinHandle<()>, Bulker)

Spawn an extraction service on a separate thread and return an extraction instance to interact with it

pub fn statistics(&self) -> BulkerStatistic

pub async fn index<T: Serialize>( &self, index: &str, body: &T, id: Option<String>, ) -> Result<(), Error>

Sends a bulk index request to OpenSearch with the specified index, id and document body.

Arguments

• index - A string slice that holds the name of the index.
• id - An optional string slice that holds the id of the document.
• body - A reference to a serializable document body.

Returns

Returns () on success, or an Error on failure.

pub async fn create<T: Serialize>( &self, index: &str, id: &str, body: &T, ) -> Result<(), Error>

Sends a bulk create request to the OpenSearch cluster with the specified index, id and body.

Arguments

• index - A string slice that holds the name of the index.
• id - A string slice that holds the id of the document.
• body - A generic type T that holds the body of the document to be created.

Returns

Returns () on success, or an Error on failure.

pub async fn delete<T: Serialize>( &self, index: &str, id: &str, ) -> Result<(), Error>

Sends a bulk delete request to the OpenSearch cluster with the specified index and id.

Arguments

• index - A string slice that holds the name of the index.
• id - A string slice that holds the id of the document.

Returns

Returns () on success, or an Error on failure.

pub async fn update( &self, index: &str, id: &str, body: &UpdateActionBody, ) -> Result<(), Error>

Asynchronously updates a document in bulk.

Arguments

• index - A string slice that holds the name of the index.
• id - A string slice that holds the ID of the document to update.
• body - An UpdateAction struct that holds the update action to perform.

Returns

Returns a Result containing a serde_json::Value on success, or an Error on failure.

pub async fn flush(&self)

Trait Implementations

impl Clone for Bulker

fn clone(&self) -> Bulker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Drop for Bulker

fn drop(&mut self)

Executes the destructor for this type.