Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
DiDi
kafka-manager
提交
c5b1bed7
K
kafka-manager
项目概览
DiDi
/
kafka-manager
10 个月 前同步成功
通知
59
Star
6372
Fork
1229
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
K
kafka-manager
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
c5b1bed7
编写于
5月 18, 2021
作者:
Z
zengqiao
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
简化sd配置枚举类的长度
上级
c3a0dbbe
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
12 addition
and
12 deletion
+12
-12
docs/install_guide/create_mysql_table.sql
docs/install_guide/create_mysql_table.sql
+5
-5
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/gateway/GatewayConfigKeyEnum.java
.../manager/common/bizenum/gateway/GatewayConfigKeyEnum.java
+5
-5
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/gateway/impl/GatewayConfigServiceImpl.java
...ervice/service/gateway/impl/GatewayConfigServiceImpl.java
+2
-2
未找到文件。
docs/install_guide/create_mysql_table.sql
浏览文件 @
c5b1bed7
...
...
@@ -210,11 +210,11 @@ CREATE TABLE `gateway_config` (
PRIMARY
KEY
(
`id`
),
UNIQUE
KEY
`uniq_type_name`
(
`type`
,
`name`
)
)
ENGINE
=
InnoDB
DEFAULT
CHARSET
=
utf8
COMMENT
=
'gateway配置'
;
INSERT
INTO
gateway_config
(
type
,
name
,
value
,
`version`
)
values
(
'SERVICE_DISCOVERY_QUEUE_SIZE'
,
'SERVICE_DISCOVERY_QUEUE_SIZE'
,
100000000
,
1
);
INSERT
INTO
gateway_config
(
type
,
name
,
value
,
`version`
)
values
(
'SERVICE_DISCOVERY_APPID_RATE'
,
'SERVICE_DISCOVERY_APPID_RATE'
,
100000000
,
1
);
INSERT
INTO
gateway_config
(
type
,
name
,
value
,
`version`
)
values
(
'SERVICE_DISCOVERY_IP_RATE'
,
'SERVICE_DISCOVERY_IP_RATE'
,
100000000
,
1
);
INSERT
INTO
gateway_config
(
type
,
name
,
value
,
`version`
)
values
(
'SERVICE_DISCOVERY_SP_RATE'
,
'app_01234567'
,
100000000
,
1
);
INSERT
INTO
gateway_config
(
type
,
name
,
value
,
`version`
)
values
(
'SERVICE_DISCOVERY_SP_RATE'
,
'192.168.0.1'
,
100000000
,
1
);
INSERT
INTO
gateway_config
(
type
,
name
,
value
,
`version`
,
`description`
)
values
(
'SD_QUEUE_SIZE'
,
'SD_QUEUE_SIZE'
,
100000000
,
1
,
'任意集群队列大小'
);
INSERT
INTO
gateway_config
(
type
,
name
,
value
,
`version`
,
`description`
)
values
(
'SD_APP_RATE'
,
'SD_APP_RATE'
,
100000000
,
1
,
'任意一个App限速'
);
INSERT
INTO
gateway_config
(
type
,
name
,
value
,
`version`
,
`description`
)
values
(
'SD_IP_RATE'
,
'SD_IP_RATE'
,
100000000
,
1
,
'任意一个IP限速'
);
INSERT
INTO
gateway_config
(
type
,
name
,
value
,
`version`
,
`description`
)
values
(
'SD_SP_RATE'
,
'app_01234567'
,
100000000
,
1
,
'指定App限速'
);
INSERT
INTO
gateway_config
(
type
,
name
,
value
,
`version`
,
`description`
)
values
(
'SD_SP_RATE'
,
'192.168.0.1'
,
100000000
,
1
,
'指定IP限速'
);
--
-- Table structure for table `heartbeat`
...
...
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/gateway/GatewayConfigKeyEnum.java
浏览文件 @
c5b1bed7
...
...
@@ -5,11 +5,11 @@ package com.xiaojukeji.kafka.manager.common.bizenum.gateway;
* @date 20/7/28
*/
public
enum
GatewayConfigKeyEnum
{
SD_CLUSTER_ID
(
"S
ERVICE_DISCOVERY_CLUSTER_ID"
,
"SERVICE_DISCOVERY
_CLUSTER_ID"
),
SD_QUEUE_SIZE
(
"S
ERVICE_DISCOVERY_QUEUE_SIZE"
,
"SERVICE_DISCOVERY
_QUEUE_SIZE"
),
SD_APP_
ID_RATE
(
"SERVICE_DISCOVERY_APPID_RATE"
,
"SERVICE_DISCOVERY_APPID
_RATE"
),
SD_IP_RATE
(
"S
ERVICE_DISCOVERY_IP_RATE"
,
"SERVICE_DISCOVERY
_IP_RATE"
),
SD_SP_RATE
(
"S
ERVICE_DISCOVERY_SP_RATE"
,
"SERVICE_DISCOVERY
_SP_RATE"
),
SD_CLUSTER_ID
(
"S
D_CLUSTER_ID"
,
"SD
_CLUSTER_ID"
),
SD_QUEUE_SIZE
(
"S
D_QUEUE_SIZE"
,
"SD
_QUEUE_SIZE"
),
SD_APP_
RATE
(
"SD_APP_RATE"
,
"SD_APP
_RATE"
),
SD_IP_RATE
(
"S
D_IP_RATE"
,
"SD
_IP_RATE"
),
SD_SP_RATE
(
"S
D_SP_RATE"
,
"SD
_SP_RATE"
),
;
...
...
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/gateway/impl/GatewayConfigServiceImpl.java
浏览文件 @
c5b1bed7
...
...
@@ -86,8 +86,8 @@ public class GatewayConfigServiceImpl implements GatewayConfigService {
GatewayConfigDO
configDO
=
null
;
try
{
configDO
=
gatewayConfigDao
.
getByConfigTypeAndName
(
GatewayConfigKeyEnum
.
SD_APP_
ID_
RATE
.
getConfigType
(),
GatewayConfigKeyEnum
.
SD_APP_
ID_
RATE
.
getConfigName
()
GatewayConfigKeyEnum
.
SD_APP_RATE
.
getConfigType
(),
GatewayConfigKeyEnum
.
SD_APP_RATE
.
getConfigName
()
);
if
(
ValidateUtils
.
isNull
(
configDO
)
||
configDO
.
getVersion
()
<=
requestVersion
)
{
return
new
AppRateConfig
(
Long
.
MIN_VALUE
,
null
);
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录