Struct ConnectorMetadata 

pub struct ConnectorMetadata(/* private fields */);

Connector metadata attached to each input record.

Both the transport connector and the parser can add metadata attributes such as Kafka topic name or Avro schema id. These attributes are passed to the deserializer along with the actual record, which can use them to populate some of the table columns.

Implementations

impl ConnectorMetadata

pub fn new() -> Self

pub fn insert(&mut self, name: &str, value: Variant)

Trait Implementations

impl Clone for ConnectorMetadata

fn clone(&self) -> ConnectorMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectorMetadata

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

Formats the value using the given formatter.

impl Default for ConnectorMetadata

fn default() -> ConnectorMetadata

Returns the “default value” for a type.

impl Eq for ConnectorMetadata

impl From<BTreeMap<Variant, Variant>> for ConnectorMetadata

fn from(metadata: BTreeMap<Variant, Variant>) -> Self

Converts to this type from the input type.

impl From<ConnectorMetadata> for Variant

fn from(metadata: ConnectorMetadata) -> Self

Converts to this type from the input type.

impl PartialEq for ConnectorMetadata

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