taosmsg.h 20.0 KB
Newer Older
H
hzcheng 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef TDENGINE_TAOSMSG_H
#define TDENGINE_TAOSMSG_H

#ifdef __cplusplus
extern "C" {
#endif

S
#1177  
slguan 已提交
23
#include <stdbool.h>
24
#include <stdint.h>
S
#1177  
slguan 已提交
25

S
slguan 已提交
26
#include "taosdef.h"
H
hjxilinx 已提交
27
#include "taoserror.h"
S
slguan 已提交
28
#include "trpc.h"
H
hzcheng 已提交
29 30

// message type
H
hjxilinx 已提交
31 32 33 34 35 36 37 38
#define TSDB_MSG_TYPE_REG               1
#define TSDB_MSG_TYPE_REG_RSP           2
#define TSDB_MSG_TYPE_SUBMIT            3
#define TSDB_MSG_TYPE_SUBMIT_RSP        4
#define TSDB_MSG_TYPE_QUERY             5
#define TSDB_MSG_TYPE_QUERY_RSP         6
#define TSDB_MSG_TYPE_RETRIEVE          7
#define TSDB_MSG_TYPE_RETRIEVE_RSP      8
S
slguan 已提交
39

S
slguan 已提交
40
// message from mnode to dnode
H
hjxilinx 已提交
41
#define TSDB_MSG_TYPE_MD_CREATE_TABLE     9
42
#define TSDB_MSG_TYPE_MD_CREATE_TABLE_RSP 10
H
hjxilinx 已提交
43 44 45 46 47
#define TSDB_MSG_TYPE_MD_DROP_TABLE       11
#define TSDB_MSG_TYPE_MD_DROP_TABLE_RSP   12
#define TSDB_MSG_TYPE_MD_ALTER_TABLE      13
#define TSDB_MSG_TYPE_MD_ALTER_TABLE_RSP  14
#define TSDB_MSG_TYPE_MD_CREATE_VNODE     15
48
#define TSDB_MSG_TYPE_MD_CREATE_VNODE_RSP 16
H
hjxilinx 已提交
49 50
#define TSDB_MSG_TYPE_MD_DROP_VNODE       17
#define TSDB_MSG_TYPE_MD_DROP_VNODE_RSP   18
S
slguan 已提交
51 52 53 54 55 56
#define TSDB_MSG_TYPE_MD_DROP_STABLE      19
#define TSDB_MSG_TYPE_MD_DROP_STABLE_RSP  20
#define TSDB_MSG_TYPE_MD_ALTER_STREAM     21
#define TSDB_MSG_TYPE_MD_ALTER_STREAM_RSP 22
#define TSDB_MSG_TYPE_MD_CONFIG_DNODE     23
#define TSDB_MSG_TYPE_MD_CONFIG_DNODE_RSP 24
S
slguan 已提交
57

S
slguan 已提交
58
// message from client to mnode
H
hjxilinx 已提交
59 60 61 62 63 64 65 66 67 68 69 70 71 72 73
#define TSDB_MSG_TYPE_CM_CONNECT          31
#define TSDB_MSG_TYPE_CM_CONNECT_RSP      32
#define TSDB_MSG_TYPE_CM_CREATE_ACCT      33
#define TSDB_MSG_TYPE_CM_CREATE_ACCT_RSP  34
#define TSDB_MSG_TYPE_CM_ALTER_ACCT       35
#define TSDB_MSG_TYPE_CM_ALTER_ACCT_RSP   36
#define TSDB_MSG_TYPE_CM_DROP_ACCT        37
#define TSDB_MSG_TYPE_CM_DROP_ACCT_RSP    38
#define TSDB_MSG_TYPE_CM_CREATE_USER      39
#define TSDB_MSG_TYPE_CM_CREATE_USER_RSP  40
#define TSDB_MSG_TYPE_CM_ALTER_USER       41
#define TSDB_MSG_TYPE_CM_ALTER_USER_RSP   42
#define TSDB_MSG_TYPE_CM_DROP_USER        43
#define TSDB_MSG_TYPE_CM_DROP_USER_RSP    44
#define TSDB_MSG_TYPE_CM_CREATE_DNODE     45
74
#define TSDB_MSG_TYPE_CM_CREATE_DNODE_RSP 46
H
hjxilinx 已提交
75 76 77
#define TSDB_MSG_TYPE_CM_DROP_DNODE       47
#define TSDB_MSG_TYPE_CM_DROP_DNODE_RSP   48
#define TSDB_MSG_TYPE_CM_CONFIG_DNODE     TSDB_MSG_TYPE_MD_CONFIG_DNODE
78
#define TSDB_MSG_TYPE_CM_CONFIG_DNODE_RSP TSDB_MSG_TYPE_MD_CONFIG_DNODE_RSP
H
hjxilinx 已提交
79 80 81 82 83 84 85 86 87
#define TSDB_MSG_TYPE_CM_CREATE_DB        49
#define TSDB_MSG_TYPE_CM_CREATE_DB_RSP    50
#define TSDB_MSG_TYPE_CM_DROP_DB          51
#define TSDB_MSG_TYPE_CM_DROP_DB_RSP      52
#define TSDB_MSG_TYPE_CM_USE_DB           53
#define TSDB_MSG_TYPE_CM_USE_DB_RSP       54
#define TSDB_MSG_TYPE_CM_ALTER_DB         55
#define TSDB_MSG_TYPE_CM_ALTER_DB_RSP     56
#define TSDB_MSG_TYPE_CM_CREATE_TABLE     57
88
#define TSDB_MSG_TYPE_CM_CREATE_TABLE_RSP 58
H
hjxilinx 已提交
89 90 91 92 93 94 95
#define TSDB_MSG_TYPE_CM_DROP_TABLE       59
#define TSDB_MSG_TYPE_CM_DROP_TABLE_RSP   60
#define TSDB_MSG_TYPE_CM_ALTER_TABLE      61
#define TSDB_MSG_TYPE_CM_ALTER_TABLE_RSP  62
#define TSDB_MSG_TYPE_CM_TABLE_META       63
#define TSDB_MSG_TYPE_CM_TABLE_META_RSP   64
#define TSDB_MSG_TYPE_CM_STABLE_VGROUP    65
96
#define TSDB_MSG_TYPE_CM_STABLE_VGROUP_RSP 66
H
hjxilinx 已提交
97 98 99
#define TSDB_MSG_TYPE_CM_TABLES_META      67
#define TSDB_MSG_TYPE_CM_TABLES_META_RSP  68
#define TSDB_MSG_TYPE_CM_ALTER_STREAM     69
100
#define TSDB_MSG_TYPE_CM_ALTER_STREAM_RSP 70
H
hjxilinx 已提交
101 102 103 104 105
#define TSDB_MSG_TYPE_CM_SHOW             71
#define TSDB_MSG_TYPE_CM_SHOW_RSP         72
#define TSDB_MSG_TYPE_CM_KILL_QUERY       73
#define TSDB_MSG_TYPE_CM_KILL_QUERY_RSP   74
#define TSDB_MSG_TYPE_CM_KILL_STREAM      75
106 107 108 109 110
#define TSDB_MSG_TYPE_CM_KILL_STREAM_RSP 76
#define TSDB_MSG_TYPE_CM_KILL_CONN 77
#define TSDB_MSG_TYPE_CM_KILL_CONN_RSP 78
#define TSDB_MSG_TYPE_CM_HEARTBEAT 79
#define TSDB_MSG_TYPE_CM_HEARTBEAT_RSP 80
S
slguan 已提交
111

S
slguan 已提交
112
// message from dnode to mnode
113 114 115 116 117 118 119 120 121 122 123 124 125 126 127
#define TSDB_MSG_TYPE_DM_CONFIG_TABLE 91
#define TSDB_MSG_TYPE_DM_CONFIG_TABLE_RSP 92
#define TSDB_MSG_TYPE_DM_CONFIG_VNODE 93
#define TSDB_MSG_TYPE_DM_CONFIG_VNODE_RSP 94
#define TSDB_MSG_TYPE_DM_STATUS 95
#define TSDB_MSG_TYPE_DM_STATUS_RSP 96
#define TSDB_MSG_TYPE_DM_GRANT 97
#define TSDB_MSG_TYPE_DM_GRANT_RSP 98

#define TSDB_MSG_TYPE_SDB_SYNC 101
#define TSDB_MSG_TYPE_SDB_SYNC_RSP 102
#define TSDB_MSG_TYPE_SDB_FORWARD 103
#define TSDB_MSG_TYPE_SDB_FORWARD_RSP 104

#define TSDB_MSG_TYPE_MAX 105
H
hzcheng 已提交
128 129

// IE type
130 131 132 133 134 135 136
#define TSDB_IE_TYPE_SEC 1
#define TSDB_IE_TYPE_META 2
#define TSDB_IE_TYPE_MGMT_IP 3
#define TSDB_IE_TYPE_DNODE_CFG 4
#define TSDB_IE_TYPE_NEW_VERSION 5
#define TSDB_IE_TYPE_DNODE_EXT 6
#define TSDB_IE_TYPE_DNODE_STATE 7
H
hzcheng 已提交
137 138

enum _mgmt_table {
S
slguan 已提交
139
  TSDB_MGMT_TABLE_ACCT,
H
hzcheng 已提交
140 141 142
  TSDB_MGMT_TABLE_USER,
  TSDB_MGMT_TABLE_DB,
  TSDB_MGMT_TABLE_TABLE,
143
  TSDB_MGMT_TABLE_DNODE,
S
slguan 已提交
144
  TSDB_MGMT_TABLE_MNODE,
H
hzcheng 已提交
145 146
  TSDB_MGMT_TABLE_VGROUP,
  TSDB_MGMT_TABLE_METRIC,
S
slguan 已提交
147
  TSDB_MGMT_TABLE_MODULE,
H
hzcheng 已提交
148 149
  TSDB_MGMT_TABLE_QUERIES,
  TSDB_MGMT_TABLE_STREAMS,
S
slguan 已提交
150
  TSDB_MGMT_TABLE_CONFIGS,
H
hzcheng 已提交
151
  TSDB_MGMT_TABLE_CONNS,
S
slguan 已提交
152 153
  TSDB_MGMT_TABLE_SCORES,
  TSDB_MGMT_TABLE_GRANTS,
L
lihui 已提交
154
  TSDB_MGMT_TABLE_VNODES,
H
hzcheng 已提交
155 156 157
  TSDB_MGMT_TABLE_MAX,
};

158 159 160 161
#define TSDB_ALTER_TABLE_ADD_TAG_COLUMN 1
#define TSDB_ALTER_TABLE_DROP_TAG_COLUMN 2
#define TSDB_ALTER_TABLE_CHANGE_TAG_COLUMN 3
#define TSDB_ALTER_TABLE_UPDATE_TAG_VAL 4
H
hzcheng 已提交
162

163 164
#define TSDB_ALTER_TABLE_ADD_COLUMN 5
#define TSDB_ALTER_TABLE_DROP_COLUMN 6
H
hzcheng 已提交
165

166 167 168 169 170
#define TSDB_INTERPO_NONE 0
#define TSDB_INTERPO_NULL 1
#define TSDB_INTERPO_SET_VALUE 2
#define TSDB_INTERPO_LINEAR 3
#define TSDB_INTERPO_PREV 4
H
hzcheng 已提交
171

172 173
#define TSDB_ALTER_USER_PASSWD 0x1
#define TSDB_ALTER_USER_PRIVILEGES 0x2
H
hzcheng 已提交
174

175
#define TSDB_KILL_MSG_LEN 30
H
hzcheng 已提交
176

177
#define TSDB_VN_READ_ACCCESS ((char)0x1)
S
slguan 已提交
178 179
#define TSDB_VN_WRITE_ACCCESS ((char)0x2)
#define TSDB_VN_ALL_ACCCESS (TSDB_VN_READ_ACCCESS | TSDB_VN_WRITE_ACCCESS)
H
hzcheng 已提交
180

181 182 183
#define TSDB_COL_NORMAL 0x0u
#define TSDB_COL_TAG 0x1u
#define TSDB_COL_JOIN 0x2u
H
hzcheng 已提交
184 185 186

extern char *taosMsg[];

S
slguan 已提交
187
#pragma pack(push, 1)
H
hzcheng 已提交
188

189
typedef struct {
J
jtao1735 已提交
190
  char     fqdn[TSDB_FQDN_LEN];
191 192 193
  uint16_t port;
} SIpAddr;

H
hzcheng 已提交
194
typedef struct {
H
hjxilinx 已提交
195 196 197 198 199 200 201 202
  int32_t numOfVnodes;
} SMsgDesc;

typedef struct SMsgHead {
  int32_t contLen;
  int32_t vgId;
} SMsgHead;

203 204
// Submit message for one table
typedef struct SSubmitBlk {
205 206 207 208 209 210 211
  int64_t uid;        // table unique id
  int32_t tid;        // table id
  int32_t padding;    // TODO just for padding here
  int32_t sversion;   // data schema version
  int32_t len;        // data part length, not including the SSubmitBlk head
  int16_t numOfRows;  // total number of rows in current submit block
  char    data[];
212 213 214 215 216 217
} SSubmitBlk;

// Submit message for this TSDB
typedef struct SSubmitMsg {
  SMsgHead   header;
  int32_t    length;
218 219
  int32_t    compressed : 2;
  int32_t    numOfBlocks : 30;
220 221
  SSubmitBlk blocks[];
} SSubmitMsg;
H
hzcheng 已提交
222

S
slguan 已提交
223
typedef struct {
224 225 226 227
  int32_t index;  // index of failed block in submit blocks
  int32_t vnode;  // vnode index of failed block
  int32_t sid;    // table index of failed block
  int32_t code;   // errorcode while write data to vnode, such as not created, dropped, no space, invalid table
S
slguan 已提交
228 229 230
} SShellSubmitRspBlock;

typedef struct {
231 232 233 234 235
  int32_t              code;          // 0-success, > 0 error code
  int32_t              numOfRows;     // number of records the client is trying to write
  int32_t              affectedRows;  // number of records actually written
  int32_t              failedRows;    // number of failed records (exclude duplicate records)
  int32_t              numOfFailedBlocks;
S
slguan 已提交
236
  SShellSubmitRspBlock failedBlocks[];
S
slguan 已提交
237 238
} SShellSubmitRspMsg;

S
slguan 已提交
239
typedef struct SSchema {
S
slguan 已提交
240
  uint8_t type;
S
slguan 已提交
241
  char    name[TSDB_COL_NAME_LEN + 1];
S
slguan 已提交
242 243
  int16_t colId;
  int16_t bytes;
S
slguan 已提交
244
} SSchema;
H
hzcheng 已提交
245

S
slguan 已提交
246
typedef struct {
247 248 249 250 251 252 253 254 255 256 257 258
  int32_t  contLen;
  int32_t  vgId;
  int8_t   tableType;
  int16_t  numOfColumns;
  int16_t  numOfTags;
  int32_t  sid;
  int32_t  sversion;
  int32_t  tagDataLen;
  int32_t  sqlDataLen;
  uint64_t uid;
  uint64_t superTableUid;
  uint64_t createdTime;
S
slguan 已提交
259 260
  char     tableId[TSDB_TABLE_ID_LEN + 1];
  char     superTableId[TSDB_TABLE_ID_LEN + 1];
261
  char     data[];
S
slguan 已提交
262
} SMDCreateTableMsg;
S
slguan 已提交
263

H
hzcheng 已提交
264
typedef struct {
S
slguan 已提交
265 266
  char    tableId[TSDB_TABLE_ID_LEN + 1];
  char    db[TSDB_DB_NAME_LEN + 1];
267
  int8_t  igExists;
S
slguan 已提交
268
  int8_t  getMeta;
269 270 271 272 273 274
  int16_t numOfTags;
  int16_t numOfColumns;
  int16_t sqlLen;  // the length of SQL, it starts after schema , sql is a null-terminated string
  int32_t contLen;
  int8_t  reserved[16];
  char    schema[];
275
} SCMCreateTableMsg;
H
hzcheng 已提交
276 277

typedef struct {
S
slguan 已提交
278
  char   tableId[TSDB_TABLE_ID_LEN + 1];
279
  int8_t igNotExists;
280
} SCMDropTableMsg;
H
hzcheng 已提交
281 282

typedef struct {
S
slguan 已提交
283 284
  char    tableId[TSDB_TABLE_ID_LEN + 1];
  char    db[TSDB_DB_NAME_LEN + 1];
285
  int16_t type; /* operation type   */
H
hzcheng 已提交
286
  char    tagVal[TSDB_MAX_BYTES_PER_ROW];
287
  int8_t  numOfCols; /* number of schema */
S
slguan 已提交
288
  SSchema schema[];
289
} SCMAlterTableMsg;
H
hzcheng 已提交
290

S
slguan 已提交
291
typedef struct {
S
slguan 已提交
292 293
  char clientVersion[TSDB_VERSION_LEN];
  char msgVersion[TSDB_VERSION_LEN];
S
slguan 已提交
294
  char db[TSDB_TABLE_ID_LEN + 1];
295
} SCMConnectMsg;
S
slguan 已提交
296 297

typedef struct {
S
slguan 已提交
298
  char      acctId[TSDB_ACCT_LEN + 1];
S
slguan 已提交
299 300 301 302
  char      serverVersion[TSDB_VERSION_LEN];
  int8_t    writeAuth;
  int8_t    superAuth;
  SRpcIpSet ipList;
303
} SCMConnectRsp;
S
slguan 已提交
304

H
hzcheng 已提交
305 306 307 308 309 310 311 312 313 314 315
typedef struct {
  int32_t maxUsers;
  int32_t maxDbs;
  int32_t maxTimeSeries;
  int32_t maxConnections;
  int32_t maxStreams;
  int32_t maxPointsPerSecond;
  int64_t maxStorage;    // In unit of GB
  int64_t maxQueryTime;  // In unit of hour
  int64_t maxInbound;
  int64_t maxOutbound;
316
  int8_t  accessState;  // Configured only by command
S
slguan 已提交
317
} SAcctCfg;
H
hzcheng 已提交
318 319

typedef struct {
S
slguan 已提交
320 321
  char     user[TSDB_USER_LEN + 1];
  char     pass[TSDB_KEY_LEN + 1];
S
slguan 已提交
322
  SAcctCfg cfg;
323
} SCMCreateAcctMsg, SCMAlterAcctMsg;
H
hzcheng 已提交
324 325

typedef struct {
S
slguan 已提交
326
  char user[TSDB_USER_LEN + 1];
327
} SCMDropUserMsg, SCMDropAcctMsg;
S
slguan 已提交
328 329

typedef struct {
S
slguan 已提交
330 331
  char   user[TSDB_USER_LEN + 1];
  char   pass[TSDB_KEY_LEN + 1];
S
slguan 已提交
332 333
  int8_t privilege;
  int8_t flag;
334
} SCMCreateUserMsg, SCMAlterUserMsg;
H
hzcheng 已提交
335

S
slguan 已提交
336
typedef struct {
S
slguan 已提交
337
  char db[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
338
} SMgmtHead;
H
hzcheng 已提交
339 340

typedef struct {
341 342 343 344 345
  int32_t  contLen;
  int32_t  vgId;
  int32_t  sid;
  uint64_t uid;
  char     tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
346
} SMDDropTableMsg;
H
hzcheng 已提交
347

S
slguan 已提交
348
typedef struct {
S
slguan 已提交
349
  int32_t vgId;
S
slguan 已提交
350
  int64_t uid;
S
slguan 已提交
351
  char    tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
352
} SMDDropSTableMsg;
S
slguan 已提交
353

S
slguan 已提交
354
typedef struct {
355
  int32_t vgId;
S
slguan 已提交
356
} SMDDropVnodeMsg;
H
hzcheng 已提交
357

358
typedef struct SColIndex {
359 360 361
  int16_t  colId;      // column id
  int16_t  colIndex;   // column index in colList if it is a normal column or index in tagColList if a tag
  uint16_t flag;       // denote if it is a tag or a normal column
H
hjxilinx 已提交
362
  char     name[TSDB_COL_NAME_LEN];
363
} SColIndex;
H
hzcheng 已提交
364 365 366

/* sql function msg, to describe the message to vnode about sql function
 * operations in select clause */
H
hjxilinx 已提交
367
typedef struct SSqlFuncMsg {
H
hzcheng 已提交
368 369 370
  int16_t functionId;
  int16_t numOfParams;

371
  SColIndex colInfo;
H
hzcheng 已提交
372 373 374 375 376 377 378 379 380
  struct ArgElem {
    int16_t argType;
    int16_t argBytes;
    union {
      double  d;
      int64_t i64;
      char *  pz;
    } argValue;
  } arg[3];
H
hjxilinx 已提交
381
} SSqlFuncMsg;
H
hzcheng 已提交
382

H
hjxilinx 已提交
383
typedef struct SExprInfo {
384 385
  SSqlFuncMsg base;
  struct tExprNode* pExpr;
H
hjxilinx 已提交
386 387
  int16_t     bytes;
  int16_t     type;
388
  int16_t     interBytes;
H
hjxilinx 已提交
389
} SExprInfo;
H
hzcheng 已提交
390

S
slguan 已提交
391
typedef struct SColumnFilterInfo {
H
hzcheng 已提交
392 393
  int16_t lowerRelOptr;
  int16_t upperRelOptr;
394
  int16_t filterstr;   // denote if current column is char(binary/nchar)
H
hzcheng 已提交
395 396 397 398 399 400 401 402 403 404 405 406 407 408 409

  union {
    struct {
      int64_t lowerBndi;
      int64_t upperBndi;
    };
    struct {
      double lowerBndd;
      double upperBndd;
    };
    struct {
      int64_t pz;
      int64_t len;
    };
  };
S
slguan 已提交
410 411 412 413 414 415 416 417 418 419 420 421 422
} SColumnFilterInfo;

/*
 * for client side struct, we only need the column id, type, bytes are not necessary
 * But for data in vnode side, we need all the following information.
 */
typedef struct SColumnInfo {
  int16_t            colId;
  int16_t            type;
  int16_t            bytes;
  int16_t            numOfFilters;
  SColumnFilterInfo *filters;
} SColumnInfo;
H
hzcheng 已提交
423

424
typedef struct STableIdInfo {
425
  int64_t uid;
426
  int32_t tid;
427
  TSKEY   key;  // last accessed ts, for subscription
428
} STableIdInfo;
H
hzcheng 已提交
429

H
hjxilinx 已提交
430 431 432 433 434
typedef struct STimeWindow {
  TSKEY skey;
  TSKEY ekey;
} STimeWindow;

H
hzcheng 已提交
435 436
/*
 * the outputCols is equalled to or larger than numOfCols
S
slguan 已提交
437
 * e.g., select min(colName), max(colName), avg(colName) from table
H
hzcheng 已提交
438 439 440
 * the outputCols will be 3 while the numOfCols is 1.
 */
typedef struct {
441
  SMsgHead    head;
H
hjxilinx 已提交
442
  STimeWindow window;
443 444 445 446 447 448 449 450
  int32_t     numOfTables;
  int16_t     order;
  int16_t     orderColId;
  int16_t     numOfCols;        // the number of columns will be load from vnode
  int64_t     intervalTime;     // time interval for aggregation, in million second
  int64_t     intervalOffset;   // start offset for interval query
  int64_t     slidingTime;      // value for sliding window
  char        slidingTimeUnit;  // time interval type, for revisement of interval(1d)
451
  uint16_t    tagCondLen;       // tag length in current query
452 453
  int16_t     numOfGroupCols;   // num of group by columns
  int16_t     orderByIdx;
H
hjxilinx 已提交
454
  int16_t     orderType;        // used in group by xx order by xxx
455 456
  int64_t     limit;
  int64_t     offset;
457
  uint16_t    queryType;        // denote another query process
H
hjxilinx 已提交
458
  int16_t     numOfOutput;  // final output columns numbers
weixin_48148422's avatar
weixin_48148422 已提交
459
  int16_t     tagNameRelType;   // relation of tag criteria and tbname criteria
460 461
  int16_t     interpoType;      // interpolate type
  uint64_t    defaultVal;       // default value array list
S
slguan 已提交
462 463 464 465
  int32_t     tsOffset;       // offset value in current msg body, NOTE: ts list is compressed
  int32_t     tsLen;          // total length of ts comp block
  int32_t     tsNumOfBlocks;  // ts comp block numbers
  int32_t     tsOrder;        // ts comp block order
466
  int32_t     numOfTags;      // number of tags columns involved
S
slguan 已提交
467
  SColumnInfo colList[];
S
slguan 已提交
468
} SQueryTableMsg;
H
hzcheng 已提交
469 470

typedef struct {
H
hjxilinx 已提交
471
  int32_t  code;
H
hzcheng 已提交
472
  uint64_t qhandle;
S
slguan 已提交
473
} SQueryTableRsp;
H
hzcheng 已提交
474 475

typedef struct {
476
  SMsgHead header;
H
hzcheng 已提交
477
  uint64_t qhandle;
H
hjxilinx 已提交
478
  uint16_t free;
S
slguan 已提交
479
} SRetrieveTableMsg;
H
hzcheng 已提交
480

481
typedef struct SRetrieveTableRsp {
H
hzcheng 已提交
482
  int32_t numOfRows;
483
  int8_t  completed;  // all results are returned to client
H
hzcheng 已提交
484
  int16_t precision;
485
  int64_t offset;  // updated offset value for multi-vnode projection query
H
hzcheng 已提交
486 487
  int64_t useconds;
  char    data[];
S
slguan 已提交
488
} SRetrieveTableRsp;
H
hzcheng 已提交
489 490

typedef struct {
S
slguan 已提交
491
  int32_t vgId;
S
slguan 已提交
492
  int32_t cfgVersion;
S
slguan 已提交
493 494 495 496
  int64_t totalStorage;
  int64_t compStorage;
  int64_t pointsWritten;
  uint8_t status;
S
slguan 已提交
497
  uint8_t role;
S
slguan 已提交
498
  uint8_t replica;
499
  uint8_t reserved[5];
H
hzcheng 已提交
500 501 502
} SVnodeLoad;

typedef struct {
S
slguan 已提交
503 504
  char     acct[TSDB_USER_LEN + 1];
  char     db[TSDB_DB_NAME_LEN + 1];
H
hzcheng 已提交
505
  int32_t  maxSessions;
S
slguan 已提交
506 507 508 509 510 511 512 513 514 515 516 517 518 519
  int32_t  cacheBlockSize; //MB
  int32_t  totalBlocks;
  int32_t  daysPerFile;
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
  int32_t  daysToKeep;
  int32_t  commitTime;
  int32_t  minRowsPerFileBlock;
  int32_t  maxRowsPerFileBlock;
  int8_t   compression;
  int8_t   commitLog;
  int8_t   replications;
  uint8_t  precision;   // time resolution
  int8_t   ignoreExist;
520
} SCMCreateDbMsg, SCMAlterDbMsg;
H
hzcheng 已提交
521

522
typedef struct {
S
slguan 已提交
523
  char    db[TSDB_TABLE_ID_LEN + 1];
524
  uint8_t ignoreNotExists;
525
} SCMDropDbMsg, SCMUseDbMsg;
H
hzcheng 已提交
526 527 528 529 530 531 532 533 534 535 536

// IMPORTANT: sizeof(SVnodeStatisticInfo) should not exceed
// TSDB_FILE_HEADER_LEN/4 - TSDB_FILE_HEADER_VERSION_SIZE
typedef struct {
  int64_t pointsWritten;  // In unit of points
  int64_t totalStorage;   // In unit of bytes
  int64_t compStorage;    // In unit of bytes
  int64_t queryTime;      // In unit of second ??
  char    reserved[64];
} SVnodeStatisticInfo;

S
slguan 已提交
537 538 539 540 541
typedef struct {
  int32_t  vgId;
  int8_t   accessState;
} SDMVgroupAccess;

S
slguan 已提交
542
typedef struct {
S
slguan 已提交
543
  int32_t  dnodeId;
S
slguan 已提交
544 545
  uint32_t moduleStatus;
  uint32_t numOfVnodes;
S
slguan 已提交
546 547 548 549
} SDMDnodeCfg;

typedef struct {
  int32_t   nodeId;
J
jtao1735 已提交
550
  char      nodeEp[TSDB_FQDN_LEN];
S
slguan 已提交
551 552 553 554 555
} SDMMnodeInfo;

typedef struct {
  int8_t       inUse;
  int8_t       nodeNum;
J
jtao1735 已提交
556
  SDMMnodeInfo nodeInfos[TSDB_MAX_REPLICA];
S
slguan 已提交
557
} SDMMnodeInfos;
S
slguan 已提交
558

H
hzcheng 已提交
559 560
typedef struct {
  uint32_t   version;
S
slguan 已提交
561
  int32_t    dnodeId;
J
jtao1735 已提交
562
  char       dnodeEp[TSDB_FQDN_LEN];
S
slguan 已提交
563
  uint32_t   moduleStatus;
564 565
  uint32_t   lastReboot;        // time stamp for last reboot
  uint16_t   numOfTotalVnodes;  // from config file
S
slguan 已提交
566
  uint16_t   openVnodes;
H
hzcheng 已提交
567
  uint16_t   numOfCores;
568
  float      diskAvailable;  // GB
H
hzcheng 已提交
569
  uint8_t    alternativeRole;
S
slguan 已提交
570
  uint8_t    reserve[15];
H
hzcheng 已提交
571
  SVnodeLoad load[];
572
} SDMStatusMsg;
H
hzcheng 已提交
573

S
slguan 已提交
574
typedef struct {
S
slguan 已提交
575 576 577
  SDMMnodeInfos    mnodes;
  SDMDnodeCfg      dnodeCfg;
  SDMVgroupAccess  vgAccess[];
578
} SDMStatusRsp;
S
slguan 已提交
579

H
hzcheng 已提交
580
typedef struct {
S
slguan 已提交
581
  uint32_t vgId;
S
slguan 已提交
582
  int32_t  cfgVersion;
S
slguan 已提交
583 584
  int32_t  cacheBlockSize;
  int32_t  totalBlocks;
S
slguan 已提交
585 586 587 588 589
  int32_t  maxTables;
  int32_t  daysPerFile;
  int32_t  daysToKeep;
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
S
slguan 已提交
590 591
  int32_t  minRowsPerFileBlock;
  int32_t  maxRowsPerFileBlock;
S
slguan 已提交
592
  int32_t  commitTime;
S
slguan 已提交
593
  int8_t   precision;
S
slguan 已提交
594 595 596
  int8_t   compression;
  int8_t   commitLog;
  int8_t   replications;
S
slguan 已提交
597
  int8_t   wals;
S
slguan 已提交
598 599 600 601 602 603
  int8_t   quorum;
  int8_t   reserved[16];
} SMDVnodeCfg;

typedef struct {
  int32_t  nodeId;
J
jtao1735 已提交
604
  char     nodeEp[TSDB_FQDN_LEN];
S
slguan 已提交
605 606 607 608
} SMDVnodeDesc;

typedef struct {
  SMDVnodeCfg  cfg;
J
jtao1735 已提交
609
  SMDVnodeDesc nodes[TSDB_MAX_REPLICA];
S
slguan 已提交
610
} SMDCreateVnodeMsg;
H
hzcheng 已提交
611 612

typedef struct {
S
slguan 已提交
613
  char    tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
614 615
  int16_t createFlag;
  char    tags[];
616
} SCMTableInfoMsg;
H
hzcheng 已提交
617 618

typedef struct {
S
slguan 已提交
619 620
  int32_t numOfTables;
  char    tableIds[];
621
} SCMMultiTableInfoMsg;
H
hzcheng 已提交
622

H
hjxilinx 已提交
623
typedef struct SCMSTableVgroupMsg {
H
hjxilinx 已提交
624 625
  int32_t numOfTables;
} SCMSTableVgroupMsg, SCMSTableVgroupRspMsg;
S
slguan 已提交
626

627
typedef struct {
S
slguan 已提交
628
  int32_t   vgId;
S
slguan 已提交
629
  int8_t    numOfIps;
S
slguan 已提交
630
  SIpAddr   ipAddr[TSDB_MAX_REPLICA_NUM];
S
slguan 已提交
631
} SCMVgroupInfo;
632

S
slguan 已提交
633
typedef struct {
H
hjxilinx 已提交
634
  int32_t numOfVgroups;
S
slguan 已提交
635
  SCMVgroupInfo vgroups[];
H
hjxilinx 已提交
636 637 638 639 640 641 642 643
} SVgroupsInfo;

//typedef struct {
//  int32_t numOfTables;
//  int32_t join;
//  int32_t joinCondLen;  // for join condition
//  int32_t metaElem[TSDB_MAX_JOIN_TABLE_NUM];
//} SSuperTableMetaMsg;
H
hzcheng 已提交
644

H
hjxilinx 已提交
645
typedef struct STableMetaMsg {
S
slguan 已提交
646
  int32_t       contLen;
S
slguan 已提交
647 648
  char          tableId[TSDB_TABLE_ID_LEN + 1];   // table id
  char          stableId[TSDB_TABLE_ID_LEN + 1];  // stable name if it is created according to super table
S
slguan 已提交
649 650 651 652 653 654 655 656 657
  uint8_t       numOfTags;
  uint8_t       precision;
  uint8_t       tableType;
  int16_t       numOfColumns;
  int16_t       sversion;
  int32_t       sid;
  uint64_t      uid;
  SCMVgroupInfo vgroup;
  SSchema       schema[];
H
hjxilinx 已提交
658
} STableMetaMsg;
H
hzcheng 已提交
659

S
slguan 已提交
660
typedef struct SMultiTableMeta {
661 662
  int32_t       numOfTables;
  int32_t       contLen;
H
hjxilinx 已提交
663
  STableMetaMsg metas[];
S
slguan 已提交
664
} SMultiTableMeta;
S
slguan 已提交
665

H
hzcheng 已提交
666
typedef struct {
S
slguan 已提交
667
  char name[TSDB_TABLE_ID_LEN + 1];
H
hzcheng 已提交
668 669 670 671 672 673 674 675 676
  char data[TSDB_MAX_TAGS_LEN];
} STagData;

/*
 * sql: show tables like '%a_%'
 * payload is the query condition, e.g., '%a_%'
 * payloadLen is the length of payload
 */
typedef struct {
S
slguan 已提交
677
  int8_t   type;
S
slguan 已提交
678
  char     db[TSDB_DB_NAME_LEN + 1];
H
hzcheng 已提交
679 680
  uint16_t payloadLen;
  char     payload[];
681
} SCMShowMsg;
H
hzcheng 已提交
682

H
hjxilinx 已提交
683 684 685
typedef struct SCMShowRsp {
  uint64_t      qhandle;
  STableMetaMsg tableMeta;
686
} SCMShowRsp;
S
slguan 已提交
687 688

typedef struct {
J
jtao1735 已提交
689
  char     ep[TSDB_FQDN_LEN];  // end point, hostname:port
690
} SCMCreateDnodeMsg, SCMDropDnodeMsg;
H
hzcheng 已提交
691 692

typedef struct {
S
slguan 已提交
693 694 695
  uint32_t dnode;
  int32_t  vnode;
  int32_t  sid;
696
} SDMConfigTableMsg;
H
hzcheng 已提交
697

S
slguan 已提交
698
typedef struct {
S
slguan 已提交
699 700
  uint32_t dnodeId;
  int32_t  vgId;
701
} SDMConfigVnodeMsg;
H
hzcheng 已提交
702 703

typedef struct {
J
jtao1735 已提交
704
  char ep[TSDB_FQDN_LEN];  // end point, hostname:port
705
  char config[64];
S
slguan 已提交
706
} SMDCfgDnodeMsg, SCMCfgDnodeMsg;
H
hzcheng 已提交
707 708

typedef struct {
H
hjxilinx 已提交
709
  char     sql[TSDB_SHOW_SQL_LEN];
H
hzcheng 已提交
710 711 712
  uint32_t queryId;
  int64_t  useconds;
  int64_t  stime;
S
slguan 已提交
713
} SQueryDesc;
H
hzcheng 已提交
714 715

typedef struct {
H
hjxilinx 已提交
716
  char     sql[TSDB_SHOW_SQL_LEN];
H
hzcheng 已提交
717 718 719 720 721 722 723
  uint32_t streamId;
  int64_t  num;  // number of computing/cycles
  int64_t  useconds;
  int64_t  ctime;
  int64_t  stime;
  int64_t  slidingTime;
  int64_t  interval;
S
slguan 已提交
724
} SStreamDesc;
H
hzcheng 已提交
725 726

typedef struct {
727
  int32_t    numOfQueries;
S
slguan 已提交
728
} SQqueryList;
H
hzcheng 已提交
729 730

typedef struct {
731
  int32_t     numOfStreams;
S
slguan 已提交
732
} SStreamList;
S
slguan 已提交
733 734

typedef struct {
S
slguan 已提交
735 736
  SQqueryList qlist;
  SStreamList slist;
737
} SCMHeartBeatMsg;
S
slguan 已提交
738 739 740 741 742 743

typedef struct {
  uint32_t  queryId;
  uint32_t  streamId;
  int8_t    killConnection;
  SRpcIpSet ipList;
744
} SCMHeartBeatRsp;
H
hzcheng 已提交
745 746

typedef struct {
S
slguan 已提交
747
  char queryId[TSDB_KILL_MSG_LEN + 1];
748
} SCMKillQueryMsg, SCMKillStreamMsg, SCMKillConnMsg;
H
hzcheng 已提交
749 750

typedef struct {
S
slguan 已提交
751
  int32_t  vnode;
H
hzcheng 已提交
752 753 754
  int32_t  sid;
  uint64_t uid;
  uint64_t stime;  // stream starting time
S
slguan 已提交
755
  int32_t  status;
S
slguan 已提交
756
  char     tableId[TSDB_TABLE_ID_LEN + 1];
757
} SMDAlterStreamMsg;
H
hzcheng 已提交
758

S
slguan 已提交
759
#pragma pack(pop)
H
hzcheng 已提交
760 761 762 763 764 765

#ifdef __cplusplus
}
#endif

#endif