mz_testdrive::action::fivetran::proto::fivetran::destination_server

Trait Destination

Source 
pub trait Destination:
    Send
    + Sync
    + 'static {
    // Required methods
    fn configuration_form<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ConfigurationFormRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ConfigurationFormResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn test<'life0, 'async_trait>(
        &'life0 self,
        request: Request<TestRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TestResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn describe_table<'life0, 'async_trait>(
        &'life0 self,
        request: Request<DescribeTableRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeTableResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn create_table<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CreateTableRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CreateTableResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn alter_table<'life0, 'async_trait>(
        &'life0 self,
        request: Request<AlterTableRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<AlterTableResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn truncate<'life0, 'async_trait>(
        &'life0 self,
        request: Request<TruncateRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<TruncateResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn write_batch<'life0, 'async_trait>(
        &'life0 self,
        request: Request<WriteBatchRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<WriteBatchResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}
Expand description

Generated trait containing gRPC methods that should be implemented for use with DestinationServer.

Required Methods§

Source

fn configuration_form<'life0, 'async_trait>( &'life0 self, request: Request<ConfigurationFormRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ConfigurationFormResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn test<'life0, 'async_trait>( &'life0 self, request: Request<TestRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TestResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn describe_table<'life0, 'async_trait>( &'life0 self, request: Request<DescribeTableRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DescribeTableResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn create_table<'life0, 'async_trait>( &'life0 self, request: Request<CreateTableRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateTableResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn alter_table<'life0, 'async_trait>( &'life0 self, request: Request<AlterTableRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AlterTableResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn truncate<'life0, 'async_trait>( &'life0 self, request: Request<TruncateRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TruncateResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn write_batch<'life0, 'async_trait>( &'life0 self, request: Request<WriteBatchRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<WriteBatchResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors§