feat: adapt to polaris-java CLIENT_REPORTER plugin for config watch reporting

- Upgrade polaris.version from 2.1.2.0-SNAPSHOT to 2.1.2.0
- Enable clientReporter in ConfigurationModifier.modify()
- Add ClientReporterConfigImpl mock to ConfigurationModifierTest
- Add clientReporter verification to test assertions
pull/1813/head
fishtailfu 1 month ago
parent 859b0258d8
commit 66c32b10ba

@ -67,6 +67,8 @@ public class ConfigurationModifier implements PolarisConfigurationConfigModifier
@Override
public void modify(ConfigurationImpl configuration) {
configuration.getGlobal().getStatReporter().setEnable(false);
// Enable client reporter to report config watch metadata via ReportClient.
configuration.getGlobal().getClientReporter().setEnable(true);
configuration.getConsumer().getOutlierDetection().setWhen(OutlierDetectionConfig.When.never);
configuration.getConsumer().getCircuitBreaker().setEnable(false);

@ -40,6 +40,7 @@ import com.tencent.polaris.factory.config.consumer.CircuitBreakerConfigImpl;
import com.tencent.polaris.factory.config.consumer.ConsumerConfigImpl;
import com.tencent.polaris.factory.config.consumer.OutlierDetectionConfigImpl;
import com.tencent.polaris.factory.config.global.APIConfigImpl;
import com.tencent.polaris.factory.config.global.ClientReporterConfigImpl;
import com.tencent.polaris.factory.config.global.GlobalConfigImpl;
import com.tencent.polaris.factory.config.global.ServerConnectorConfigImpl;
import com.tencent.polaris.factory.config.global.StatReporterConfigImpl;
@ -94,9 +95,11 @@ class ConfigurationModifierTest {
GlobalConfigImpl globalConfig = mock(GlobalConfigImpl.class);
StatReporterConfigImpl statReporter = mock(StatReporterConfigImpl.class);
ClientReporterConfigImpl clientReporter = mock(ClientReporterConfigImpl.class);
ServerConnectorConfigImpl serverConnector = mock(ServerConnectorConfigImpl.class);
APIConfigImpl apiConfig = mock(APIConfigImpl.class);
when(globalConfig.getStatReporter()).thenReturn(statReporter);
when(globalConfig.getClientReporter()).thenReturn(clientReporter);
Mockito.lenient().when(globalConfig.getServerConnector()).thenReturn(serverConnector);
Mockito.lenient().when(globalConfig.getAPI()).thenReturn(apiConfig);
when(configuration.getGlobal()).thenReturn(globalConfig);
@ -153,6 +156,7 @@ class ConfigurationModifierTest {
// Assert
verify(configuration.getGlobal().getStatReporter()).setEnable(false);
verify(configuration.getGlobal().getClientReporter()).setEnable(true);
verify(configuration.getConsumer().getOutlierDetection()).setWhen(OutlierDetectionConfig.When.never);
verify(configuration.getConsumer().getCircuitBreaker()).setEnable(false);
verify(configuration.getConfigFile(), never()).getServerConnector();
@ -176,6 +180,7 @@ class ConfigurationModifierTest {
// Assert
verify(configuration.getGlobal().getStatReporter()).setEnable(false);
verify(configuration.getGlobal().getClientReporter()).setEnable(true);
verify(configuration.getConfigFile(), never()).getServerConnector();
}

Loading…
Cancel
Save