GetFlushAllState()

Retrieves the state of an earlier flush-all operation.

pub async fn get_flush_all_state(&self, request: GetFlushAllStateRequest) -> Result<GetFlushAllStateResponse>

Request Syntax

let request = GetFlushAllStateRequest::builder()
    .flush_all_timestamp(flush_all_ts)
    .build()?;

REQUEST FIELDS:

• database_name: Option<String>

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

• flush_all_timestamp: u64

  Timestamp returned by an earlier FlushAll operation.

• channel_timestamps: HashMap<String, u64>

  Per-channel timestamps to query instead of the aggregate flush_all_timestamp.

RETURN TYPE:

Result

RETURNS:

A GetFlushAllStateResponse indicating whether all data has been flushed. Returns an Error if the operation fails.

GetFlushAllStateResponse
    is_flushed() // -> bool

METHODS:

• is_flushed() (bool) -

  Whether all data has been flushed.

Example

let request = GetFlushAllStateRequest::builder()
    .flush_all_timestamp(flush_all_ts)
    .build()?;
let resp = client.get_flush_all_state(request).await?;
assert!(resp.is_flushed());