Trait mz_testdrive::action::fivetran::proto::fivetran::destination_server::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§