From 68f948c70b7275ff6b3828f358d0fc7c2f62ce96 Mon Sep 17 00:00:00 2001 From: Dom Dwyer Date: Thu, 23 Mar 2023 14:31:03 +0100 Subject: [PATCH] refactor: rename generic type parameter Rename C -> T, to be consistent with the Balancer, and open up C for consistent usage between the two. --- router/src/dml_handlers/rpc_write.rs | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) 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;