FlushAll()

Flushes pending insert data for all collections into durable storage.

pub async fn flush_all(&self, request: FlushAllRequest) -> Result<FlushAllResponse>

Request Syntax

let request = FlushAllRequest::builder()
    .build()?;

REQUEST FIELDS:

• database_name: Option<String>

  Name of the target database; uses the default database when empty.

• wait_flushed_ms: i64

  Maximum time to wait for the cluster-wide flush to complete. Zero waits indefinitely; negative values are invalid.

RETURNS:

Result

FlushAllResponse exposes flush_all_timestamp() returning the timestamp identifying the flush-all operation, usable with GetFlushAllState. Returns an Error on failure.

Example

let request = FlushAllRequest::builder()
    .wait_flushed_ms(60_000)
    .build()?;
let resp = client.flush_all(request).await?;
println!("flush_all_ts: {}", resp.flush_all_timestamp());