MCPcopy Create free account
hub / github.com/ClickHouse/ClickHouse / getManyChecked

Method getManyChecked

src/Client/ConnectionPoolWithFailover.cpp:161–174  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

159}
160
161std::vector<ConnectionPoolWithFailover::TryResult> ConnectionPoolWithFailover::getManyChecked(
162 const ConnectionTimeouts & timeouts,
163 const Settings & settings,
164 PoolMode pool_mode,
165 const QualifiedTableName & table_to_check,
166 AsyncCallback async_callback,
167 std::optional<bool> skip_unavailable_endpoints,
168 GetPriorityForLoadBalancing::Func priority_func)
169{
170 TryGetEntryFunc try_get_entry = [&](const NestedPoolPtr & pool, std::string & fail_message)
171 { return tryGetEntry(pool, timeouts, fail_message, settings, &table_to_check, async_callback); };
172
173 return getManyImpl(settings, pool_mode, try_get_entry, skip_unavailable_endpoints, priority_func);
174}
175
176std::vector<ConnectionPoolWithFailover::TryResult> ConnectionPoolWithFailover::getManyCheckedForInsert(
177 const ConnectionTimeouts & timeouts,

Callers 2

addLazyPipeMethod · 0.80
RemoteQueryExecutorMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected