This is an automated email from the ASF dual-hosted git repository.
kimmking pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from 9097894 Merge pull request #7122 from kimmking/observability2
add 51393bd add unit test for shardingsphere-scaling-core (#7119)
No new revisions were added by this update.
Summary of changes:
.../scaling/core/ScalingJobController.java | 6 +-
.../scaling/core/config/ResumeConfiguration.java | 33 -----
.../scaling/core/config/ServerConfiguration.java | 5 +-
.../resume/ZookeeperResumeBreakPointManager.java | 13 +-
.../scaling/core/ScalingJobControllerTest.java | 142 +++++++++++++++++++++
.../core/datasource/DataSourceManagerTest.java | 4 +-
.../executor/channel/DistributionChannelTest.java | 14 +-
.../core}/fixture/FixtureH2DataSourceChecker.java | 2 +-
.../scaling/core/fixture/FixtureH2LogDumper.java} | 32 ++---
.../core/fixture/FixtureH2ScalingEntry.java | 4 +-
.../scaling/core/fixture/FixtureNopImporter.java | 21 +--
.../scaling/core/fixture/FixtureNopManager.java | 4 +
.../AbstractResumeBreakPointManagerTest.java | 11 +-
.../ZookeeperResumeBreakPointManagerTest.java | 107 ++++++++++++++++
.../preparer/resumer/SyncPositionResumerTest.java | 2 +-
.../IncrementalDataScalingTaskTest.java} | 57 +++------
.../scaling/core/util/ReflectionUtil.java | 85 ++++++++++++
.../scaling/mysql/MySQLBinlogDumperTest.java | 6 +-
.../scaling/utils/ReflectionUtil.java | 37 +++++-
19 files changed, 434 insertions(+), 151 deletions(-)
delete mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config/ResumeConfiguration.java
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/ScalingJobControllerTest.java
copy
shardingsphere-scaling/{shardingsphere-scaling-bootstrap/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core}/fixture/FixtureH2DataSourceChecker.java
(96%)
copy
shardingsphere-scaling/shardingsphere-scaling-core/src/{main/java/org/apache/shardingsphere/scaling/core/execute/executor/AbstractShardingScalingExecutor.java
=>
test/java/org/apache/shardingsphere/scaling/core/fixture/FixtureH2LogDumper.java}
(60%)
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/position/resume/ZookeeperResumeBreakPointManagerTest.java
copy
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/{preparer/resumer/SyncPositionResumerTest.java
=> task/incremental/IncrementalDataScalingTaskTest.java} (50%)
