This is an automated email from the ASF dual-hosted git repository.
panjuan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from c9e4273 Fix alteruser and createUser syntax (#8201)
add 24ab231 Add shardingsphere-scaling-elasticjob module (#8209)
No new revisions were added by this update.
Summary of changes:
pom.xml | 2 +
.../resources/bin/{start.bat => server_start.bat} | 2 +-
.../resources/bin/{start.sh => server_start.sh} | 5 +-
.../main/resources/bin/{stop.sh => server_stop.sh} | 4 +-
.../resources/bin/{start.bat => worker_start.bat} | 2 +-
.../resources/bin/{start.sh => worker_start.sh} | 5 +-
.../main/resources/bin/{stop.sh => worker_stop.sh} | 4 +-
.../src/main/resources/conf/server.yaml | 4 +-
shardingsphere-scaling/pom.xml | 1 +
.../shardingsphere-scaling-bootstrap/pom.xml | 5 +
.../{Bootstrap.java => ServerBootstrap.java} | 46 ++----
.../shardingsphere/scaling/WorkerBootstrap.java | 62 +++++++
.../scaling/utils/ScalingConfigUtil.java | 52 ++++++
.../src/main/resources/conf/server.yaml | 4 +-
.../scaling/utils/ScalingConfigUtilTest.java | 14 +-
.../scaling/web/HttpServerHandlerTest.java | 27 +++-
.../scaling/web/HttpServerInitializerTest.java | 6 +-
.../scaling/core/config/JobConfiguration.java | 6 +-
.../scaling/core/config/ScalingContext.java | 3 +-
.../scaling/core/constant/ScalingConstant.java | 9 +-
.../execute/executor/channel/ManualBitSet.java | 3 -
.../scaling/core/job/ShardingScalingJob.java | 1 +
.../job/preparer/ShardingScalingJobPreparer.java | 5 +-
.../inventory/InventoryDataScalingTaskGroup.java | 6 +-
.../core/service/AbstractScalingJobService.java | 6 +-
.../service/impl/DistributedScalingJobService.java | 31 ++--
.../scaling/core/spi/ScalingWorker.java | 27 ++--
.../scaling/core/spi/ScalingWorkerLoader.java | 52 ++++++
.../scaling/core/utils/ProxyConfigurationUtil.java | 124 +-------------
.../{ReflectionUtils.java => ReflectionUtil.java} | 7 +-
.../scaling/core/utils/ScalingTaskUtil.java | 6 +-
.../scaling/core/utils/SyncConfigurationUtil.java | 118 ++++++++++++++
.../scaling/core/fixture/FixtureScalingWorker.java | 20 ++-
.../InventoryDataScalingTaskGroupTest.java | 14 ++
.../impl/DistributedScalingJobServiceTest.java | 22 ++-
.../impl/StandaloneScalingJobServiceTest.java | 6 +-
.../scaling/core/spi/ScalingWorkerLoaderTest.java | 56 +++++++
.../core/util/ScalingConfigurationUtil.java | 2 +-
...e.shardingsphere.scaling.core.spi.ScalingWorker | 2 +-
.../shardingsphere-scaling-elasticjob}/pom.xml | 39 ++---
.../elasticjob/ElasticJobScalingWorker.java | 178 +++++++++++++++++++++
.../scaling/elasticjob/job/ScalingElasticJob.java | 67 ++++++++
.../scaling/elasticjob/util/ElasticJobUtils.java | 58 +++++++
...e.shardingsphere.scaling.core.spi.ScalingWorker | 2 +-
44 files changed, 840 insertions(+), 275 deletions(-)
copy
shardingsphere-distribution/shardingsphere-scaling-distribution/src/main/resources/bin/{start.bat
=> server_start.bat} (95%)
copy
shardingsphere-distribution/shardingsphere-scaling-distribution/src/main/resources/bin/{start.sh
=> server_start.sh} (93%)
copy
shardingsphere-distribution/shardingsphere-scaling-distribution/src/main/resources/bin/{stop.sh
=> server_stop.sh} (89%)
rename
shardingsphere-distribution/shardingsphere-scaling-distribution/src/main/resources/bin/{start.bat
=> worker_start.bat} (95%)
rename
shardingsphere-distribution/shardingsphere-scaling-distribution/src/main/resources/bin/{start.sh
=> worker_start.sh} (93%)
rename
shardingsphere-distribution/shardingsphere-scaling-distribution/src/main/resources/bin/{stop.sh
=> worker_stop.sh} (89%)
rename
shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/main/java/org/apache/shardingsphere/scaling/{Bootstrap.java
=> ServerBootstrap.java} (63%)
mode change 100755 => 100644
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/main/java/org/apache/shardingsphere/scaling/WorkerBootstrap.java
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/main/java/org/apache/shardingsphere/scaling/utils/ScalingConfigUtil.java
copy
shardingsphere-governance/shardingsphere-governance-core/shardingsphere-governance-core-common/src/test/java/org/apache/shardingsphere/governance/core/utils/IpUtilsTest.java
=>
shardingsphere-scaling/shardingsphere-scaling-bootstrap/src/test/java/org/apache/shardingsphere/scaling/utils/ScalingConfigUtilTest.java
(68%)
copy
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/spi/typed/TypedSPI.java
=>
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/spi/ScalingWorker.java
(68%)
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/spi/ScalingWorkerLoader.java
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/utils/{ReflectionUtils.java
=> ReflectionUtil.java} (88%)
copy
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/spi/fixture/TypedSPIFixtureImpl.java
=>
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/fixture/FixtureScalingWorker.java
(68%)
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/spi/ScalingWorkerLoaderTest.java
copy
shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-spring/shardingsphere-encrypt-spring-boot-starter/src/main/resources/META-INF/spring.provides
=>
shardingsphere-scaling/shardingsphere-scaling-core/src/test/resources/META-INF/services/org.apache.shardingsphere.scaling.core.spi.ScalingWorker
(92%)
copy {shardingsphere-infra/shardingsphere-infra-common =>
shardingsphere-scaling/shardingsphere-scaling-elasticjob}/pom.xml (65%)
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-elasticjob/src/main/java/org/apache/shardingsphere/scaling/elasticjob/ElasticJobScalingWorker.java
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-elasticjob/src/main/java/org/apache/shardingsphere/scaling/elasticjob/job/ScalingElasticJob.java
create mode 100644
shardingsphere-scaling/shardingsphere-scaling-elasticjob/src/main/java/org/apache/shardingsphere/scaling/elasticjob/util/ElasticJobUtils.java
copy
shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-spring/shardingsphere-encrypt-spring-boot-starter/src/main/resources/META-INF/spring.provides
=>
shardingsphere-scaling/shardingsphere-scaling-elasticjob/src/main/resources/META-INF/services/org.apache.shardingsphere.scaling.core.spi.ScalingWorker
(91%)
