pub fn all_persisted(res: &GetWriteInfoResponse) -> bool {
    res.kafka_partition_infos
        .iter()
        .all(|info| matches!(info.status(), KafkaPartitionStatus::Persisted))
}
/// returns true if all partitions in the response are readablel
/// TODO: maybe put this in the influxdb_iox_client library / make a
/// proper public facing client API. For now, iterate in the end to end tests.
returns true if all partitions in the response are readablel
TODO: maybe put this in the influxdb_iox_client library / make a
proper public facing client API. For now, iterate in the end to end tests.
returns true if all partitions in the response are readablel TODO : maybe put this in the influxdb_iox_client library / make a proper public facing client API . For now iterate in the end to end tests .
pub fn all_persisted(res: &GetWriteInfoResponse) -> bool {
    res.kafka_partition_infos
        .iter()
        .all(|info| matches!(info.status(), KafkaPartitionStatus::Persisted))
}
pub fn all_persisted ( res : & GetWriteInfoResponse ) -> bool { res . kafka_partition_infos . iter ( ) . all ( | info | matches ! ( info status ( ) KafkaPartitionStatus Persisted ) ) }
returns true if all partitions in the response are readablel
TODO: maybe put this in the influxdb_iox_client library / make a
proper public facing client API.
returns true if all partitions in the response are readablel TODO : maybe put this in the influxdb_iox_client library / make a proper public facing client API .
res
&GetWriteInfoResponse
res
&GetWriteInfoResponse