pub struct ComponentConfig { /* private fields */ }Expand description
An opaque component section: { <type_tag>: { ...connector config... } }.
The framework never interprets the body — it records which component
type the section selects (kafka, clickhouse, memory, …) and hands
the raw YAML to that component’s factory, which deserializes it into its
own typed config via deserialize_into.
The nested-block shape (exactly one key) is what lets every typed struct
in the tree keep deny_unknown_fields — a flattened shape would disable
that check.
Implementations§
Source§impl ComponentConfig
impl ComponentConfig
Sourcepub fn deserialize_into<T: DeserializeOwned>(&self) -> Result<T, ConfigError>
pub fn deserialize_into<T: DeserializeOwned>(&self) -> Result<T, ConfigError>
Deserialize the opaque body into the component’s typed config.
Errors carry the full dotted path from the pipeline config root,
e.g. source.kafka.brokers: missing field \brokers``.
Sourcepub fn new(type_tag: impl Into<String>, raw: YamlValue) -> Self
pub fn new(type_tag: impl Into<String>, raw: YamlValue) -> Self
Build a component config programmatically (primarily for tests and
etl-test pipelines that skip YAML).
raw is the opaque connector body as a YamlValue
(an etl-core re-export of serde_yaml::Value — see its docs for the
dependency-policy exemption).
Trait Implementations§
Source§impl Clone for ComponentConfig
impl Clone for ComponentConfig
Source§fn clone(&self) -> ComponentConfig
fn clone(&self) -> ComponentConfig
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for ComponentConfig
impl Debug for ComponentConfig
Source§impl<'de> Deserialize<'de> for ComponentConfig
impl<'de> Deserialize<'de> for ComponentConfig
Source§fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
Source§impl PartialEq for ComponentConfig
impl PartialEq for ComponentConfig
Source§fn eq(&self, other: &ComponentConfig) -> bool
fn eq(&self, other: &ComponentConfig) -> bool
self and other values to be equal, and is used by ==.