summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-11-22 22:16:42 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2022-11-23 10:01:17 +0100
commitef637d4a7236d6570c748ba5782e0435f628bd9a (patch)
treed7c4a7ab240d2faca50eace28eb18db2cda5240c /container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java
parentb8165e0e316527dc956489bc416f9ccb83cf1904 (diff)
Make a few simpler interfaces instead of carrying one huge implement all SearchCluster around.
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java')
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java9
1 files changed, 4 insertions, 5 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java b/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java
index 36c5c8a16fa..b7a2d9f70ba 100644
--- a/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java
+++ b/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java
@@ -58,9 +58,9 @@ public class Dispatcher extends AbstractComponent {
private final ClusterMonitor<Node> clusterMonitor;
private final LoadBalancer loadBalancer;
private final InvokerFactory invokerFactory;
- private final RpcResourcePool rpcResourcePool;
private final RpcClient rpcClient;
private final int maxHitsPerNode;
+ private final RpcResourcePool rpcResourcePool;
private static final QueryProfileType argumentType;
@@ -101,7 +101,7 @@ public class Dispatcher extends AbstractComponent {
RpcClient rpcClient, RpcResourcePool rpcResourcePool) {
this(new ClusterMonitor<>(searchCluster, true),
searchCluster, dispatchConfig,
- new RpcInvokerFactory(rpcResourcePool, searchCluster),
+ new RpcInvokerFactory(rpcResourcePool, searchCluster, dispatchConfig),
rpcClient, rpcResourcePool);
}
@@ -161,9 +161,8 @@ public class Dispatcher extends AbstractComponent {
new Compressor().warmup(seconds);
}
- /** Returns the search cluster this dispatches to */
- public SearchCluster searchCluster() {
- return searchCluster;
+ public boolean allGroupsHaveSize1() {
+ return searchCluster.allGroupsHaveSize1();
}
@Override