diff options
author | Olli Virtanen <olli.virtanen@oath.com> | 2019-01-03 15:11:03 +0100 |
---|---|---|
committer | Olli Virtanen <olli.virtanen@oath.com> | 2019-01-03 15:11:03 +0100 |
commit | 033182288ab6f4f404a23d1456001d31cb930fc9 (patch) | |
tree | 6d89922ce1505766261b5df7b2656f7528485f42 /container-search/src/test/java/com/yahoo/search/dispatch/MockSearchCluster.java | |
parent | b48a97a0814a9a5b6e42ef963f5cb9e2f61d5395 (diff) |
Increased java dispatcher test coverage
Diffstat (limited to 'container-search/src/test/java/com/yahoo/search/dispatch/MockSearchCluster.java')
-rw-r--r-- | container-search/src/test/java/com/yahoo/search/dispatch/MockSearchCluster.java | 22 |
1 files changed, 20 insertions, 2 deletions
diff --git a/container-search/src/test/java/com/yahoo/search/dispatch/MockSearchCluster.java b/container-search/src/test/java/com/yahoo/search/dispatch/MockSearchCluster.java index f7b92419b52..2f970a9c007 100644 --- a/container-search/src/test/java/com/yahoo/search/dispatch/MockSearchCluster.java +++ b/container-search/src/test/java/com/yahoo/search/dispatch/MockSearchCluster.java @@ -1,6 +1,7 @@ // Copyright 2018 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.search.dispatch; +import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableMap; import com.google.common.collect.ImmutableMultimap; import com.yahoo.search.dispatch.searchcluster.Group; @@ -18,6 +19,7 @@ import java.util.Optional; public class MockSearchCluster extends SearchCluster { private final int numGroups; private final int numNodesPerGroup; + private final ImmutableList<Group> orderedGroups; private final ImmutableMap<Integer, Group> groups; private final ImmutableMultimap<String, Node> nodesByHost; @@ -28,6 +30,7 @@ public class MockSearchCluster extends SearchCluster { public MockSearchCluster(String clusterId, DispatchConfig dispatchConfig, int groups, int nodesPerGroup) { super(clusterId, dispatchConfig, null, 1, null); + ImmutableList.Builder<Group> orderedGroupBuilder = ImmutableList.builder(); ImmutableMap.Builder<Integer, Group> groupBuilder = ImmutableMap.builder(); ImmutableMultimap.Builder<String, Node> hostBuilder = ImmutableMultimap.builder(); int dk = 1; @@ -40,8 +43,11 @@ public class MockSearchCluster extends SearchCluster { hostBuilder.put(n.hostname(), n); dk++; } - groupBuilder.put(group, new Group(group, nodes)); + Group g = new Group(group, nodes); + groupBuilder.put(group, g); + orderedGroupBuilder.add(g); } + this.orderedGroups = orderedGroupBuilder.build(); this.groups = groupBuilder.build(); this.nodesByHost = hostBuilder.build(); this.numGroups = groups; @@ -49,18 +55,26 @@ public class MockSearchCluster extends SearchCluster { } @Override + public ImmutableList<Group> orderedGroups() { + return orderedGroups; + } + + @Override public int size() { return numGroups * numNodesPerGroup; } + @Override public ImmutableMap<Integer, Group> groups() { return groups; } + @Override public int groupSize() { return numNodesPerGroup; } + @Override public Optional<Group> group(int n) { if (n < numGroups) { return Optional.of(groups.get(n)); @@ -69,18 +83,22 @@ public class MockSearchCluster extends SearchCluster { } } + @Override public ImmutableMultimap<String, Node> nodesByHost() { return nodesByHost; } + @Override public Optional<Node> directDispatchTarget() { return Optional.empty(); } + @Override public void working(Node node) { node.setWorking(true); } + @Override public void failed(Node node) { node.setWorking(false); } @@ -95,7 +113,7 @@ public class MockSearchCluster extends SearchCluster { builder.minGroupCoverage(99.0); builder.maxNodesDownPerGroup(0); builder.minSearchCoverage(minSearchCoverage); - if(minSearchCoverage < 100.0) { + if (minSearchCoverage < 100.0) { builder.minWaitAfterCoverageFactor(0); builder.maxWaitAfterCoverageFactor(0.5); } |