async fn check_write_service_health(server_type: ServerType, connection: Connection) -> bool {
    let mut health = influxdb_iox_client::health::Client::new(connection);

    match health.check("influxdata.pbdata.v1.WriteService").await {
        Ok(true) => {
            info!("Write service {:?} is running", server_type);
            true
        }
        Ok(false) => {
            info!("Write service {:?} is not running", server_type);
            true
        }
        Err(e) => {
            info!("Write service {:?} not yet healthy: {:?}", server_type, e);
            false
        }
    }
}
/// checks write service health, returning false if the service should be checked again
checks write service health, returning false if the service should be checked again
checks write service health returning false if the service should be checked again
async fn check_write_service_health(server_type: ServerType, connection: Connection) -> bool {
    let mut health = influxdb_iox_client::health::Client::new(connection);
    match health.check("influxdata.pbdata.v1.WriteService").await {
        Ok(true) => {
            info!("Write service {:?} is running", server_type);
            true
        }
        Ok(false) => {
            info!("Write service {:?} is not running", server_type);
            true
        }
        Err(e) => {
            info!("Write service {:?} not yet healthy: {:?}", server_type, e);
            false
        }
    }
}
async fn check_write_service_health ( server_type : ServerType , connection : Connection ) -> bool { let mut health = influxdb_iox_client :: health :: Client :: new ( connection ) ; match health . check ( " " ) . await { Ok ( true ) => { info ! ( " " server_type ) ; true } Ok ( false ) => { info ! ( " " server_type ) ; true } Err ( e ) => { info ! ( " " server_type e ) ; false } } }
checks write service health, returning false if the service should be checked again
checks write service health returning false if the service should be checked again
server_type
ServerType
connection
Connection
server_type
ServerType
connection
Connection