diff --git a/router/src/dml_handlers/rpc_write.rs b/router/src/dml_handlers/rpc_write.rs index b955d82bb3..0f8cab87df 100644 --- a/router/src/dml_handlers/rpc_write.rs +++ b/router/src/dml_handlers/rpc_write.rs @@ -68,16 +68,16 @@ pub enum RpcWriteError { /// /// [gRPC write service]: client::WriteClient #[derive(Debug)] -pub struct RpcWrite { - endpoints: Balancer, +pub struct RpcWrite { + endpoints: Balancer, } -impl RpcWrite { +impl RpcWrite { /// Initialise a new [`RpcWrite`] that sends requests to an arbitrary /// downstream Ingester, using a round-robin strategy. - pub fn new(endpoints: impl IntoIterator, metrics: &metric::Registry) -> Self + pub fn new(endpoints: impl IntoIterator, metrics: &metric::Registry) -> Self where - C: Send + Sync + Debug + 'static, + T: Send + Sync + Debug + 'static, N: Into>, { Self { @@ -92,9 +92,9 @@ impl RpcWrite { } #[async_trait] -impl DmlHandler for RpcWrite +impl DmlHandler for RpcWrite where - C: WriteClient + 'static, + T: WriteClient + 'static, { type WriteInput = Partitioned>; type WriteOutput = Vec;