/// Create a connection channel to the specified gRPC endpoint
Create a connection channel to the specified gRPC endpoint
Create a connection channel to the specified gRPC endpoint
async fn grpc_channel(
    test_config: &TestConfig,
    client_base: &str,
) -> influxdb_iox_client::connection::Result<Connection> {
    let builder = influxdb_iox_client::connection::Builder::default();
    info!("Creating gRPC channel to {}", client_base);
    test_config
        .client_headers()
        .iter()
        .fold(builder, |builder, (header_name, header_value)| {
            builder.header(header_name, header_value)
        })
        .build(client_base)
        .await
}
async fn grpc_channel ( test_config : & TestConfig , client_base : & str , ) -> influxdb_iox_client :: connection :: Result < Connection > { let builder = influxdb_iox_client :: connection :: Builder :: default ( ) ; info ! ( " " client_base ) ; test_config . client_headers ( ) . iter ( ) . fold ( builder , | builder , ( header_name , header_value ) | { builder . header ( header_name , header_value ) } ) . build ( client_base ) . await }
Create a connection channel to the specified gRPC endpoint
Create a connection channel to the specified gRPC endpoint
test_config
&TestConfig
client_base
&str