未验证 提交 5f302288 编写于 作者: 彭勇升 pengys 提交者: GitHub

Rename thermodynamic attributes. (#1161)

* Rename thermodynamic attributes.

* A missing attribute name.
上级 ed487bc2
...@@ -73,11 +73,11 @@ public class ResponseTimeDistributionSpanListener implements FirstSpanListener { ...@@ -73,11 +73,11 @@ public class ResponseTimeDistributionSpanListener implements FirstSpanListener {
} }
int getStep(int duration) { int getStep(int duration) {
int responseTimeMaxStep = configService.getResponseTimeStep() * configService.getResponseTimeMaxStep(); int countOfResponseTimeSteps = configService.getResponseTimeStep() * configService.getCountOfResponseTimeSteps();
int responseTimeStep = configService.getResponseTimeStep(); int responseTimeStep = configService.getResponseTimeStep();
if (duration > responseTimeMaxStep) { if (duration > countOfResponseTimeSteps) {
return responseTimeMaxStep / responseTimeStep; return countOfResponseTimeSteps / responseTimeStep;
} else if (duration <= responseTimeStep) { } else if (duration <= responseTimeStep) {
return 0; return 0;
} else { } else {
......
...@@ -42,7 +42,7 @@ public class ResponseTimeDistributionSpanListenerTestCase { ...@@ -42,7 +42,7 @@ public class ResponseTimeDistributionSpanListenerTestCase {
IResponseTimeDistributionConfigService service = Mockito.mock(IResponseTimeDistributionConfigService.class); IResponseTimeDistributionConfigService service = Mockito.mock(IResponseTimeDistributionConfigService.class);
Mockito.when(service.getResponseTimeStep()).thenReturn(50); Mockito.when(service.getResponseTimeStep()).thenReturn(50);
Mockito.when(service.getResponseTimeMaxStep()).thenReturn(40); Mockito.when(service.getCountOfResponseTimeSteps()).thenReturn(40);
Module module = Mockito.mock(Module.class); Module module = Mockito.mock(Module.class);
Whitebox.setInternalState(module, "loadedProviders", loadedProviders); Whitebox.setInternalState(module, "loadedProviders", loadedProviders);
......
...@@ -75,10 +75,14 @@ storage: ...@@ -75,10 +75,14 @@ storage:
configuration: configuration:
default: default:
# namespace: xxxxx # namespace: xxxxx
# alarm threshold
applicationApdexThreshold: 2000 applicationApdexThreshold: 2000
serviceErrorRateThreshold: 10.00 serviceErrorRateThreshold: 10.00
serviceAverageResponseTimeThreshold: 2000 serviceAverageResponseTimeThreshold: 2000
instanceErrorRateThreshold: 10.00 instanceErrorRateThreshold: 10.00
instanceAverageResponseTimeThreshold: 2000 instanceAverageResponseTimeThreshold: 2000
applicationErrorRateThreshold: 10.00 applicationErrorRateThreshold: 10.00
applicationAverageResponseTimeThreshold: 2000 applicationAverageResponseTimeThreshold: 2000
\ No newline at end of file # thermodynamic
thermodynamicResponseTimeStep: 50
thermodynamicCountOfResponseTimeSteps: 40
\ No newline at end of file
...@@ -27,5 +27,5 @@ public interface IResponseTimeDistributionConfigService extends Service { ...@@ -27,5 +27,5 @@ public interface IResponseTimeDistributionConfigService extends Service {
int getResponseTimeStep(); int getResponseTimeStep();
int getResponseTimeMaxStep(); int getCountOfResponseTimeSteps();
} }
...@@ -33,8 +33,8 @@ class ConfigurationModuleConfig extends ModuleConfig { ...@@ -33,8 +33,8 @@ class ConfigurationModuleConfig extends ModuleConfig {
private int instanceAverageResponseTimeThreshold; private int instanceAverageResponseTimeThreshold;
private double applicationErrorRateThreshold; private double applicationErrorRateThreshold;
private int applicationAverageResponseTimeThreshold; private int applicationAverageResponseTimeThreshold;
private int responseTimeDistributionDuration; private int thermodynamicResponseTimeStep;
private int responseTimeDistributionMaxDurationns; private int thermodynamicCountOfResponseTimeSteps;
public String getNamespace() { public String getNamespace() {
return namespace; return namespace;
...@@ -100,19 +100,19 @@ class ConfigurationModuleConfig extends ModuleConfig { ...@@ -100,19 +100,19 @@ class ConfigurationModuleConfig extends ModuleConfig {
this.applicationAverageResponseTimeThreshold = applicationAverageResponseTimeThreshold; this.applicationAverageResponseTimeThreshold = applicationAverageResponseTimeThreshold;
} }
public int getResponseTimeDistributionDuration() { public int getThermodynamicResponseTimeStep() {
return responseTimeDistributionDuration; return thermodynamicResponseTimeStep;
} }
public void setResponseTimeDistributionDuration(int responseTimeDistributionDuration) { public void setThermodynamicResponseTimeStep(int thermodynamicResponseTimeStep) {
this.responseTimeDistributionDuration = responseTimeDistributionDuration; this.thermodynamicResponseTimeStep = thermodynamicResponseTimeStep;
} }
public int getResponseTimeDistributionMaxDurationns() { public int getThermodynamicCountOfResponseTimeSteps() {
return responseTimeDistributionMaxDurationns; return thermodynamicCountOfResponseTimeSteps;
} }
public void setResponseTimeDistributionMaxDurationns(int responseTimeDistributionMaxDurationns) { public void setThermodynamicCountOfResponseTimeSteps(int thermodynamicCountOfResponseTimeSteps) {
this.responseTimeDistributionMaxDurationns = responseTimeDistributionMaxDurationns; this.thermodynamicCountOfResponseTimeSteps = thermodynamicCountOfResponseTimeSteps;
} }
} }
...@@ -18,32 +18,9 @@ ...@@ -18,32 +18,9 @@
package org.apache.skywalking.apm.collector.configuration; package org.apache.skywalking.apm.collector.configuration;
import org.apache.skywalking.apm.collector.configuration.service.ApdexThresholdService; import org.apache.skywalking.apm.collector.configuration.service.*;
import org.apache.skywalking.apm.collector.configuration.service.ApplicationAlarmRuleConfig; import org.apache.skywalking.apm.collector.core.module.*;
import org.apache.skywalking.apm.collector.configuration.service.ApplicationReferenceAlarmRuleConfig; import org.apache.skywalking.apm.collector.core.util.*;
import org.apache.skywalking.apm.collector.configuration.service.CollectorConfigService;
import org.apache.skywalking.apm.collector.configuration.service.ComponentLibraryCatalogService;
import org.apache.skywalking.apm.collector.configuration.service.IApdexThresholdService;
import org.apache.skywalking.apm.collector.configuration.service.IApplicationAlarmRuleConfig;
import org.apache.skywalking.apm.collector.configuration.service.IApplicationReferenceAlarmRuleConfig;
import org.apache.skywalking.apm.collector.configuration.service.ICollectorConfig;
import org.apache.skywalking.apm.collector.configuration.service.IComponentLibraryCatalogService;
import org.apache.skywalking.apm.collector.configuration.service.IInstanceAlarmRuleConfig;
import org.apache.skywalking.apm.collector.configuration.service.IInstanceReferenceAlarmRuleConfig;
import org.apache.skywalking.apm.collector.configuration.service.IResponseTimeDistributionConfigService;
import org.apache.skywalking.apm.collector.configuration.service.IServiceAlarmRuleConfig;
import org.apache.skywalking.apm.collector.configuration.service.IServiceReferenceAlarmRuleConfig;
import org.apache.skywalking.apm.collector.configuration.service.InstanceAlarmRuleConfig;
import org.apache.skywalking.apm.collector.configuration.service.InstanceReferenceAlarmRuleConfig;
import org.apache.skywalking.apm.collector.configuration.service.ResponseTimeDistributionConfigService;
import org.apache.skywalking.apm.collector.configuration.service.ServiceAlarmRuleConfig;
import org.apache.skywalking.apm.collector.configuration.service.ServiceReferenceAlarmRuleConfig;
import org.apache.skywalking.apm.collector.core.module.Module;
import org.apache.skywalking.apm.collector.core.module.ModuleConfig;
import org.apache.skywalking.apm.collector.core.module.ModuleProvider;
import org.apache.skywalking.apm.collector.core.module.ServiceNotProvidedException;
import org.apache.skywalking.apm.collector.core.util.Const;
import org.apache.skywalking.apm.collector.core.util.StringUtils;
/** /**
* @author peng-yongsheng * @author peng-yongsheng
...@@ -79,8 +56,8 @@ public class ConfigurationModuleProvider extends ModuleProvider { ...@@ -79,8 +56,8 @@ public class ConfigurationModuleProvider extends ModuleProvider {
double applicationErrorRateThreshold = config.getApplicationErrorRateThreshold() == 0 ? 10.00 : config.getApplicationErrorRateThreshold(); double applicationErrorRateThreshold = config.getApplicationErrorRateThreshold() == 0 ? 10.00 : config.getApplicationErrorRateThreshold();
int applicationAverageResponseTimeThreshold = config.getApplicationAverageResponseTimeThreshold() == 0 ? 2000 : config.getApplicationAverageResponseTimeThreshold(); int applicationAverageResponseTimeThreshold = config.getApplicationAverageResponseTimeThreshold() == 0 ? 2000 : config.getApplicationAverageResponseTimeThreshold();
int responseTimeDistributionDuration = config.getResponseTimeDistributionDuration() == 0 ? 50 : config.getResponseTimeDistributionDuration(); int thermodynamicResponseTimeStep = config.getThermodynamicResponseTimeStep() == 0 ? 50 : config.getThermodynamicResponseTimeStep();
int responseTimeDistributionMaxDurations = config.getResponseTimeDistributionMaxDurationns() == 0 ? 40 : config.getResponseTimeDistributionMaxDurationns(); int thermodynamicCountOfResponseTimeSteps = config.getThermodynamicCountOfResponseTimeSteps() == 0 ? 40 : config.getThermodynamicCountOfResponseTimeSteps();
this.registerServiceImplementation(ICollectorConfig.class, new CollectorConfigService(namespace)); this.registerServiceImplementation(ICollectorConfig.class, new CollectorConfigService(namespace));
this.registerServiceImplementation(IComponentLibraryCatalogService.class, new ComponentLibraryCatalogService()); this.registerServiceImplementation(IComponentLibraryCatalogService.class, new ComponentLibraryCatalogService());
...@@ -91,7 +68,7 @@ public class ConfigurationModuleProvider extends ModuleProvider { ...@@ -91,7 +68,7 @@ public class ConfigurationModuleProvider extends ModuleProvider {
this.registerServiceImplementation(IServiceReferenceAlarmRuleConfig.class, new ServiceReferenceAlarmRuleConfig(serviceErrorRateThreshold, serviceAverageResponseTimeThreshold)); this.registerServiceImplementation(IServiceReferenceAlarmRuleConfig.class, new ServiceReferenceAlarmRuleConfig(serviceErrorRateThreshold, serviceAverageResponseTimeThreshold));
this.registerServiceImplementation(IInstanceReferenceAlarmRuleConfig.class, new InstanceReferenceAlarmRuleConfig(instanceErrorRateThreshold, instanceAverageResponseTimeThreshold)); this.registerServiceImplementation(IInstanceReferenceAlarmRuleConfig.class, new InstanceReferenceAlarmRuleConfig(instanceErrorRateThreshold, instanceAverageResponseTimeThreshold));
this.registerServiceImplementation(IApplicationReferenceAlarmRuleConfig.class, new ApplicationReferenceAlarmRuleConfig(applicationErrorRateThreshold, applicationAverageResponseTimeThreshold)); this.registerServiceImplementation(IApplicationReferenceAlarmRuleConfig.class, new ApplicationReferenceAlarmRuleConfig(applicationErrorRateThreshold, applicationAverageResponseTimeThreshold));
this.registerServiceImplementation(IResponseTimeDistributionConfigService.class, new ResponseTimeDistributionConfigService(responseTimeDistributionDuration, responseTimeDistributionMaxDurations)); this.registerServiceImplementation(IResponseTimeDistributionConfigService.class, new ResponseTimeDistributionConfigService(thermodynamicResponseTimeStep, thermodynamicCountOfResponseTimeSteps));
} }
@Override public void start() { @Override public void start() {
......
...@@ -24,18 +24,18 @@ package org.apache.skywalking.apm.collector.configuration.service; ...@@ -24,18 +24,18 @@ package org.apache.skywalking.apm.collector.configuration.service;
public class ResponseTimeDistributionConfigService implements IResponseTimeDistributionConfigService { public class ResponseTimeDistributionConfigService implements IResponseTimeDistributionConfigService {
private final int responseTimeStep; private final int responseTimeStep;
private final int responseTimeMaxStep; private final int countOfResponseTimeSteps;
public ResponseTimeDistributionConfigService(int responseTimeStep, int responseTimeMaxStep) { public ResponseTimeDistributionConfigService(int responseTimeStep, int countOfResponseTimeSteps) {
this.responseTimeStep = responseTimeStep; this.responseTimeStep = responseTimeStep;
this.responseTimeMaxStep = responseTimeMaxStep + 1; this.countOfResponseTimeSteps = countOfResponseTimeSteps + 1;
} }
@Override public int getResponseTimeStep() { @Override public int getResponseTimeStep() {
return responseTimeStep; return responseTimeStep;
} }
@Override public int getResponseTimeMaxStep() { @Override public int getCountOfResponseTimeSteps() {
return responseTimeMaxStep; return countOfResponseTimeSteps;
} }
} }
...@@ -51,7 +51,7 @@ public class ResponseTimeDistributionService { ...@@ -51,7 +51,7 @@ public class ResponseTimeDistributionService {
List<IResponseTimeDistributionUIDAO.ResponseTimeStep> responseTimeSteps = new LinkedList<>(); List<IResponseTimeDistributionUIDAO.ResponseTimeStep> responseTimeSteps = new LinkedList<>();
for (int i = 0; i < durationPoints.size(); i++) { for (int i = 0; i < durationPoints.size(); i++) {
for (int j = 0; j < responseTimeDistributionConfigService.getResponseTimeMaxStep(); j++) { for (int j = 0; j < responseTimeDistributionConfigService.getCountOfResponseTimeSteps(); j++) {
responseTimeSteps.add(new IResponseTimeDistributionUIDAO.ResponseTimeStep(durationPoints.get(i).getPoint(), i, j)); responseTimeSteps.add(new IResponseTimeDistributionUIDAO.ResponseTimeStep(durationPoints.get(i).getPoint(), i, j));
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册