/// 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_readable(res: &GetWriteInfoResponse) -> bool {
    res.kafka_partition_infos.iter().all(|info| {
        matches!(
            info.status(),
            KafkaPartitionStatus::Readable | KafkaPartitionStatus::Persisted
        )
    })
}
pub fn all_readable ( res : & GetWriteInfoResponse ) -> bool { res . kafka_partition_infos . iter ( ) . all ( | info | { matches ! ( info status ( ) KafkaPartitionStatus Readable 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