add new request codes

Author: yuz10

lib/resty/rocketmq/core.lua

@@ -31,6 +31,7 @@ local LanguageCode = {
     [9] = "GO",
     [10] = "PHP",
     [11] = "OMS",
+    [12] = "RUST",
 }
 
 _M.CID_RMQ_SYS_PREFIX = 'CID_RMQ_SYS_'
@@ -59,6 +60,7 @@ local REQUEST_CODE = {
     QUERY_CONSUMER_OFFSET = 14,
     UPDATE_CONSUMER_OFFSET = 15,
     UPDATE_AND_CREATE_TOPIC = 17,
+    UPDATE_AND_CREATE_TOPIC_LIST = 18,
     GET_ALL_TOPIC_CONFIG = 21,
     GET_TOPIC_CONFIG_LIST = 22,
     GET_TOPIC_NAME_LIST = 23,
@@ -93,6 +95,7 @@ local REQUEST_CODE = {
     GET_TIMER_METRICS = 61,
     POP_MESSAGE = 200050,
     ACK_MESSAGE = 200051,
+    BATCH_ACK_MESSAGE = 200151,
     PEEK_MESSAGE = 200052,
     CHANGE_MESSAGE_INVISIBLETIME = 200053,
     NOTIFICATION = 200054,
@@ -129,6 +132,7 @@ local REQUEST_CODE = {
     INVOKE_BROKER_TO_GET_CONSUMER_STATUS = 223,
     QUERY_TOPIC_CONSUME_BY_WHO = 300,
     GET_TOPICS_BY_CLUSTER = 224,
+    UPDATE_AND_CREATE_SUBSCRIPTIONGROUP_LIST = 225,
     QUERY_TOPICS_BY_CONSUMER = 343,
     QUERY_SUBSCRIPTION_BY_CONSUMER = 345,
     REGISTER_FILTER_SERVER = 301,
@@ -161,6 +165,7 @@ local REQUEST_CODE = {
     GET_TOPIC_CONFIG = 351,
     GET_SUBSCRIPTIONGROUP_CONFIG = 352,
     UPDATE_AND_GET_GROUP_FORBIDDEN = 353,
+    CHECK_ROCKSDB_CQ_WRITE_PROGRESS = 354,
     LITE_PULL_MESSAGE = 361,
     QUERY_ASSIGNMENT = 400,
     SET_MESSAGE_REQUEST_MODE = 401,
@@ -187,6 +192,27 @@ local REQUEST_CODE = {
     UPDATE_CONTROLLER_CONFIG = 1009,
     GET_CONTROLLER_CONFIG = 1010,
     CLEAN_BROKER_DATA = 1011,
+    CONTROLLER_GET_NEXT_BROKER_ID = 1012,
+    CONTROLLER_APPLY_BROKER_ID = 1013,
+    BROKER_CLOSE_CHANNEL_REQUEST = 1014,
+    CHECK_NOT_ACTIVE_BROKER_REQUEST = 1015,
+    GET_BROKER_LIVE_INFO_REQUEST = 1016,
+    GET_SYNC_STATE_DATA_REQUEST = 1017,
+    RAFT_BROKER_HEART_BEAT_EVENT_REQUEST = 1018,
+    UPDATE_COLD_DATA_FLOW_CTR_CONFIG = 2001,
+    REMOVE_COLD_DATA_FLOW_CTR_CONFIG = 2002,
+    GET_COLD_DATA_FLOW_CTR_INFO = 2003,
+    SET_COMMITLOG_READ_MODE = 2004,
+    AUTH_CREATE_USER = 3001,
+    AUTH_UPDATE_USER = 3002,
+    AUTH_DELETE_USER = 3003,
+    AUTH_GET_USER = 3004,
+    AUTH_LIST_USER = 3005,
+    AUTH_CREATE_ACL = 3006,
+    AUTH_UPDATE_ACL = 3007,
+    AUTH_DELETE_ACL = 3008,
+    AUTH_GET_ACL = 3009,
+    AUTH_LIST_ACL = 3010,
 }
 _M.REQUEST_CODE = REQUEST_CODE