Skip to content

Commit 423f224

Browse files
committed
Clean up
1 parent e86088b commit 423f224

File tree

3 files changed

+12
-12
lines changed

3 files changed

+12
-12
lines changed

server/src/main/java/module-info.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -398,8 +398,7 @@
398398
org.elasticsearch.settings.secure,
399399
org.elasticsearch.serverless.constants,
400400
org.elasticsearch.serverless.apifiltering,
401-
org.elasticsearch.internal.security,
402-
org.elasticsearch.serverless.crossproject;
401+
org.elasticsearch.internal.security;
403402

404403
exports org.elasticsearch.telemetry.tracing;
405404
exports org.elasticsearch.telemetry;

server/src/main/java/org/elasticsearch/node/NodeConstruction.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
import org.elasticsearch.action.bulk.IncrementalBulkService;
2424
import org.elasticsearch.action.datastreams.autosharding.DataStreamAutoShardingService;
2525
import org.elasticsearch.action.ingest.ReservedPipelineAction;
26-
import org.elasticsearch.action.search.CrossClusterSearchExtension;
26+
import org.elasticsearch.search.internal.CrossClusterSearchExtension;
2727
import org.elasticsearch.action.search.OnlinePrewarmingService;
2828
import org.elasticsearch.action.search.OnlinePrewarmingServiceProvider;
2929
import org.elasticsearch.action.search.SearchExecutionStatsCollector;
@@ -1018,11 +1018,10 @@ public Map<String, String> queryFields() {
10181018

10191019
var crossClusterSearchExtension = pluginsService.loadSingletonServiceProvider(
10201020
CrossClusterSearchExtension.class,
1021-
CrossClusterSearchExtension.Noop::new
1021+
CrossClusterSearchExtension.Default::new
10221022
);
10231023

1024-
logger.info("Using cross-cluster search extension: [{}]", crossClusterSearchExtension.getClass().getName());
1025-
logger.info("Cross-cluster search force reconnect: [{}]", crossClusterSearchExtension.forceReconnect());
1024+
logger.info("Cross-cluster search force reconnect: [{}]", crossClusterSearchExtension.forceReconnectBehaviorSupplier().get());
10261025

10271026
ActionModule actionModule = new ActionModule(
10281027
settings,

server/src/main/java/org/elasticsearch/action/search/CrossClusterSearchExtension.java renamed to server/src/main/java/org/elasticsearch/search/internal/CrossClusterSearchExtension.java

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -7,18 +7,20 @@
77
* License v3.0 only", or the "Server Side Public License, v 1".
88
*/
99

10-
package org.elasticsearch.action.search;
10+
package org.elasticsearch.search.internal;
11+
12+
import java.util.function.Supplier;
1113

1214
public interface CrossClusterSearchExtension {
1315

14-
boolean forceReconnect();
16+
Supplier<Boolean> forceReconnectBehaviorSupplier();
1517

16-
class Noop implements CrossClusterSearchExtension {
17-
public Noop() {}
18+
class Default implements CrossClusterSearchExtension {
19+
public Default() {}
1820

1921
@Override
20-
public boolean forceReconnect() {
21-
return false;
22+
public Supplier<Boolean> forceReconnectBehaviorSupplier() {
23+
return () -> false;
2224
}
2325
}
2426
}

0 commit comments

Comments
 (0)