Enum 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)

👎Deprecated: will be made private

Setup state of the worker. This typically means waiting on the TLS handshake.

This approach is needed because Exasol will issue connections sequentially and thus perform TLS handshakes the same way.

Therefore we accommodate the worker state until the query gets executed and data gets sent through the workers, which happens within consumer code.

Reading(ExaExportReader)

👎Deprecated: will be made private

The worker is fully connected and ready for I/O.

Trait Implementations

impl AsyncRead for ExaExport

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<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.