-
Notifications
You must be signed in to change notification settings - Fork 51
/
request_code.go
172 lines (158 loc) · 5.54 KB
/
request_code.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
package rocketmq
const (
// Broker 发送消息
SEND_MESSAGE = 10
// Broker 订阅消息
PULL_MESSAGE = 11
// Broker 查询消息
QUERY_MESSAGE = 12
// Broker 查询Broker Offset
QUERY_BROKER_OFFSET = 13
// Broker 查询Consumer Offset
QUERY_CONSUMER_OFFSET = 14
// Broker 更新Consumer Offset
UPDATE_CONSUMER_OFFSET = 15
// Broker 更新或者增加一个Topic
UPDATE_AND_CREATE_TOPIC = 17
// Broker 获取所有Topic的配置（Slave和Namesrv都会向Master请求此配置）
GET_ALL_TOPIC_CONFIG = 21
// Broker 获取所有Topic配置（Slave和Namesrv都会向Master请求此配置）
GET_TOPIC_CONFIG_LIST = 22
// Broker 获取所有Topic名称列表
GET_TOPIC_NAME_LIST = 23
// Broker 更新Broker上的配置
UPDATE_BROKER_CONFIG = 25
// Broker 获取Broker上的配置
GET_BROKER_CONFIG = 26
// Broker 触发Broker删除文件
TRIGGER_DELETE_FILES = 27
// Broker 获取Broker运行时信息
GET_BROKER_RUNTIME_INFO = 28
// Broker 根据时间查询队列的Offset
SEARCH_OFFSET_BY_TIMESTAMP = 29
// Broker 查询队列最大Offset
GET_MAX_OFFSET = 30
// Broker 查询队列最小Offset
GET_MIN_OFFSET = 31
// Broker 查询队列最早消息对应时间
GET_EARLIEST_MSG_STORETIME = 32
// Broker 根据消息ID来查询消息
VIEW_MESSAGE_BY_ID = 33
// Broker Client向Client发送心跳，并注册自身
HEART_BEAT = 34
// Broker Client注销
UNREGISTER_CLIENT = 35
// Broker Consumer将处理不了的消息发回服务器
CONSUMER_SEND_MSG_BACK = 36
// Broker Commit或者Rollback事务
END_TRANSACTION = 37
// Broker 获取ConsumerId列表通过GroupName
GET_CONSUMER_LIST_BY_GROUP = 38
// Broker 主动向Producer回查事务状态
CHECK_TRANSACTION_STATE = 39
// Broker Broker通知Consumer列表变化
NOTIFY_CONSUMER_IDS_CHANGED = 40
// Broker Consumer向Master锁定队列
LOCK_BATCH_MQ = 41
// Broker Consumer向Master解锁队列
UNLOCK_BATCH_MQ = 42
// Broker 获取所有Consumer Offset
GET_ALL_CONSUMER_OFFSET = 43
// Broker 获取所有定时进度
GET_ALL_DELAY_OFFSET = 45
// Namesrv 向Namesrv追加KV配置
PUT_KV_CONFIG = 100
// Namesrv 从Namesrv获取KV配置
GET_KV_CONFIG = 101
// Namesrv 从Namesrv获取KV配置
DELETE_KV_CONFIG = 102
// Namesrv 注册一个Broker，数据都是持久化的，如果存在则覆盖配置
REGISTER_BROKER = 103
// Namesrv 卸载一个Broker，数据都是持久化的
UNREGISTER_BROKER = 104
// Namesrv 根据Topic获取Broker Name、队列数(包含读队列与写队列)
GET_ROUTEINTO_BY_TOPIC = 105
// Namesrv 获取注册到Name Server的所有Broker集群信息
GET_BROKER_CLUSTER_INFO = 106
UPDATE_AND_CREATE_SUBSCRIPTIONGROUP = 200
GET_ALL_SUBSCRIPTIONGROUP_CONFIG = 201
GET_TOPIC_STATS_INFO = 202
GET_CONSUMER_CONNECTION_LIST = 203
GET_PRODUCER_CONNECTION_LIST = 204
WIPE_WRITE_PERM_OF_BROKER = 205
// 从Name Server获取完整Topic列表
GET_ALL_TOPIC_LIST_FROM_NAMESERVER = 206
// 从Broker删除订阅组
DELETE_SUBSCRIPTIONGROUP = 207
// 从Broker获取消费状态（进度）
GET_CONSUME_STATS = 208
// Suspend Consumer消费过程
SUSPEND_CONSUMER = 209
// Resume Consumer消费过程
RESUME_CONSUMER = 210
// 重置Consumer Offset
RESET_CONSUMER_OFFSET_IN_CONSUMER = 211
// 重置Consumer Offset
RESET_CONSUMER_OFFSET_IN_BROKER = 212
// 调整Consumer线程池数量
ADJUST_CONSUMER_THREAD_POOL = 213
// 查询消息被哪些消费组消费
WHO_CONSUME_THE_MESSAGE = 214
// 从Broker删除Topic配置
DELETE_TOPIC_IN_BROKER = 215
// 从Namesrv删除Topic配置
DELETE_TOPIC_IN_NAMESRV = 216
// Namesrv 通过 project 获取所有的 server ip 信息
GET_KV_CONFIG_BY_VALUE = 217
// Namesrv 删除指定 project group 下的所有 server ip 信息
DELETE_KV_CONFIG_BY_VALUE = 218
// 通过NameSpace获取所有的KV List
GET_KVLIST_BY_NAMESPACE = 219
// offset 重置
RESET_CONSUMER_CLIENT_OFFSET = 220
// 客户端订阅消息
GET_CONSUMER_STATUS_FROM_CLIENT = 221
// 通知 broker 调用 offset 重置处理
INVOKE_BROKER_TO_RESET_OFFSET = 222
// 通知 broker 调用客户端订阅消息处理
INVOKE_BROKER_TO_GET_CONSUMER_STATUS = 223
// Broker 查询topic被谁消费
// 2014-03-21 Add By shijia
QUERY_TOPIC_CONSUME_BY_WHO = 300
// 获取指定集群下的所有 topic
// 2014-03-26
GET_TOPICS_BY_CLUSTER = 224
// 向Broker注册Filter Server
// 2014-04-06 Add By shijia
REGISTER_FILTER_SERVER = 301
// 向Filter Server注册Class
// 2014-04-06 Add By shijia
REGISTER_MESSAGE_FILTER_CLASS = 302
// 根据 topic 和 group 获取消息的时间跨度
QUERY_CONSUME_TIME_SPAN = 303
// 获取所有系统内置 Topic 列表
GET_SYSTEM_TOPIC_LIST_FROM_NS = 304
GET_SYSTEM_TOPIC_LIST_FROM_BROKER = 305
// 清理失效队列
CLEAN_EXPIRED_CONSUMEQUEUE = 306
// 通过Broker查询Consumer内存数据
// 2014-07-19 Add By shijia
GET_CONSUMER_RUNNING_INFO = 307
// 查找被修正 offset (转发组件）
QUERY_CORRECTION_OFFSET = 308
// 通过Broker直接向某个Consumer发送一条消息，并立刻消费，返回结果给broker，再返回给调用方
// 2014-08-11 Add By shijia
CONSUME_MESSAGE_DIRECTLY = 309
// Broker 发送消息，优化网络数据包
SEND_MESSAGE_V2 = 310
// 单元化相关 topic
GET_UNIT_TOPIC_LIST = 311
// 获取含有单元化订阅组的 Topic 列表
GET_HAS_UNIT_SUB_TOPIC_LIST = 312
// 获取含有单元化订阅组的非单元化 Topic 列表
GET_HAS_UNIT_SUB_UNUNIT_TOPIC_LIST = 313
// 克隆某一个组的消费进度到新的组
CLONE_GROUP_OFFSET = 314
// 查看Broker上的各种统计信息
VIEW_BROKER_STATS_DATA = 315
)