Struct PipelineMetadata 

pub struct PipelineMetadata {
    pub data_source: DataSource,
    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

content_type: Option<String>

custom: Record

Implementations

impl PipelineMetadata

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

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

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