FederatedQueryExecutor

Trait FederatedQueryExecutor 

Source
pub trait FederatedQueryExecutor: Send + Sync {
    // Required methods
    fn execute_query<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        endpoint: &'life1 FederatedEndpoint,
        query: &'life2 Query,
    ) -> Pin<Box<dyn Future<Output = Result<QueryResult, OxirsError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn check_health<'life0, 'life1, 'async_trait>(
        &'life0 self,
        endpoint: &'life1 FederatedEndpoint,
    ) -> Pin<Box<dyn Future<Output = EndpointStatus> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_capabilities<'life0, 'life1, 'async_trait>(
        &'life0 self,
        endpoint: &'life1 FederatedEndpoint,
    ) -> Pin<Box<dyn Future<Output = Result<EndpointFeatures, OxirsError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}
Expand description

Async trait for federated query execution

Required Methods§

Source

fn execute_query<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, endpoint: &'life1 FederatedEndpoint, query: &'life2 Query, ) -> Pin<Box<dyn Future<Output = Result<QueryResult, OxirsError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute query on federated endpoint

Source

fn check_health<'life0, 'life1, 'async_trait>( &'life0 self, endpoint: &'life1 FederatedEndpoint, ) -> Pin<Box<dyn Future<Output = EndpointStatus> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check endpoint health

Source

fn get_capabilities<'life0, 'life1, 'async_trait>( &'life0 self, endpoint: &'life1 FederatedEndpoint, ) -> Pin<Box<dyn Future<Output = Result<EndpointFeatures, OxirsError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get endpoint capabilities

Implementors§