Struct DestinationMetadata 

pub struct DestinationMetadata {
    pub name: String,
    pub destination_type: String,
    pub supports_transactions: bool,
    pub max_batch_size: Option<usize>,
    pub supports_concurrent_writes: bool,
    pub properties: HashMap<String, String>,
}

Metadata about a destination’s capabilities.

This allows runtime introspection of destination features and is used for:

• Feature detection and capability negotiation
• Monitoring and observability
• Dynamic pipeline configuration

Fields

name: String

Human-readable destination name (e.g., “S3”, “BigQuery”, “Kafka”)

destination_type: String

Destination type identifier (e.g., “s3”, “bigquery”, “kafka”)

supports_transactions: bool

Whether the destination supports transactions

max_batch_size: Option<usize>

Maximum batch size hint (None = no limit)

supports_concurrent_writes: bool

Whether the destination supports concurrent writes

properties: HashMap<String, String>

Additional destination-specific metadata

Implementations

impl DestinationMetadata

pub fn new(name: impl Into<String>, destination_type: impl Into<String>) -> Self

Creates new metadata with required fields.

pub const fn with_transactions(self, supports: bool) -> Self

Sets transaction support.

pub const fn with_max_batch_size(self, size: usize) -> Self

Sets maximum batch size.

pub const fn with_concurrent_writes(self, supports: bool) -> Self

Sets concurrent write support.

pub fn with_property( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Adds a custom property.

Trait Implementations

impl Clone for DestinationMetadata

fn clone(&self) -> DestinationMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DestinationMetadata

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

Formats the value using the given formatter.

impl PartialEq for DestinationMetadata

fn eq(&self, other: &DestinationMetadata) -> 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 Eq for DestinationMetadata

impl StructuralPartialEq for DestinationMetadata