Trait TransportFactory 

pub trait TransportFactory: Send + Sync {
    // Required method
    fn open<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        table: &'life1 TableRef,
        schema: Arc<Schema>,
        creds: &'life2 VendedCredentials,
    ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ZerobusTransport>, ZerobusSinkError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
}

Opens (and re-opens, on rebuild) a stream for a target table.

Required Methods

fn open<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, table: &'life1 TableRef, schema: Arc<Schema>, creds: &'life2 VendedCredentials, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ZerobusTransport>, ZerobusSinkError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Open a new stream for table with the given Arrow schema, authenticated with vended creds.

Errors

ZerobusSinkError if the stream cannot be opened.

Implementors

impl TransportFactory for DatabricksFactory