pub trait FlightSqlService:
Sync
+ Send
+ Sized
+ 'static {
type FlightService: FlightService;
Show 46 methods
// Required method
fn register_sql_info<'life0, 'life1, 'async_trait>(
&'life0 self,
id: i32,
result: &'life1 SqlInfo,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
// Provided methods
fn do_handshake<'life0, 'async_trait>(
&'life0 self,
_request: Request<Streaming<HandshakeRequest>>,
) -> Pin<Box<dyn Future<Output = Result<Response<Pin<Box<dyn Stream<Item = Result<HandshakeResponse, Status>> + Send>>>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_fallback<'life0, 'async_trait>(
&'life0 self,
_request: Request<Ticket>,
message: Any,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_statement<'life0, 'async_trait>(
&'life0 self,
_query: CommandStatementQuery,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_substrait_plan<'life0, 'async_trait>(
&'life0 self,
_query: CommandStatementSubstraitPlan,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementQuery,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_catalogs<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCatalogs,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_schemas<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetDbSchemas,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_tables<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTables,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_table_types<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTableTypes,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_sql_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetSqlInfo,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_primary_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetPrimaryKeys,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_exported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetExportedKeys,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_imported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetImportedKeys,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_cross_reference<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCrossReference,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_xdbc_type_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetXdbcTypeInfo,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn get_flight_info_fallback<'life0, 'async_trait>(
&'life0 self,
cmd: Command,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_statement<'life0, 'async_trait>(
&'life0 self,
_ticket: TicketStatementQuery,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementQuery,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_catalogs<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCatalogs,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_schemas<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetDbSchemas,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_tables<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTables,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_table_types<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTableTypes,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_sql_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetSqlInfo,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_primary_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetPrimaryKeys,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_exported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetExportedKeys,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_imported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetImportedKeys,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_cross_reference<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCrossReference,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_get_xdbc_type_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetXdbcTypeInfo,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_put_fallback<'life0, 'async_trait>(
&'life0 self,
_request: Request<PeekableFlightDataStream>,
message: Any,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoPutStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_put_statement_update<'life0, 'async_trait>(
&'life0 self,
_ticket: CommandStatementUpdate,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_put_statement_ingest<'life0, 'async_trait>(
&'life0 self,
_ticket: CommandStatementIngest,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_put_prepared_statement_query<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementQuery,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<DoPutPreparedStatementResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_put_prepared_statement_update<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementUpdate,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_put_substrait_plan<'life0, 'async_trait>(
&'life0 self,
_query: CommandStatementSubstraitPlan,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_action_fallback<'life0, 'async_trait>(
&'life0 self,
request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoActionStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn list_custom_actions<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Option<Vec<Result<ActionType, Status>>>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_action_create_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: ActionCreatePreparedStatementRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionCreatePreparedStatementResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_action_close_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: ActionClosePreparedStatementRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_action_create_prepared_substrait_plan<'life0, 'async_trait>(
&'life0 self,
_query: ActionCreatePreparedSubstraitPlanRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionCreatePreparedStatementResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_action_begin_transaction<'life0, 'async_trait>(
&'life0 self,
_query: ActionBeginTransactionRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionBeginTransactionResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_action_end_transaction<'life0, 'async_trait>(
&'life0 self,
_query: ActionEndTransactionRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_action_begin_savepoint<'life0, 'async_trait>(
&'life0 self,
_query: ActionBeginSavepointRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionBeginSavepointResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_action_end_savepoint<'life0, 'async_trait>(
&'life0 self,
_query: ActionEndSavepointRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_action_cancel_query<'life0, 'async_trait>(
&'life0 self,
_query: ActionCancelQueryRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionCancelQueryResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
fn do_exchange_fallback<'life0, 'async_trait>(
&'life0 self,
_request: Request<Streaming<FlightData>>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoExchangeStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait { ... }
}
Expand description
Implements FlightSqlService to handle the flight sql protocol
Required Associated Types§
Sourcetype FlightService: FlightService
type FlightService: FlightService
When impl FlightSqlService, you can always set FlightService to Self
Required Methods§
Sourcefn register_sql_info<'life0, 'life1, 'async_trait>(
&'life0 self,
id: i32,
result: &'life1 SqlInfo,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn register_sql_info<'life0, 'life1, 'async_trait>(
&'life0 self,
id: i32,
result: &'life1 SqlInfo,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Register a new SqlInfo result, making it available when calling GetSqlInfo.
Provided Methods§
Sourcefn do_handshake<'life0, 'async_trait>(
&'life0 self,
_request: Request<Streaming<HandshakeRequest>>,
) -> Pin<Box<dyn Future<Output = Result<Response<Pin<Box<dyn Stream<Item = Result<HandshakeResponse, Status>> + Send>>>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_handshake<'life0, 'async_trait>(
&'life0 self,
_request: Request<Streaming<HandshakeRequest>>,
) -> Pin<Box<dyn Future<Output = Result<Response<Pin<Box<dyn Stream<Item = Result<HandshakeResponse, Status>> + Send>>>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Accept authentication and return a token https://arrow.apache.org/docs/format/Flight.html#authentication
Sourcefn do_get_fallback<'life0, 'async_trait>(
&'life0 self,
_request: Request<Ticket>,
message: Any,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_fallback<'life0, 'async_trait>(
&'life0 self,
_request: Request<Ticket>,
message: Any,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Implementors may override to handle additional calls to do_get()
Sourcefn get_flight_info_statement<'life0, 'async_trait>(
&'life0 self,
_query: CommandStatementQuery,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_statement<'life0, 'async_trait>(
&'life0 self,
_query: CommandStatementQuery,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo for executing a SQL query.
Sourcefn get_flight_info_substrait_plan<'life0, 'async_trait>(
&'life0 self,
_query: CommandStatementSubstraitPlan,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_substrait_plan<'life0, 'async_trait>(
&'life0 self,
_query: CommandStatementSubstraitPlan,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo for executing a substrait plan.
Sourcefn get_flight_info_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementQuery,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementQuery,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo for executing an already created prepared statement.
Sourcefn get_flight_info_catalogs<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCatalogs,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_catalogs<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCatalogs,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo for listing catalogs.
Sourcefn get_flight_info_schemas<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetDbSchemas,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_schemas<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetDbSchemas,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo for listing schemas.
Sourcefn get_flight_info_tables<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTables,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_tables<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTables,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo for listing tables.
Sourcefn get_flight_info_table_types<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTableTypes,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_table_types<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTableTypes,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo to extract information about the table types.
Sourcefn get_flight_info_sql_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetSqlInfo,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_sql_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetSqlInfo,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo for retrieving other information (See SqlInfo).
Sourcefn get_flight_info_primary_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetPrimaryKeys,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_primary_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetPrimaryKeys,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo to extract information about primary and foreign keys.
Sourcefn get_flight_info_exported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetExportedKeys,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_exported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetExportedKeys,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo to extract information about exported keys.
Sourcefn get_flight_info_imported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetImportedKeys,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_imported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetImportedKeys,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo to extract information about imported keys.
Sourcefn get_flight_info_cross_reference<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCrossReference,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_cross_reference<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCrossReference,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo to extract information about cross reference.
Sourcefn get_flight_info_xdbc_type_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetXdbcTypeInfo,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_xdbc_type_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetXdbcTypeInfo,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightInfo to extract information about the supported XDBC types.
Sourcefn get_flight_info_fallback<'life0, 'async_trait>(
&'life0 self,
cmd: Command,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_flight_info_fallback<'life0, 'async_trait>(
&'life0 self,
cmd: Command,
_request: Request<FlightDescriptor>,
) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Implementors may override to handle additional calls to get_flight_info()
Sourcefn do_get_statement<'life0, 'async_trait>(
&'life0 self,
_ticket: TicketStatementQuery,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_statement<'life0, 'async_trait>(
&'life0 self,
_ticket: TicketStatementQuery,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the query results.
Sourcefn do_get_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementQuery,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementQuery,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the prepared statement query results.
Sourcefn do_get_catalogs<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCatalogs,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_catalogs<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCatalogs,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the list of catalogs.
Sourcefn do_get_schemas<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetDbSchemas,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_schemas<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetDbSchemas,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the list of schemas.
Sourcefn do_get_tables<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTables,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_tables<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTables,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the list of tables.
Sourcefn do_get_table_types<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTableTypes,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_table_types<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetTableTypes,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the data related to the table types.
Sourcefn do_get_sql_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetSqlInfo,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_sql_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetSqlInfo,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the list of SqlInfo results.
Sourcefn do_get_primary_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetPrimaryKeys,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_primary_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetPrimaryKeys,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the data related to the primary and foreign keys.
Sourcefn do_get_exported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetExportedKeys,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_exported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetExportedKeys,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the data related to the exported keys.
Sourcefn do_get_imported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetImportedKeys,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_imported_keys<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetImportedKeys,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the data related to the imported keys.
Sourcefn do_get_cross_reference<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCrossReference,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_cross_reference<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetCrossReference,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the data related to the cross reference.
Sourcefn do_get_xdbc_type_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetXdbcTypeInfo,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_get_xdbc_type_info<'life0, 'async_trait>(
&'life0 self,
_query: CommandGetXdbcTypeInfo,
_request: Request<Ticket>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get a FlightDataStream containing the data related to the supported XDBC types.
Sourcefn do_put_fallback<'life0, 'async_trait>(
&'life0 self,
_request: Request<PeekableFlightDataStream>,
message: Any,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoPutStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_put_fallback<'life0, 'async_trait>(
&'life0 self,
_request: Request<PeekableFlightDataStream>,
message: Any,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoPutStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Implementors may override to handle additional calls to do_put()
Sourcefn do_put_statement_update<'life0, 'async_trait>(
&'life0 self,
_ticket: CommandStatementUpdate,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_put_statement_update<'life0, 'async_trait>(
&'life0 self,
_ticket: CommandStatementUpdate,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Execute an update SQL statement.
Sourcefn do_put_statement_ingest<'life0, 'async_trait>(
&'life0 self,
_ticket: CommandStatementIngest,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_put_statement_ingest<'life0, 'async_trait>(
&'life0 self,
_ticket: CommandStatementIngest,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Execute a bulk ingestion.
Sourcefn do_put_prepared_statement_query<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementQuery,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<DoPutPreparedStatementResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_put_prepared_statement_query<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementQuery,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<DoPutPreparedStatementResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Bind parameters to given prepared statement.
Returns an opaque handle that the client should pass back to the server during subsequent requests with this prepared statement.
Sourcefn do_put_prepared_statement_update<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementUpdate,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_put_prepared_statement_update<'life0, 'async_trait>(
&'life0 self,
_query: CommandPreparedStatementUpdate,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Execute an update SQL prepared statement.
Sourcefn do_put_substrait_plan<'life0, 'async_trait>(
&'life0 self,
_query: CommandStatementSubstraitPlan,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_put_substrait_plan<'life0, 'async_trait>(
&'life0 self,
_query: CommandStatementSubstraitPlan,
_request: Request<PeekableFlightDataStream>,
) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Execute a substrait plan
Sourcefn do_action_fallback<'life0, 'async_trait>(
&'life0 self,
request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoActionStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_action_fallback<'life0, 'async_trait>(
&'life0 self,
request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoActionStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Implementors may override to handle additional calls to do_action()
Sourcefn list_custom_actions<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Option<Vec<Result<ActionType, Status>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn list_custom_actions<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Option<Vec<Result<ActionType, Status>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Add custom actions to list_actions() result
Sourcefn do_action_create_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: ActionCreatePreparedStatementRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionCreatePreparedStatementResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_action_create_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: ActionCreatePreparedStatementRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionCreatePreparedStatementResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Create a prepared statement from given SQL statement.
Sourcefn do_action_close_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: ActionClosePreparedStatementRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_action_close_prepared_statement<'life0, 'async_trait>(
&'life0 self,
_query: ActionClosePreparedStatementRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Close a prepared statement.
Sourcefn do_action_create_prepared_substrait_plan<'life0, 'async_trait>(
&'life0 self,
_query: ActionCreatePreparedSubstraitPlanRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionCreatePreparedStatementResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_action_create_prepared_substrait_plan<'life0, 'async_trait>(
&'life0 self,
_query: ActionCreatePreparedSubstraitPlanRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionCreatePreparedStatementResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Create a prepared substrait plan.
Sourcefn do_action_begin_transaction<'life0, 'async_trait>(
&'life0 self,
_query: ActionBeginTransactionRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionBeginTransactionResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_action_begin_transaction<'life0, 'async_trait>(
&'life0 self,
_query: ActionBeginTransactionRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionBeginTransactionResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Begin a transaction
Sourcefn do_action_end_transaction<'life0, 'async_trait>(
&'life0 self,
_query: ActionEndTransactionRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_action_end_transaction<'life0, 'async_trait>(
&'life0 self,
_query: ActionEndTransactionRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
End a transaction
Sourcefn do_action_begin_savepoint<'life0, 'async_trait>(
&'life0 self,
_query: ActionBeginSavepointRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionBeginSavepointResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_action_begin_savepoint<'life0, 'async_trait>(
&'life0 self,
_query: ActionBeginSavepointRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionBeginSavepointResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Begin a savepoint
Sourcefn do_action_end_savepoint<'life0, 'async_trait>(
&'life0 self,
_query: ActionEndSavepointRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_action_end_savepoint<'life0, 'async_trait>(
&'life0 self,
_query: ActionEndSavepointRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
End a savepoint
Sourcefn do_action_cancel_query<'life0, 'async_trait>(
&'life0 self,
_query: ActionCancelQueryRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionCancelQueryResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_action_cancel_query<'life0, 'async_trait>(
&'life0 self,
_query: ActionCancelQueryRequest,
_request: Request<Action>,
) -> Pin<Box<dyn Future<Output = Result<ActionCancelQueryResult, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Cancel a query
Sourcefn do_exchange_fallback<'life0, 'async_trait>(
&'life0 self,
_request: Request<Streaming<FlightData>>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoExchangeStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn do_exchange_fallback<'life0, 'async_trait>(
&'life0 self,
_request: Request<Streaming<FlightData>>,
) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoExchangeStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
do_exchange Implementors may override to handle additional calls to do_exchange()
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.