Skip to content

Commit 6f973e3

Browse files
committed
fix:fix instance detect wrong result. (#668)
Signed-off-by: Haotian Zhang <[email protected]>
1 parent 06506b4 commit 6f973e3

File tree

1 file changed

+6
-0
lines changed
  • polaris-discovery/polaris-discovery-client/src/main/java/com/tencent/polaris/discovery/client/stat

1 file changed

+6
-0
lines changed

polaris-discovery/polaris-discovery-client/src/main/java/com/tencent/polaris/discovery/client/stat/InstancesDetectTask.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
package com.tencent.polaris.discovery.client.stat;
1919

2020
import com.tencent.polaris.api.config.consumer.OutlierDetectionConfig.When;
21+
import com.tencent.polaris.api.config.verify.DefaultValues;
2122
import com.tencent.polaris.api.exception.PolarisException;
2223
import com.tencent.polaris.api.plugin.compose.Extensions;
2324
import com.tencent.polaris.api.plugin.detect.HealthChecker;
@@ -28,6 +29,7 @@
2829
import com.tencent.polaris.api.pojo.ServiceEventKey.EventType;
2930
import com.tencent.polaris.api.utils.CollectionUtils;
3031
import com.tencent.polaris.api.utils.MapUtils;
32+
import com.tencent.polaris.api.utils.StringUtils;
3133
import com.tencent.polaris.client.pojo.InstanceByProto;
3234
import com.tencent.polaris.logging.LoggerFactory;
3335
import org.slf4j.Logger;
@@ -133,6 +135,10 @@ private ServiceUpdateRequest buildInstanceUpdateResult(ServiceKey serviceKey,
133135
private DetectResult detectInstance(Instance instance) throws PolarisException {
134136
DetectResult result = null;
135137
for (HealthChecker detector : extensions.getHealthCheckers()) {
138+
// only tcp detect.
139+
if (!StringUtils.equals(detector.getName(), DefaultValues.DEFAULT_HEALTH_CHECKER_TCP)) {
140+
continue;
141+
}
136142
DetectResult pluginResult = detector.detectInstance(instance, null);
137143
if (pluginResult == null) {
138144
continue;

0 commit comments

Comments
 (0)