Struct ComponentConfig 

pub struct ComponentConfig { /* private fields */ }

An opaque component section: { <type_tag>: { ...connector config... } }.

The framework records which component type the section selects (kafka, clickhouse, memory, …) and hands the body to that component’s factory, which deserializes it into its own typed config via deserialize_into. chunk is framework-reserved and is the one exception to that opacity. It configures the chain terminal, not the connector, and is peeled out of the body at construction. A connector must not declare its own chunk field; it would never receive a value (on a sink section the framework consumes the key, and on a source/deserializer section the key is rejected outright).

The nested-block shape (exactly one key) lets every typed struct in the tree keep deny_unknown_fields. A flattened shape would disable that check.

Implementations

impl ComponentConfig

pub fn type_tag(&self) -> &str

Which component implementation this section selects.

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``.

pub fn new(type_tag: impl Into<String>, raw: YamlValue) -> Self

Build a component config programmatically (primarily for tests and spate-test pipelines that skip YAML).

raw is the opaque connector body as a YamlValue (an spate-core re-export of serde_yaml::Value; see its docs for the dependency-policy exemption). The framework-reserved chunk key is peeled out of raw here, as on the YAML path. See the struct docs.

Trait Implementations

impl Clone for ComponentConfig

fn clone(&self) -> ComponentConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ComponentConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ComponentConfig

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ComponentConfig

fn eq(&self, other: &ComponentConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ComponentConfig