Struct connectorx::transports::PostgresArrow2Transport

source ·

pub struct PostgresArrow2Transport<P, C>(/* private fields */);

Expand description

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

process will ask source to produce a value with type T1, based on TSS, and then do type conversion using convert_type to get value with type T2, which is associated to TSD. Finally, it will write the value with type T2 to the destination.

source §

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

source §

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

convert_type convert the type T1 associated with the source type system TSS to a type T2 which is associated with the destination type system TSD.

source §

fn convert_typesystem(ts: Self::TSS) -> Result<Self::TSD>

convert_typesystem convert the source type system TSS to the destination type system TSD.

source §

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

process will ask source to produce a value with type T1, based on TSS, and then do type conversion using convert_type to get value with type T2, which is associated to TSD. Finally, it will write the value with type T2 to the destination.

source §

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

source §

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

convert_type convert the type T1 associated with the source type system TSS to a type T2 which is associated with the destination type system TSD.

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

process will ask source to produce a value with type T1, based on TSS, and then do type conversion using convert_type to get value with type T2, which is associated to TSD. Finally, it will write the value with type T2 to the destination.

source §

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

source §

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

convert_type convert the type T1 associated with the source type system TSS to a type T2 which is associated with the destination type system TSD.

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

process will ask source to produce a value with type T1, based on TSS, and then do type conversion using convert_type to get value with type T2, which is associated to TSD. Finally, it will write the value with type T2 to the destination.

source §

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

source §

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

convert_type convert the type T1 associated with the source type system TSS to a type T2 which is associated with the destination type system TSD.

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

process will ask source to produce a value with type T1, based on TSS, and then do type conversion using convert_type to get value with type T2, which is associated to TSD. Finally, it will write the value with type T2 to the destination.

source §

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

source §

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

convert_type convert the type T1 associated with the source type system TSS to a type T2 which is associated with the destination type system TSD.

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

process will ask source to produce a value with type T1, based on TSS, and then do type conversion using convert_type to get value with type T2, which is associated to TSD. Finally, it will write the value with type T2 to the destination.

source §

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

source §

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

convert_type convert the type T1 associated with the source type system TSS to a type T2 which is associated with the destination type system TSD.

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

process will ask source to produce a value with type T1, based on TSS, and then do type conversion using convert_type to get value with type T2, which is associated to TSD. Finally, it will write the value with type T2 to the destination.

source §

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

source §

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

convert_type convert the type T1 associated with the source type system TSS to a type T2 which is associated with the destination type system TSD.

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

process will ask source to produce a value with type T1, based on TSS, and then do type conversion using convert_type to get value with type T2, which is associated to TSD. Finally, it will write the value with type T2 to the destination.

source §

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

source §

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

convert_type convert the type T1 associated with the source type system TSS to a type T2 which is associated with the destination type system TSD.

Auto Trait Implementations§

§

impl<P, C> Freeze for PostgresArrow2Transport<P, C>

§

impl<P, C> RefUnwindSafe for PostgresArrow2Transport<P, C>
where P: RefUnwindSafe, C: RefUnwindSafe,

§

impl<P, C> Send for PostgresArrow2Transport<P, C>
where P: Send, C: Send,

§

§

fn subset( self, ) -> Result<CNil, <Choices as CoproductSubsetter<CNil, HNil>>::Remainder>

Extract a subset of the possible types in a coproduct (or get the remaining possibilities) Read more

§

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source §

impl<T> Same for T

source §

type Output = T

Should always be Self

§

impl<Source> Sculptor<HNil, HNil> for Source

§

type Remainder = Source

§

fn sculpt(self) -> (HNil, <Source as Sculptor<HNil, HNil>>::Remainder)

Consumes the current HList and returns an HList with the requested shape. Read more

§

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more

§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more

§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

§

Struct connectorx::transports::PostgresArrow2TransportCopy item path

Trait Implementations§

impl<'tp> Transport for PostgresArrow2Transport<BinaryProtocol, MakeTlsConnector>

type TSS = PostgresTypeSystem

type TSD = Arrow2TypeSystem

type S = PostgresSource<BinaryProtocol, MakeTlsConnector>

type D = Arrow2Destination

type Error = PostgresArrow2TransportError

fn convert_typesystem(ts: Self::TSS) -> Result<Self::TSD>

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2where Self: TypeConversion<T1, T2>,

impl<'tp> Transport for PostgresArrow2Transport<BinaryProtocol, NoTls>

type TSS = PostgresTypeSystem

type TSD = Arrow2TypeSystem

type S = PostgresSource<BinaryProtocol, NoTls>

type D = Arrow2Destination

type Error = PostgresArrow2TransportError

fn convert_typesystem(ts: Self::TSS) -> Result<Self::TSD>

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2where Self: TypeConversion<T1, T2>,

impl<'tp> Transport for PostgresArrow2Transport<CSVProtocol, MakeTlsConnector>

type TSS = PostgresTypeSystem

type TSD = Arrow2TypeSystem

type S = PostgresSource<CSVProtocol, MakeTlsConnector>

type D = Arrow2Destination

type Error = PostgresArrow2TransportError

fn convert_typesystem(ts: Self::TSS) -> Result<Self::TSD>

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2where Self: TypeConversion<T1, T2>,

impl<'tp> Transport for PostgresArrow2Transport<CSVProtocol, NoTls>

type TSS = PostgresTypeSystem

type TSD = Arrow2TypeSystem

type S = PostgresSource<CSVProtocol, NoTls>

type D = Arrow2Destination

type Error = PostgresArrow2TransportError

fn convert_typesystem(ts: Self::TSS) -> Result<Self::TSD>

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2where Self: TypeConversion<T1, T2>,

impl<'tp> Transport for PostgresArrow2Transport<CursorProtocol, MakeTlsConnector>

type TSS = PostgresTypeSystem

type TSD = Arrow2TypeSystem

type S = PostgresSource<CursorProtocol, MakeTlsConnector>

type D = Arrow2Destination

type Error = PostgresArrow2TransportError

fn convert_typesystem(ts: Self::TSS) -> Result<Self::TSD>

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2where Self: TypeConversion<T1, T2>,

impl<'tp> Transport for PostgresArrow2Transport<CursorProtocol, NoTls>

type TSS = PostgresTypeSystem

type TSD = Arrow2TypeSystem

type S = PostgresSource<CursorProtocol, NoTls>

type D = Arrow2Destination

type Error = PostgresArrow2TransportError

fn convert_typesystem(ts: Self::TSS) -> Result<Self::TSD>

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2where Self: TypeConversion<T1, T2>,

impl<'tp> Transport for PostgresArrow2Transport<SimpleProtocol, MakeTlsConnector>

type TSS = PostgresTypeSystem

type TSD = Arrow2TypeSystem

type S = PostgresSource<SimpleProtocol, MakeTlsConnector>

type D = Arrow2Destination

type Error = PostgresArrow2TransportError

fn convert_typesystem(ts: Self::TSS) -> Result<Self::TSD>

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2where Self: TypeConversion<T1, T2>,

impl<'tp> Transport for PostgresArrow2Transport<SimpleProtocol, NoTls>

type TSS = PostgresTypeSystem

type TSD = Arrow2TypeSystem

type S = PostgresSource<SimpleProtocol, NoTls>

type D = Arrow2Destination

type Error = PostgresArrow2TransportError

fn convert_typesystem(ts: Self::TSS) -> Result<Self::TSD>

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>where Self: 'd,

Struct connectorx::transports::PostgresArrow2Transport

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,

fn process<'s, 'd, 'r>( ts1: Self::TSS, ts2: Self::TSD, src: &'r mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &'r mut <Self::D as Destination>::Partition<'d>, ) -> Result<(), Self::Error>
where Self: 'd,

fn processor<'s, 'd>( ts1: Self::TSS, ts2: Self::TSD, ) -> Result<fn(src: &mut <<Self::S as Source>::Partition as SourcePartition>::Parser<'s>, dst: &mut <Self::D as Destination>::Partition<'d>) -> Result<(), Self::Error>>
where Self: 'd,

fn convert_type<T1, T2>(val: T1) -> T2
where Self: TypeConversion<T1, T2>,