maxmustermann/kibana
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Honor maxConcurrentShardRequests setting. (#30049)

Browse source
This commit is contained in:
Sonja Krause-Harder 2019-02-05 15:12:26 +01:00 committed by GitHub
parent 2850fd6735
commit 4a4ed6bb55
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
x-pack/plugins/infra/server/lib/adapters/framework/kibana_framework_adapter.ts
View file

@ -25,6 +25,10 @@ import {
HapiGraphQLPluginOptions,
} from './apollo_server_hapi';
interface CallWithRequestParams extends GenericParams {
max_concurrent_shard_requests?: number;
}
export class InfraKibanaBackendFrameworkAdapter implements InfraBackendFrameworkAdapter {
public version: string;
@ -85,13 +89,22 @@ export class InfraKibanaBackendFrameworkAdapter implements InfraBackendFramework
public async callWithRequest(
req: InfraFrameworkRequest<Legacy.Request>,
endpoint: string,
params: GenericParams,
params: CallWithRequestParams,
...rest: any[]
) {
const internalRequest = req[internalInfraFrameworkRequest];
const { elasticsearch } = internalRequest.server.plugins;
const { callWithRequest } = elasticsearch.getCluster('data');
const includeFrozen = await internalRequest.getUiSettingsService().get('search:includeFrozen');
if (endpoint === 'msearch') {
const maxConcurrentShardRequests = await internalRequest
.getUiSettingsService()
.get('courier:maxConcurrentShardRequests');
if (maxConcurrentShardRequests > 0) {
params = { ...params, max_concurrent_shard_requests: maxConcurrentShardRequests };
}
}
const fields = await callWithRequest(
internalRequest,
endpoint,