MCPcopy Create free account
hub / github.com/apache/arrow / GetScenario

Function GetScenario

cpp/src/arrow/flight/integration_tests/test_integration.cc:2484–2535  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2482} // namespace
2483
2484Status GetScenario(const std::string& scenario_name, std::shared_ptr<Scenario>* out) {
2485 if (scenario_name == "auth:basic_proto") {
2486 *out = std::make_shared<AuthBasicProtoScenario>();
2487 return Status::OK();
2488 } else if (scenario_name == "middleware") {
2489 *out = std::make_shared<MiddlewareScenario>();
2490 return Status::OK();
2491 } else if (scenario_name == "alignment") {
2492 *out = std::make_shared<AlignmentScenario>();
2493 return Status::OK();
2494 } else if (scenario_name == "ordered") {
2495 *out = std::make_shared<OrderedScenario>();
2496 return Status::OK();
2497 } else if (scenario_name == "expiration_time:do_get") {
2498 *out = std::make_shared<ExpirationTimeDoGetScenario>();
2499 return Status::OK();
2500 } else if (scenario_name == "expiration_time:list_actions") {
2501 *out = std::make_shared<ExpirationTimeListActionsScenario>();
2502 return Status::OK();
2503 } else if (scenario_name == "expiration_time:cancel_flight_info") {
2504 *out = std::make_shared<ExpirationTimeCancelFlightInfoScenario>();
2505 return Status::OK();
2506 } else if (scenario_name == "expiration_time:renew_flight_endpoint") {
2507 *out = std::make_shared<ExpirationTimeRenewFlightEndpointScenario>();
2508 return Status::OK();
2509 } else if (scenario_name == "location:reuse_connection") {
2510 *out = std::make_shared<ReuseConnectionScenario>();
2511 return Status::OK();
2512 } else if (scenario_name == "session_options") {
2513 *out = std::make_shared<SessionOptionsScenario>();
2514 return Status::OK();
2515 } else if (scenario_name == "poll_flight_info") {
2516 *out = std::make_shared<PollFlightInfoScenario>();
2517 return Status::OK();
2518 } else if (scenario_name == "app_metadata_flight_info_endpoint") {
2519 *out = std::make_shared<AppMetadataFlightInfoEndpointScenario>();
2520 return Status::OK();
2521 } else if (scenario_name == "do_exchange:echo") {
2522 *out = std::make_shared<DoExchangeEchoScenario>();
2523 return Status::OK();
2524 } else if (scenario_name == "flight_sql") {
2525 *out = std::make_shared<FlightSqlScenario>();
2526 return Status::OK();
2527 } else if (scenario_name == "flight_sql:extension") {
2528 *out = std::make_shared<FlightSqlExtensionScenario>();
2529 return Status::OK();
2530 } else if (scenario_name == "flight_sql:ingestion") {
2531 *out = std::make_shared<FlightSqlIngestionScenario>();
2532 return Status::OK();
2533 }
2534 return Status::KeyError("Scenario not found: ", scenario_name);
2535}
2536
2537} // namespace integration_tests
2538} // namespace flight

Callers 3

RunScenarioFunction · 0.85
mainFunction · 0.85
mainFunction · 0.85

Calls 2

KeyErrorFunction · 0.85
OKFunction · 0.50

Tested by

no test coverage detected