提交 436dd11f 编写于 作者: 公众号-WU双's avatar 公众号-WU双

#31 Configuration optimization-add related files

上级 de11e714
{
"ruleConfiguration": {
"dataSources": [
{
"name": "ds_0",
"password": "123456",
"url": "jdbc:mysql://127.0.0.1:3306/test?serverTimezone=UTC",
"username": "root"
}
],
"destinationDataSources": {
"name": "dt_0",
"password": "123456",
"url": "jdbc:mysql://127.0.0.1:3306/test2?serverTimezone=UTC",
"username": "root"
}
},
"serverConfiguration": {
"blockQueueSize": 10000,
"pushTimeout": 1000,
"concurrency": 3
}
}
\ No newline at end of file
package info.avalon566.shardingscaling.core.config;
import lombok.AllArgsConstructor;
import lombok.Data;
@AllArgsConstructor
@Data
public class ScalingConfiguration {
private RuleConfiguration ruleConfiguration;
private ServerConfiguration serverConfiguration;
}
package info.avalon566.shardingscaling.core.config;
import lombok.Getter;
@Getter
public class ScalingContext {
private static final ScalingContext INSTANCE = new ScalingContext();
private RuleConfiguration ruleConfiguration;
private ServerConfiguration serverConfiguration;
public static ScalingContext getInstance() {
return INSTANCE;
}
public void init(RuleConfiguration ruleConfiguration, ServerConfiguration serverConfiguration) {
this.ruleConfiguration = ruleConfiguration;
this.serverConfiguration = serverConfiguration;
}
}
package info.avalon566.shardingscaling.core.config;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@AllArgsConstructor
@NoArgsConstructor
@Data
public class ServerConfiguration {
private Integer blockQueueSize;
private Integer pushTimeout;
private Integer concurrency;
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册