chore: update grantsSchema to support connectors

f075652e · kailixu · 82a053e7 · f075652e
显示空白变更内容
内联并排

Showing with 24 addition and 16 deletion

include/common/tgrant.h include/common/tgrant.h +24 -16

未找到文件。
--- a/include/common/tgrant.h
+++ b/include/common/tgrant.h
@@ -26,6 +26,8 @@ extern "C" {
 #include "tgrantCfg.h"
 #endif

+#define GRANTS_COL_MAX_LEN 128
+
 typedef enum {
  TSDB_GRANT_ALL,
  TSDB_GRANT_TIME,
@@ -63,6 +65,12 @@ int32_t grantCheck(EGrantType grant);
      {.name = "cpu_cores", .bytes = 9 + VARSTR_HEADER_SIZE, .type = TSDB_DATA_TYPE_VARCHAR},                 \
      {.name = "speed", .bytes = 9 + VARSTR_HEADER_SIZE, .type = TSDB_DATA_TYPE_VARCHAR},                     \
      {.name = "querytime", .bytes = 9 + VARSTR_HEADER_SIZE, .type = TSDB_DATA_TYPE_VARCHAR},                 \
+      {.name = "opc_da", .bytes = GRANTS_COL_MAX_LEN + VARSTR_HEADER_SIZE, .type = TSDB_DATA_TYPE_VARCHAR},   \
+      {.name = "opc_ua", .bytes = GRANTS_COL_MAX_LEN + VARSTR_HEADER_SIZE, .type = TSDB_DATA_TYPE_VARCHAR},   \
+      {.name = "pi", .bytes = GRANTS_COL_MAX_LEN + VARSTR_HEADER_SIZE, .type = TSDB_DATA_TYPE_VARCHAR},       \
+      {.name = "kafka", .bytes = GRANTS_COL_MAX_LEN + VARSTR_HEADER_SIZE, .type = TSDB_DATA_TYPE_VARCHAR},    \
+      {.name = "influxdb", .bytes = GRANTS_COL_MAX_LEN + VARSTR_HEADER_SIZE, .type = TSDB_DATA_TYPE_VARCHAR}, \
+      {.name = "mqtt", .bytes = GRANTS_COL_MAX_LEN + VARSTR_HEADER_SIZE, .type = TSDB_DATA_TYPE_VARCHAR},     \
  }
 #define GRANT_CFG_ADD
 #define GRANT_CFG_SET