Struct ParallelCopyDestinationNotAvailable 

pub struct ParallelCopyDestinationNotAvailable { /* private fields */ }

A CopyDestination that panics when used. Cannot be constructed outside this module, but is available for type reference to indicate Parallel copy is not supported.

Trait Implementations

impl Clone for ParallelCopyDestinationNotAvailable

fn clone(&self) -> ParallelCopyDestinationNotAvailable

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CopyDestination for ParallelCopyDestinationNotAvailable

async fn apply_data<S: Stream<Item = Result<Bytes>> + Send, C: AsyncCleanup>( &mut self, _schema: &PostgresSchema, _table: &PostgresTable, _data: TableData<S, C>, ) -> Result<()>

This should apply the data to the destination. The data is expected to be in the format returned by supported_data_format, if possible.

async fn apply_transactional_statement( &mut self, _statement: &str, ) -> Result<()>

This should apply the DDL statements to the destination.

async fn apply_non_transactional_statement( &mut self, _statement: &str, ) -> Result<()>

This should apply the DDL statements to the destination. These commands has to be run outside a transaction, as they might fail otherwise.

async fn begin_transaction(&mut self) -> Result<()>

Should begin a new transaction.

async fn commit_transaction(&mut self) -> Result<()>

Should commit a running transaction.

fn get_identifier_quoter(&self) -> Arc<IdentifierQuoter>

Should get the identifier quoter that works with this destination. This ensures quoting respects the rules of the destination, not the source.

fn finish(&mut self) -> impl Future<Output = Result<()>> + Send

fn try_introspect( &self, ) -> impl Future<Output = Result<Option<PostgresDatabase>>> + Send

Should try to introspect the destination. If introspection is not supported, this should return Ok(None), not an error. Errors should only be returned if introspection is supported, but failed.

fn has_data_in_table( &self, _schema: &PostgresSchema, _table: &PostgresTable, ) -> impl Future<Output = Result<bool>> + Send

impl Copy for ParallelCopyDestinationNotAvailable