diff options
author | Olli Virtanen <olli.virtanen@oath.com> | 2019-03-15 15:18:16 +0100 |
---|---|---|
committer | Olli Virtanen <olli.virtanen@oath.com> | 2019-03-15 15:18:16 +0100 |
commit | 9f82c8ea00268f11d1f34687808c4bfe799f291f (patch) | |
tree | 7c72016b99f155c223e33beabff9cd1ce5deca12 /container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java | |
parent | 1e94eb4b5076c2dbf985024c4510cc41bbe7f0c7 (diff) |
dispatch_internal and dispatch_fdispatch metrics
Diffstat (limited to 'container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java b/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java index db724b41657..e850312158c 100644 --- a/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java +++ b/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java @@ -11,14 +11,14 @@ import com.yahoo.concurrent.Receiver.MessageState; import com.yahoo.container.QrSearchersConfig; import com.yahoo.container.handler.VipStatus; import com.yahoo.fs4.mplex.Backend; +import com.yahoo.jdisc.Metric; import com.yahoo.net.HostName; -import com.yahoo.search.dispatch.Dispatcher; -import com.yahoo.prelude.fastsearch.FS4ResourcePool; import com.yahoo.prelude.IndexFacts; import com.yahoo.prelude.Ping; import com.yahoo.prelude.Pong; import com.yahoo.prelude.fastsearch.ClusterParams; import com.yahoo.prelude.fastsearch.DocumentdbInfoConfig; +import com.yahoo.prelude.fastsearch.FS4ResourcePool; import com.yahoo.prelude.fastsearch.FastSearcher; import com.yahoo.prelude.fastsearch.SummaryParameters; import com.yahoo.prelude.fastsearch.VespaBackEndSearcher; @@ -26,6 +26,7 @@ import com.yahoo.search.Query; import com.yahoo.search.Result; import com.yahoo.search.Searcher; import com.yahoo.search.config.ClusterConfig; +import com.yahoo.search.dispatch.Dispatcher; import com.yahoo.search.query.ParameterParser; import com.yahoo.search.result.ErrorMessage; import com.yahoo.search.searchchain.Execution; @@ -33,6 +34,7 @@ import com.yahoo.statistics.Statistics; import com.yahoo.statistics.Value; import com.yahoo.vespa.config.search.DispatchConfig; import com.yahoo.vespa.streamingvisitors.VdsStreamingSearcher; +import org.apache.commons.lang.StringUtils; import java.net.InetAddress; import java.net.UnknownHostException; @@ -48,11 +50,8 @@ import java.util.Optional; import java.util.Set; import java.util.concurrent.ExecutorService; import java.util.concurrent.ScheduledExecutorService; -import java.util.logging.Level; import java.util.logging.Logger; -import org.apache.commons.lang.StringUtils; - import static com.yahoo.container.QrSearchersConfig.Searchcluster.Indexingmode.STREAMING; /** @@ -101,12 +100,13 @@ public class ClusterSearcher extends Searcher { DispatchConfig dispatchConfig, ClusterInfoConfig clusterInfoConfig, Statistics manager, + Metric metric, FS4ResourcePool fs4ResourcePool, VipStatus vipStatus) { super(id); this.fs4ResourcePool = fs4ResourcePool; - Dispatcher dispatcher = new Dispatcher(id.stringValue(), dispatchConfig, fs4ResourcePool, clusterInfoConfig.nodeCount(), vipStatus); + Dispatcher dispatcher = new Dispatcher(id.stringValue(), dispatchConfig, fs4ResourcePool, clusterInfoConfig.nodeCount(), vipStatus, metric); monitor = (dispatcher.searchCluster().directDispatchTarget().isPresent()) // dispatcher should decide vip status instead ? new ClusterMonitor(this, monitorConfig, Optional.empty()) |