| 1559 | |
| 1560 | |
| 1561 | StorageURLWithFailover::StorageURLWithFailover( |
| 1562 | const std::vector<String> & uri_options_, |
| 1563 | const StorageID & table_id_, |
| 1564 | const String & format_name_, |
| 1565 | const std::optional<FormatSettings> & format_settings_, |
| 1566 | const ColumnsDescription & columns_, |
| 1567 | const ConstraintsDescription & constraints_, |
| 1568 | const ContextPtr & context_, |
| 1569 | const String & compression_method_) |
| 1570 | : StorageURL("", table_id_, format_name_, format_settings_, columns_, constraints_, String{}, context_, compression_method_) |
| 1571 | { |
| 1572 | for (const auto & uri_option : uri_options_) |
| 1573 | { |
| 1574 | Poco::URI poco_uri(uri_option); |
| 1575 | context_->getRemoteHostFilter().checkURL(poco_uri); |
| 1576 | LOG_DEBUG(getLogger("StorageURLDistributed"), "Adding URL option: {}", uri_option); |
| 1577 | uri_options.emplace_back(uri_option); |
| 1578 | } |
| 1579 | } |
| 1580 | |
| 1581 | StorageURLSink::~StorageURLSink() |
| 1582 | { |
nothing calls this directly
no test coverage detected