Struct PipelineMetadata 

pub struct PipelineMetadata {
    pub data_source: DataSource,
    pub path_columns: Vec<String>,
    pub content_type: Option<String>,
    pub custom: Record,
}

Metadata that is valid for the whole PipelineData

Custom Metadata

The custom field allows commands and plugins to attach arbitrary metadata to pipeline data. To avoid key collisions, it is recommended to use namespaced keys with an underscore separator:

• "http_response" - HTTP response metadata (status, headers, etc.)
• "polars_schema" - DataFrame schema information
• "custom_plugin_field" - Plugin-specific metadata

This convention helps ensure different commands and plugins don’t overwrite each other’s metadata.

Fields

data_source: DataSource

path_columns: Vec<String>

content_type: Option<String>

custom: Record

Implementations

impl PipelineMetadata

pub fn with_data_source(self, data_source: DataSource) -> Self

pub fn with_path_columns(self, path_columns: Vec<String>) -> Self

pub fn with_content_type(self, content_type: Option<String>) -> Self

pub fn set_table_width_priority_columns<I, S>(&mut self, span: Span, columns: I)

where I: IntoIterator<Item = S>, S: AsRef<str>,

Set table width-priority columns in custom metadata.

This helper accepts plain strings to avoid manually constructing Value::list.

pub fn with_table_width_priority_columns<I, S>( self, span: Span, columns: I, ) -> Self

where I: IntoIterator<Item = S>, S: AsRef<str>,

Builder-style variant of PipelineMetadata::set_table_width_priority_columns.

pub fn for_collect(self) -> Option<Self>

Transform metadata for the collect operation.

After collecting a stream into a value, FilePath data sources are no longer meaningful and should be converted to None. If all metadata fields become empty after this transformation, returns None to avoid carrying around empty metadata.

Trait Implementations

impl Clone for PipelineMetadata

fn clone(&self) -> PipelineMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineMetadata

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

Formats the value using the given formatter.

impl Default for PipelineMetadata

fn default() -> PipelineMetadata

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PipelineMetadata

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for PipelineMetadata

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for PipelineMetadata

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PipelineMetadata