pub async fn write_to_router_grpc(
    table_batches: Vec<TableBatch>,
    namespace: impl Into<String>,
    router_connection: Connection,
) -> tonic::Response<WriteResponse> {
    let request = WriteRequest {
        database_batch: Some(DatabaseBatch {
            database_name: namespace.into(),
            table_batches,
        }),
    };

    influxdb_iox_client::write::Client::new(router_connection)
        .write_pb(request)
        .await
        .expect("grpc error sending write")
}
/// Writes the table batch to the gRPC write API on the router into the org/bucket (typically on
/// the router)
Writes the table batch to the gRPC write API on the router into the org/bucket (typically on
the router)
Writes the table batch to the gRPC write API on the router into the org / bucket ( typically on the router )
pub async fn write_to_router_grpc(
    table_batches: Vec<TableBatch>,
    namespace: impl Into<String>,
    router_connection: Connection,
) -> tonic::Response<WriteResponse> {
    let request = WriteRequest {
        database_batch: Some(DatabaseBatch {
            database_name: namespace.into(),
            table_batches,
        }),
    };
    influxdb_iox_client::write::Client::new(router_connection)
        .write_pb(request)
        .await
        .expect("grpc error sending write")
}
pub async fn write_to_router_grpc ( table_batches : Vec < TableBatch > , namespace : impl Into < String > , router_connection : Connection , ) -> tonic :: Response < WriteResponse > { let request = WriteRequest { database_batch : Some ( DatabaseBatch { database_name : namespace . into ( ) , table_batches , } ) , } ; influxdb_iox_client :: write :: Client :: new ( router_connection ) . write_pb ( request ) . await . expect ( " " ) }
Writes the table batch to the gRPC write API on the router into the org/bucket (typically on
the router)
Writes the table batch to the gRPC write API on the router into the org / bucket ( typically on the router )
table_batches
Vec<TableBatch>
namespace
impl Into<String>
router_connection
Connection
table_batches
Vec<TableBatch>
namespace
impl Into<String>
router_connection
Connection