Trait Produce

Source

pub trait Produce<'r, T> {
    type Error: From<ConnectorXError> + Send;

    // Required method
    fn produce(&'r mut self) -> Result<T, Self::Error>;
}

Expand description

A type implemented Produce<T> means that it can produce a value T by consuming part of it’s raw data buffer.

Required Associated Types§

Source

type Error: From<ConnectorXError> + Send

The error returned when the next value cannot be produced as T.

Required Methods§

Source

fn produce(&'r mut self) -> Result<T, Self::Error>

Produce the next value from the buffer as T and advance past it.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

impl<'r> Produce<'r, f32> for MsSQLSourceParser

f32 needs a hand-written impl (rather than the generic macro) to accept TdsCell::F64 as well: a genuinely non-nullable smallmoney column (fixed Money4 wire type) maps to the SmallMoney/f32 destination, but its value is decoded and stored here as a full-precision TdsCell::F64 (see column_value_to_cell), so it must be narrowed on the way out.

impl<'r> Produce<'r, u8> for MsSQLSourceParser

Source §

type Error = MsSQLSourceError

Source §

impl<'r> Produce<'r, u32> for PostgresSimpleSourceParser

Source §

Produce

Trait Produce Copy item path

Required Associated Types§

type Error: From<ConnectorXError> + Send

Required Methods§

fn produce(&'r mut self) -> Result<T, Self::Error>

Dyn Compatibility§

Implementors§

impl Produce<'_, DateTime<Utc>> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, HashMap<String, Option<String>>> for PostgresBinarySourcePartitionParser<'_>

type Error = PostgresSourceError

impl Produce<'_, NaiveDate> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, NaiveDateTime> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, NaiveTime> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, Option<DateTime<Utc>>> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, Option<HashMap<String, Option<String>>>> for PostgresBinarySourcePartitionParser<'_>

type Error = PostgresSourceError

impl Produce<'_, Option<NaiveDate>> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, Option<NaiveDateTime>> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, Option<NaiveTime>> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, Option<Vec<Option<bool>>>> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, Option<bool>> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, Vec<Option<bool>>> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl Produce<'_, bool> for PostgresCSVSourceParser<'_>

type Error = PostgresSourceError

impl<'a, 'r> Produce<'r, Option<String>> for CSVSourcePartitionParser<'a>

type Error = CSVSourceError

impl<'r, 'a> Produce<'r, &'r str> for PostgresBinarySourcePartitionParser<'a>

type Error = PostgresSourceError

impl<'r, 'a> Produce<'r, &'r str> for PostgresRawSourceParser<'a>

type Error = PostgresSourceError

impl<'r, 'a> Produce<'r, Bit> for PostgresBinarySourcePartitionParser<'a>

type Error = PostgresSourceError

impl<'r, 'a> Produce<'r, Bit> for PostgresRawSourceParser<'a>

type Error = PostgresSourceError

impl<'r, 'a> Produce<'r, Box<str>> for SQLiteSourcePartitionParser<'a>

type Error = SQLiteSourceError

impl<'r, 'a> Produce<'r, DateTime<Utc>> for CSVSourcePartitionParser<'a>

type Error = CSVSourceError

impl<'r, 'a> Produce<'r, DateTime<Utc>> for ClickHouseSourceParser<'a>

type Error = ClickHouseSourceError

impl<'r, 'a> Produce<'r, DateTime<Utc>> for DummySourcePartitionParser<'a>

type Error = ConnectorXError

impl<'r, 'a> Produce<'r, DateTime<Utc>> for OracleTextSourceParser<'a>

type Error = OracleSourceError

impl<'r, 'a> Produce<'r, Decimal> for ClickHouseSourceParser<'a>

type Error = ClickHouseSourceError

impl<'r, 'a> Produce<'r, Decimal> for MySQLBinarySourceParser<'a>

type Error = MySQLSourceError

impl<'r, 'a> Produce<'r, Decimal> for MySQLTextSourceParser<'a>

type Error = MySQLSourceError

impl<'r, 'a> Produce<'r, Decimal> for OracleTextSourceParser<'a>

type Error = OracleSourceError

impl<'r, 'a> Produce<'r, Decimal> for PostgresBinarySourcePartitionParser<'a>

type Error = PostgresSourceError

impl<'r, 'a> Produce<'r, Decimal> for PostgresRawSourceParser<'a>

type Error = PostgresSourceError

impl<'r, 'a> Produce<'r, HalfVector> for PostgresBinarySourcePartitionParser<'a>

type Error = PostgresSourceError

impl<'r, 'a> Produce<'r, HalfVector> for PostgresRawSourceParser<'a>

type Error = PostgresSourceError

impl<'r, 'a> Produce<'r, HashMap<String, Option<String>>> for PostgresRawSourceParser<'a>

type Error = PostgresSourceError

impl<'r, 'a> Produce<'r, IpAddr> for ClickHouseSourceParser<'a>

type Error = ClickHouseSourceError

impl<'r, 'a> Produce<'r, IpInet> for PostgresBinarySourcePartitionParser<'a>

type Error = PostgresSourceError

impl<'r, 'a> Produce<'r, IpInet> for PostgresCSVSourceParser<'a>

type Error = PostgresSourceError

Trait Produce