diff --git a/dt-common/src/config/sinker_config.rs b/dt-common/src/config/sinker_config.rs index df25b637..f187a010 100644 --- a/dt-common/src/config/sinker_config.rs +++ b/dt-common/src/config/sinker_config.rs @@ -143,7 +143,7 @@ pub enum SinkerConfig { }, } -#[derive(Clone, Debug, Default, Hash)] +#[derive(Clone, Debug, Hash)] pub struct BasicSinkerConfig { pub sink_type: SinkType, pub db_type: DbType, @@ -153,3 +153,17 @@ pub struct BasicSinkerConfig { pub max_connections: u32, pub rate_limiter: RateLimiterConfig, } + +impl Default for BasicSinkerConfig { + fn default() -> Self { + Self { + sink_type: SinkType::default(), + db_type: DbType::default(), + url: String::new(), + connection_auth: ConnectionAuthConfig::default(), + batch_size: 0, + max_connections: 10, + rate_limiter: RateLimiterConfig::default(), + } + } +}