Skip to content

Commit a5583e0

Browse files
author
elasticsearchmachine
committed
[CI] Auto commit changes from spotless
1 parent fdc9a24 commit a5583e0

File tree

3 files changed

+17
-12
lines changed

3 files changed

+17
-12
lines changed

x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/inference/action/GetInferenceDiagnosticsActionNodeResponseTests.java

Lines changed: 14 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -112,14 +112,21 @@ protected GetInferenceDiagnosticsAction.NodeResponse mutateInstance(GetInference
112112
}
113113

114114
@Override
115-
protected GetInferenceDiagnosticsAction.NodeResponse mutateInstanceForVersion(GetInferenceDiagnosticsAction.NodeResponse instance, TransportVersion version) {
115+
protected GetInferenceDiagnosticsAction.NodeResponse mutateInstanceForVersion(
116+
GetInferenceDiagnosticsAction.NodeResponse instance,
117+
TransportVersion version
118+
) {
116119
if (version.before(TransportVersions.INFERENCE_API_EIS_DIAGNOSTICS)) {
117-
return new GetInferenceDiagnosticsAction.NodeResponse(instance.getNode(), new PoolStats(
118-
instance.getExternalConnectionPoolStats().getLeasedConnections(),
119-
instance.getExternalConnectionPoolStats().getPendingConnections(),
120-
instance.getExternalConnectionPoolStats().getAvailableConnections(),
121-
instance.getExternalConnectionPoolStats().getMaxConnections()
122-
), new PoolStats(0, 0, 0, 0));
120+
return new GetInferenceDiagnosticsAction.NodeResponse(
121+
instance.getNode(),
122+
new PoolStats(
123+
instance.getExternalConnectionPoolStats().getLeasedConnections(),
124+
instance.getExternalConnectionPoolStats().getPendingConnections(),
125+
instance.getExternalConnectionPoolStats().getAvailableConnections(),
126+
instance.getExternalConnectionPoolStats().getMaxConnections()
127+
),
128+
new PoolStats(0, 0, 0, 0)
129+
);
123130
} else {
124131
return instance;
125132
}

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/InferencePlugin.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -375,10 +375,9 @@ public Collection<?> createComponents(PluginServices services) {
375375

376376
components.add(serviceRegistry);
377377
components.add(modelRegistry.get());
378-
components.add(new TransportGetInferenceDiagnosticsAction.ClientManagers(
379-
httpClientManager,
380-
elasticInferenceServiceHttpClientManager
381-
));
378+
components.add(
379+
new TransportGetInferenceDiagnosticsAction.ClientManagers(httpClientManager, elasticInferenceServiceHttpClientManager)
380+
);
382381
components.add(inferenceStatsBinding);
383382

384383
// Only add InferenceServiceNodeLocalRateLimitCalculator (which is a ClusterStateListener) for cluster aware rate limiting,

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/external/http/HttpClient.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,6 @@ private static CloseableHttpAsyncClient createAsyncClient(
7373
// so we don't want to support cookies to avoid accidental authentication for unauthorized users
7474
clientBuilder.disableCookieManagement();
7575

76-
7776
/*
7877
TODO When we implement multi-project we should ensure this is ok. A cluster will be authenticated to EIS because it is one mTLS
7978
cert per cluster. So I think we're ok to not need to track the connection state per request. We will need to pass a header

0 commit comments

Comments
 (0)