Enum sqlx_exasol::etl::ExaExport

pub enum ExaExport {
    Setup(BoxFuture<'static, Result<ExaSocket>>, bool),
    Reading(ExaExportReader),
}

An ETL EXPORT worker.

The type implements AsyncRead and is Send and Sync so it can be freely used in any data pipeline.

IMPORTANT

Dropping a reader before it returned EOF will result in the EXPORT query returning an error. While not necessarily a problem if you’re not interested in the whole export, there’s no way to circumvent that other than handling the error in code.

Variants

Setup(BoxFuture<'static, Result<ExaSocket>>, bool)

Reading(ExaExportReader)

Trait Implementations

impl AsyncRead for ExaExport

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8] ) -> Poll<IoResult<usize>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>] ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl Debug for ExaExport

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

Formats the value using the given formatter.

impl<'pin> Unpin for ExaExport

where __ExaExport<'pin>: Unpin,