taosmsg.h 21.5 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 24 25
#include <stdint.h>
#include <stdbool.h>

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

// message type
S
dnode  
slguan 已提交
32 33 34 35 36 37
#define TSDB_MSG_TYPE_REG                    1
#define TSDB_MSG_TYPE_REG_RSP                2
#define TSDB_MSG_TYPE_DNODE_SUBMIT           3
#define TSDB_MSG_TYPE_DNODE_SUBMIT_RSP       4
#define TSDB_MSG_TYPE_DNODE_QUERY            5
#define TSDB_MSG_TYPE_DNODE_QUERY_RSP        6
S
slguan 已提交
38 39
#define TSDB_MSG_TYPE_RETRIEVE               7
#define TSDB_MSG_TYPE_RETRIEVE_RSP           8
S
dnode  
slguan 已提交
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
#define TSDB_MSG_TYPE_DNODE_CREATE_TABLE     9
#define TSDB_MSG_TYPE_DNODE_CREATE_TABLE_RSP 10
#define TSDB_MSG_TYPE_DNODE_REMOVE_TABLE     11
#define TSDB_MSG_TYPE_DNODE_REMOVE_TABLE_RSP 12
#define TSDB_MSG_TYPE_DNODE_VPEERS           13
#define TSDB_MSG_TYPE_DNODE_VPEERS_RSP       14
#define TSDB_MSG_TYPE_DNODE_FREE_VNODE       15
#define TSDB_MSG_TYPE_DNODE_FREE_VNODE_RSP   16
#define TSDB_MSG_TYPE_DNODE_CFG              17
#define TSDB_MSG_TYPE_DNODE_CFG_RSP          18
#define TSDB_MSG_TYPE_DNODE_ALTER_STREAM     19
#define TSDB_MSG_TYPE_DNODE_ALTER_STREAM_RSP 20
#define TSDB_MSG_TYPE_SDB_SYNC               21
#define TSDB_MSG_TYPE_SDB_SYNC_RSP           22
#define TSDB_MSG_TYPE_SDB_FORWARD            23
#define TSDB_MSG_TYPE_SDB_FORWARD_RSP        24
#define TSDB_MSG_TYPE_CONNECT                31
#define TSDB_MSG_TYPE_CONNECT_RSP            32
#define TSDB_MSG_TYPE_CREATE_ACCT            33
#define TSDB_MSG_TYPE_CREATE_ACCT_RSP        34
#define TSDB_MSG_TYPE_ALTER_ACCT             35
#define TSDB_MSG_TYPE_ALTER_ACCT_RSP         36
#define TSDB_MSG_TYPE_DROP_ACCT              37
#define TSDB_MSG_TYPE_DROP_ACCT_RSP          38
#define TSDB_MSG_TYPE_CREATE_USER            39
#define TSDB_MSG_TYPE_CREATE_USER_RSP        40
#define TSDB_MSG_TYPE_ALTER_USER             41
#define TSDB_MSG_TYPE_ALTER_USER_RSP         42
#define TSDB_MSG_TYPE_DROP_USER              43
#define TSDB_MSG_TYPE_DROP_USER_RSP          44
#define TSDB_MSG_TYPE_CREATE_MNODE           45
#define TSDB_MSG_TYPE_CREATE_MNODE_RSP       46
#define TSDB_MSG_TYPE_DROP_MNODE             47
#define TSDB_MSG_TYPE_DROP_MNODE_RSP         48
#define TSDB_MSG_TYPE_CREATE_DNODE           49
#define TSDB_MSG_TYPE_CREATE_DNODE_RSP       50
#define TSDB_MSG_TYPE_DROP_DNODE             51
#define TSDB_MSG_TYPE_DROP_DNODE_RSP         52
#define TSDB_MSG_TYPE_ALTER_DNODE            53
#define TSDB_MSG_TYPE_ALTER_DNODE_RSP        54
#define TSDB_MSG_TYPE_CREATE_DB              55
#define TSDB_MSG_TYPE_CREATE_DB_RSP          56
#define TSDB_MSG_TYPE_DROP_DB                57
#define TSDB_MSG_TYPE_DROP_DB_RSP            58
#define TSDB_MSG_TYPE_USE_DB                 59
#define TSDB_MSG_TYPE_USE_DB_RSP             60
#define TSDB_MSG_TYPE_ALTER_DB               61
#define TSDB_MSG_TYPE_ALTER_DB_RSP           62
#define TSDB_MSG_TYPE_CREATE_TABLE           63
#define TSDB_MSG_TYPE_CREATE_TABLE_RSP       64
#define TSDB_MSG_TYPE_DROP_TABLE             65
#define TSDB_MSG_TYPE_DROP_TABLE_RSP         66
#define TSDB_MSG_TYPE_ALTER_TABLE            67
#define TSDB_MSG_TYPE_ALTER_TABLE_RSP        68
#define TSDB_MSG_TYPE_VNODE_CFG              69
#define TSDB_MSG_TYPE_VNODE_CFG_RSP          70
#define TSDB_MSG_TYPE_TABLE_CFG              71
#define TSDB_MSG_TYPE_TABLE_CFG_RSP          72
#define TSDB_MSG_TYPE_TABLE_META             73
#define TSDB_MSG_TYPE_TABLE_META_RSP         74
#define TSDB_MSG_TYPE_STABLE_META            75
#define TSDB_MSG_TYPE_STABLE_META_RSP        76
#define TSDB_MSG_TYPE_MULTI_TABLE_META       77
#define TSDB_MSG_TYPE_MULTI_TABLE_META_RSP   78
#define TSDB_MSG_TYPE_ALTER_STREAM           79
#define TSDB_MSG_TYPE_ALTER_STREAM_RSP       80
#define TSDB_MSG_TYPE_SHOW                   81
#define TSDB_MSG_TYPE_SHOW_RSP               82
#define TSDB_MSG_TYPE_CFG_MNODE              83
#define TSDB_MSG_TYPE_CFG_MNODE_RSP          84
#define TSDB_MSG_TYPE_KILL_QUERY             85
#define TSDB_MSG_TYPE_KILL_QUERY_RSP         86
#define TSDB_MSG_TYPE_KILL_STREAM            87
#define TSDB_MSG_TYPE_KILL_STREAM_RSP        88
#define TSDB_MSG_TYPE_KILL_CONNECTION        89
#define TSDB_MSG_TYPE_KILL_CONNECTION_RSP    90
#define TSDB_MSG_TYPE_HEARTBEAT              91
#define TSDB_MSG_TYPE_HEARTBEAT_RSP          92
#define TSDB_MSG_TYPE_STATUS                 93
#define TSDB_MSG_TYPE_STATUS_RSP             94
#define TSDB_MSG_TYPE_GRANT                  95
#define TSDB_MSG_TYPE_GRANT_RSP              96
#define TSDB_MSG_TYPE_MAX                    97
H
hzcheng 已提交
123 124 125 126 127 128 129 130 131 132 133

// IE type
#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

enum _mgmt_table {
S
slguan 已提交
134
  TSDB_MGMT_TABLE_ACCT,
H
hzcheng 已提交
135 136 137
  TSDB_MGMT_TABLE_USER,
  TSDB_MGMT_TABLE_DB,
  TSDB_MGMT_TABLE_TABLE,
138
  TSDB_MGMT_TABLE_DNODE,
S
slguan 已提交
139
  TSDB_MGMT_TABLE_MNODE,
H
hzcheng 已提交
140 141
  TSDB_MGMT_TABLE_VGROUP,
  TSDB_MGMT_TABLE_METRIC,
S
slguan 已提交
142
  TSDB_MGMT_TABLE_MODULE,
H
hzcheng 已提交
143 144
  TSDB_MGMT_TABLE_QUERIES,
  TSDB_MGMT_TABLE_STREAMS,
S
slguan 已提交
145
  TSDB_MGMT_TABLE_CONFIGS,
H
hzcheng 已提交
146
  TSDB_MGMT_TABLE_CONNS,
S
slguan 已提交
147 148
  TSDB_MGMT_TABLE_SCORES,
  TSDB_MGMT_TABLE_GRANTS,
L
lihui 已提交
149
  TSDB_MGMT_TABLE_VNODES,
H
hzcheng 已提交
150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171
  TSDB_MGMT_TABLE_MAX,
};

#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

#define TSDB_ALTER_TABLE_ADD_COLUMN         5
#define TSDB_ALTER_TABLE_DROP_COLUMN        6

#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

#define TSDB_ALTER_USER_PASSWD         0x1
#define TSDB_ALTER_USER_PRIVILEGES     0x2

#define TSDB_KILL_MSG_LEN              30

S
#1177  
slguan 已提交
172
typedef enum {
S
slguan 已提交
173
  TSDB_TABLE_TYPE_SUPER_TABLE        = 0,  // super table
S
#1177  
slguan 已提交
174
  TSDB_TABLE_TYPE_CHILD_TABLE        = 1,  // table created from super table
S
slguan 已提交
175 176 177 178 179
  TSDB_TABLE_TYPE_NORMAL_TABLE       = 2,  // ordinary table
  TSDB_TABLE_TYPE_STREAM_TABLE       = 3,  // table created from stream computing
  TSDB_TABLE_TYPE_MAX                = 4
} ETableType;

H
hzcheng 已提交
180

S
slguan 已提交
181 182 183
#define TSDB_VN_READ_ACCCESS  ((char)0x1)
#define TSDB_VN_WRITE_ACCCESS ((char)0x2)
#define TSDB_VN_ALL_ACCCESS (TSDB_VN_READ_ACCCESS | TSDB_VN_WRITE_ACCCESS)
H
hzcheng 已提交
184

S
slguan 已提交
185 186 187
#define TSDB_COL_NORMAL                0x0U
#define TSDB_COL_TAG                   0x1U
#define TSDB_COL_JOIN                  0x2U
H
hzcheng 已提交
188 189 190

extern char *taosMsg[];

S
slguan 已提交
191
#pragma pack(push, 1)
H
hzcheng 已提交
192 193

typedef struct {
S
slguan 已提交
194
  int32_t  vnode;
H
hzcheng 已提交
195 196 197 198 199 200 201 202
  int32_t  sid;
  int32_t  sversion;
  uint64_t uid;
  short    numOfRows;
  char     payLoad[];
} SShellSubmitBlock;

typedef struct {
S
slguan 已提交
203 204
  int8_t  import;
  int8_t  reserved[3];
H
hzcheng 已提交
205
  int32_t numOfSid; /* total number of sid */
S
slguan 已提交
206
  char    blks[];   /* numOfSid blocks, each blocks for one table */
H
hzcheng 已提交
207 208
} SShellSubmitMsg;

S
slguan 已提交
209
typedef struct {
S
slguan 已提交
210
  int32_t index; // index of failed block in submit blocks
S
slguan 已提交
211 212 213 214 215 216
  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
} SShellSubmitRspBlock;

typedef struct {
S
slguan 已提交
217
  int32_t code;         // 0-success, > 0 error code
S
slguan 已提交
218 219 220 221 222 223 224
  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;
  SShellSubmitRspBlock *failedBlocks;
} SShellSubmitRspMsg;

S
slguan 已提交
225
typedef struct SSchema {
S
slguan 已提交
226
  uint8_t type;
S
slguan 已提交
227
  char    name[TSDB_COL_NAME_LEN + 1];
S
slguan 已提交
228 229
  int16_t colId;
  int16_t bytes;
S
slguan 已提交
230
} SSchema;
H
hzcheng 已提交
231

S
slguan 已提交
232 233 234 235
typedef struct {
  int32_t  vnode;
  int32_t  sid;
  uint64_t uid;
S
slguan 已提交
236 237
  uint64_t superTableUid;
  int32_t  tableType;
S
slguan 已提交
238 239 240 241
  int32_t  sversion;
  int16_t  numOfColumns;
  int16_t  numOfTags;
  int32_t  tagDataLen;
S
slguan 已提交
242
  int32_t  sqlDataLen;
S
slguan 已提交
243 244
  uint64_t createdTime;
  char     tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
245
  char     superTableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
246
  int8_t   data[];
S
slguan 已提交
247
} SDCreateTableMsg;
S
slguan 已提交
248

H
hzcheng 已提交
249
typedef struct {
S
slguan 已提交
250 251
  char      tableId[TSDB_TABLE_ID_LEN + 1];
  char      db[TSDB_DB_NAME_LEN + 1];
252 253 254 255 256
  int8_t    igExists;
  int16_t   numOfTags;
  int16_t   numOfColumns;
  int16_t   sqlLen;  // the length of SQL, it starts after schema , sql is a null-terminated string
  int16_t   reserved[16];
S
slguan 已提交
257
  SSchema   schema[];
S
slguan 已提交
258
} SCreateTableMsg;
H
hzcheng 已提交
259 260

typedef struct {
S
slguan 已提交
261 262
  char   tableId[TSDB_TABLE_ID_LEN + 1];
  char   db[TSDB_DB_NAME_LEN + 1];
263
  int8_t igNotExists;
H
hzcheng 已提交
264 265 266
} SDropTableMsg;

typedef struct {
S
slguan 已提交
267 268
  char    tableId[TSDB_TABLE_ID_LEN + 1];
  char    db[TSDB_DB_NAME_LEN + 1];
269
  int16_t type; /* operation type   */
H
hzcheng 已提交
270
  char    tagVal[TSDB_MAX_BYTES_PER_ROW];
271
  int8_t  numOfCols; /* number of schema */
S
slguan 已提交
272
  SSchema schema[];
H
hzcheng 已提交
273 274
} SAlterTableMsg;

S
slguan 已提交
275
typedef struct {
S
slguan 已提交
276 277
  char clientVersion[TSDB_VERSION_LEN];
  char msgVersion[TSDB_VERSION_LEN];
S
slguan 已提交
278
  char db[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
279
} SConnectMsg;
S
slguan 已提交
280 281

typedef struct {
S
slguan 已提交
282
  char      acctId[TSDB_ACCT_LEN + 1];
S
slguan 已提交
283 284 285 286
  char      serverVersion[TSDB_VERSION_LEN];
  int8_t    writeAuth;
  int8_t    superAuth;
  SRpcIpSet ipList;
S
slguan 已提交
287
} SConnectRsp;
S
slguan 已提交
288

H
hzcheng 已提交
289 290 291 292 293 294 295 296 297 298 299
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;
S
slguan 已提交
300
  int8_t  accessState;   // Configured only by command
S
slguan 已提交
301
} SAcctCfg;
H
hzcheng 已提交
302 303

typedef struct {
S
slguan 已提交
304 305
  char       user[TSDB_USER_LEN + 1];
  char       pass[TSDB_KEY_LEN + 1];
S
slguan 已提交
306 307
  SAcctCfg cfg;
} SCreateAcctMsg, SAlterAcctMsg;
H
hzcheng 已提交
308 309

typedef struct {
S
slguan 已提交
310
  char user[TSDB_USER_LEN + 1];
S
slguan 已提交
311
} SDropUserMsg, SDropAcctMsg;
S
slguan 已提交
312 313

typedef struct {
S
slguan 已提交
314 315
  char   user[TSDB_USER_LEN + 1];
  char   pass[TSDB_KEY_LEN + 1];
S
slguan 已提交
316 317
  int8_t privilege;
  int8_t flag;
S
slguan 已提交
318
} SCreateUserMsg, SAlterUserMsg;
H
hzcheng 已提交
319

S
slguan 已提交
320
typedef struct {
S
slguan 已提交
321
  char db[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
322
} SMgmtHead;
H
hzcheng 已提交
323 324 325 326 327

typedef struct {
  short    vnode;
  int32_t  sid;
  uint64_t uid;
S
slguan 已提交
328
  char     tableId[TSDB_TABLE_ID_LEN];
S
slguan 已提交
329
} SDRemoveTableMsg;
H
hzcheng 已提交
330

S
slguan 已提交
331
typedef struct {
S
slguan 已提交
332
  int32_t vnode;
S
slguan 已提交
333
} SFreeVnodeMsg;
H
hzcheng 已提交
334 335 336 337 338 339

typedef struct SColIndexEx {
  int16_t colId;
  /*
   * colIdx is the index of column in latest schema of table
   * it is available in the client side. Also used to determine
S
slguan 已提交
340
   * whether current table schema is up-to-date.
H
hzcheng 已提交
341 342
   *
   * colIdxInBuf is used to denote the index of column in pQuery->colList,
S
slguan 已提交
343
   * this value is invalid in client side, as well as in cache block of vnode either.
H
hzcheng 已提交
344
   */
S
slguan 已提交
345 346 347
  int16_t  colIdx;
  int16_t  colIdxInBuf;
  uint16_t flag;         // denote if it is a tag or not
H
hzcheng 已提交
348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378
} SColIndexEx;

/* sql function msg, to describe the message to vnode about sql function
 * operations in select clause */
typedef struct SSqlFuncExprMsg {
  int16_t functionId;
  int16_t numOfParams;

  SColIndexEx colInfo;
  struct ArgElem {
    int16_t argType;
    int16_t argBytes;
    union {
      double  d;
      int64_t i64;
      char *  pz;
    } argValue;
  } arg[3];
} SSqlFuncExprMsg;

typedef struct SSqlBinaryExprInfo {
  struct tSQLBinaryExpr *pBinExpr;    /*  for binary expression */
  int32_t                numOfCols;   /*  binary expression involves the readed number of columns*/
  SColIndexEx *          pReqColumns; /*  source column list */
} SSqlBinaryExprInfo;

typedef struct SSqlFunctionExpr {
  SSqlFuncExprMsg    pBase;
  SSqlBinaryExprInfo pBinExprInfo;
  int16_t            resBytes;
  int16_t            resType;
S
slguan 已提交
379
  int16_t            interResBytes;
H
hzcheng 已提交
380 381
} SSqlFunctionExpr;

S
slguan 已提交
382
typedef struct SColumnFilterInfo {
H
hzcheng 已提交
383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400
  int16_t lowerRelOptr;
  int16_t upperRelOptr;
  int16_t filterOnBinary; /* denote if current column is binary   */

  union {
    struct {
      int64_t lowerBndi;
      int64_t upperBndi;
    };
    struct {
      double lowerBndd;
      double upperBndd;
    };
    struct {
      int64_t pz;
      int64_t len;
    };
  };
S
slguan 已提交
401 402 403 404 405 406 407 408 409 410 411 412 413
} 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 已提交
414 415 416 417

/*
 * enable vnode to understand how to group several tables with different tag;
 */
S
slguan 已提交
418
typedef struct STableSidExtInfo {
H
hzcheng 已提交
419
  int32_t sid;
420
  int64_t uid;
421
  TSKEY   key;   // key for subscription
H
hzcheng 已提交
422
  char    tags[];
S
slguan 已提交
423
} STableSidExtInfo;
H
hzcheng 已提交
424 425 426

/*
 * the outputCols is equalled to or larger than numOfCols
S
slguan 已提交
427
 * e.g., select min(colName), max(colName), avg(colName) from table
H
hzcheng 已提交
428 429 430 431 432
 * the outputCols will be 3 while the numOfCols is 1.
 */
typedef struct {
  int16_t  vnode;
  int32_t  numOfSids;
S
slguan 已提交
433
  uint64_t pSidExtInfo;  // table id & tag info ptr, in windows pointer may
H
hzcheng 已提交
434 435 436 437 438 439 440 441 442 443 444

  uint64_t uid;
  TSKEY    skey;
  TSKEY    ekey;

  int16_t order;
  int16_t orderColId;

  int16_t numOfCols;         // the number of columns will be load from vnode
  char    intervalTimeUnit;  // time interval type, for revisement of interval(1d)

S
slguan 已提交
445
  int64_t nAggTimeInterval;  // time interval for aggregation, in million second
446
  int64_t slidingTime;       // value for sliding window
S
slguan 已提交
447

S
slguan 已提交
448 449
  // tag schema, used to parse tag information in pSidExtInfo
  uint64_t pTagSchema;
H
hzcheng 已提交
450 451 452 453

  int16_t numOfTagsCols;  // required number of tags
  int16_t tagLength;      // tag length in current query

S
slguan 已提交
454
  int16_t  numOfGroupCols;  // num of group by columns
H
hzcheng 已提交
455 456 457 458 459 460 461
  int16_t  orderByIdx;
  int16_t  orderType;  // used in group by xx order by xxx
  uint64_t groupbyTagIds;

  int64_t limit;
  int64_t offset;

S
slguan 已提交
462
  int16_t queryType;        // denote another query process
H
hzcheng 已提交
463 464 465 466 467 468 469 470
  int16_t numOfOutputCols;  // final output columns numbers

  int16_t  interpoType;  // interpolate type
  uint64_t defaultVal;   // default value array list

  int32_t colNameLen;
  int64_t colNameList;

S
slguan 已提交
471 472 473 474 475 476 477
  int64_t pSqlFuncExprs;

  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
  SColumnInfo colList[];
S
slguan 已提交
478
} SQueryTableMsg;
H
hzcheng 已提交
479 480 481 482

typedef struct {
  char     code;
  uint64_t qhandle;
S
slguan 已提交
483
} SQueryTableRsp;
H
hzcheng 已提交
484 485 486

typedef struct {
  uint64_t qhandle;
H
hjxilinx 已提交
487
  uint16_t free;
S
slguan 已提交
488
} SRetrieveTableMsg;
H
hzcheng 已提交
489 490 491 492 493 494 495

typedef struct {
  int32_t numOfRows;
  int16_t precision;
  int64_t offset;  // updated offset value for multi-vnode projection query
  int64_t useconds;
  char    data[];
S
slguan 已提交
496
} SRetrieveTableRsp;
H
hzcheng 已提交
497 498 499 500 501 502 503 504 505 506

typedef struct {
  uint32_t vnode;
  uint32_t vgId;
  uint8_t  status;
  uint8_t  dropStatus;
  uint8_t  accessState;
  int64_t  totalStorage;
  int64_t  compStorage;
  int64_t  pointsWritten;
S
slguan 已提交
507
  uint8_t  syncStatus;
S
slguan 已提交
508
  uint8_t  reserved[15];
H
hzcheng 已提交
509 510 511 512 513 514 515
} SVnodeLoad;

typedef struct {
  uint32_t vnode;
  char     accessState;
} SVnodeAccess;

516 517 518
/*
 * NOTE: sizeof(SVnodeCfg) < TSDB_FILE_HEADER_LEN / 4
 */
H
hzcheng 已提交
519
typedef struct {
S
slguan 已提交
520 521
  char     acct[TSDB_USER_LEN + 1];
  char     db[TSDB_DB_NAME_LEN + 1];
H
hzcheng 已提交
522 523 524 525 526 527 528 529 530 531 532 533 534
  uint32_t vgId;
  int32_t  maxSessions;
  int32_t  cacheBlockSize;
  union {
    int32_t totalBlocks;
    float   fraction;
  } cacheNumOfBlocks;
  int32_t daysPerFile;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
  int32_t daysToKeep;
  int32_t commitTime;
  int32_t rowsInFileBlock;
S
slguan 已提交
535
  int16_t blocksPerTable;
536 537 538 539 540
  int8_t  compression;
  int8_t  commitLog;
  int8_t  replications;
  int8_t  repStrategy;
  int8_t  loadLatest;  // load into mem or not
H
hjxilinx 已提交
541
  uint8_t precision;   // time resolution
542
  int8_t  reserved[16];
S
slguan 已提交
543
} SVnodeCfg, SCreateDbMsg, SDbCfg, SAlterDbMsg;
H
hzcheng 已提交
544

545
typedef struct {
S
slguan 已提交
546
  char    db[TSDB_TABLE_ID_LEN + 1];
547
  uint8_t ignoreNotExists;
S
slguan 已提交
548
} SDropDbMsg, SUseDbMsg;
H
hzcheng 已提交
549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566

// 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;

typedef struct {
  uint32_t   version;
  uint32_t   publicIp;
  uint32_t   lastReboot;  // time stamp for last reboot
  uint16_t   numOfCores;
  uint8_t    alternativeRole;
  uint8_t    reserve;
S
slguan 已提交
567 568 569
  uint16_t   numOfTotalVnodes;  // from config file
  uint16_t   unused;
  float      diskAvailable;  // GB
H
hzcheng 已提交
570 571 572 573 574
  uint32_t   openVnodes;
  char       reserved[16];
  SVnodeLoad load[];
} SStatusMsg;

S
slguan 已提交
575 576 577 578 579
typedef struct {
  int32_t   code;
  SRpcIpSet ipList;
} SStatusRsp;

H
hzcheng 已提交
580 581 582 583 584 585 586 587 588 589
typedef struct {
  uint32_t moduleStatus;
  uint32_t createdTime;
  uint32_t numOfVnodes;
  uint32_t reserved;
} SDnodeState;

// internal message
typedef struct {
  uint32_t destId;
S
slguan 已提交
590
  uint32_t destIp;
S
slguan 已提交
591
  char     tableId[TSDB_UNI_LEN + 1];
S
slguan 已提交
592
  char     empty[3];
S
slguan 已提交
593
  uint8_t  msgType;
H
hzcheng 已提交
594 595 596 597 598 599 600 601 602 603 604 605
  int32_t  msgLen;
  uint8_t  content[0];
} SIntMsg;

typedef struct {
  char spi;
  char encrypt;
  char secret[TSDB_KEY_LEN];  // key is changed if updated
  char cipheringKey[TSDB_KEY_LEN];
} SSecIe;

typedef struct {
S
slguan 已提交
606 607
  int32_t dnode;  //the ID of dnode
  int32_t vnode;  //the index of vnode
S
slguan 已提交
608
  uint32_t ip;
H
hzcheng 已提交
609 610
} SVPeerDesc;

S
slguan 已提交
611 612 613 614 615
typedef struct {
  int32_t numOfVPeers;
  SVPeerDesc vpeerDesc[];
} SVpeerDescArray;

H
hzcheng 已提交
616 617 618 619 620 621 622
typedef struct {
  int32_t    vnode;
  SVnodeCfg  cfg;
  SVPeerDesc vpeerDesc[];
} SVPeersMsg;

typedef struct {
S
slguan 已提交
623
  char    tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
624 625 626
  int16_t createFlag;
  char    tags[];
} STableInfoMsg;
H
hzcheng 已提交
627 628

typedef struct {
S
slguan 已提交
629 630 631
  int32_t numOfTables;
  char    tableIds[];
} SMultiTableInfoMsg;
H
hzcheng 已提交
632

S
slguan 已提交
633
typedef struct {
S
slguan 已提交
634
  char    tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
635 636 637 638 639 640 641
} SSuperTableInfoMsg;

typedef struct {
  int32_t  numOfDnodes;
  uint32_t dnodeIps[];
} SSuperTableInfoRsp;

S
slguan 已提交
642 643 644
typedef struct {
  int16_t elemLen;

S
slguan 已提交
645
  char    tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
646 647 648 649 650 651 652 653 654 655
  int16_t orderIndex;
  int16_t orderType;  // used in group by xx order by xxx

  int16_t rel;  // denotes the relation between condition and table list

  int32_t tableCond;  // offset value of table name condition
  int32_t tableCondLen;

  int32_t cond;  // offset of column query condition
  int32_t condLen;
H
hzcheng 已提交
656 657 658 659

  int16_t tagCols[TSDB_MAX_TAGS + 1];  // required tag columns, plus one is for table name
  int16_t numOfTags;                   // required number of tags

S
slguan 已提交
660 661
  int16_t numOfGroupCols;  // num of group by columns
  int32_t groupbyTagColumnList;
S
slguan 已提交
662
} SSuperTableMetaElemMsg;
S
slguan 已提交
663 664

typedef struct {
S
slguan 已提交
665
  int32_t numOfTables;
S
slguan 已提交
666 667 668
  int32_t join;
  int32_t joinCondLen;  // for join condition
  int32_t metaElem[TSDB_MAX_JOIN_TABLE_NUM];
S
slguan 已提交
669
} SSuperTableMetaMsg;
H
hzcheng 已提交
670 671 672 673 674

typedef struct {
  SVPeerDesc vpeerDesc[TSDB_VNODES_SUPPORT];
  int16_t    index;  // used locally
  int32_t    numOfSids;
S
slguan 已提交
675
  int32_t    pSidExtInfoList[];  // offset value of STableSidExtInfo
H
hzcheng 已提交
676 677 678
} SVnodeSidList;

typedef struct {
S
slguan 已提交
679
  int32_t  numOfTables;
H
hzcheng 已提交
680 681
  int32_t  numOfVnodes;
  uint16_t tagLen; /* tag value length */
S
slguan 已提交
682 683
  int32_t  list[]; /* offset of SVnodeSidList, compared to the SSuperTableMeta struct */
} SSuperTableMeta;
H
hzcheng 已提交
684

S
slguan 已提交
685
typedef struct STableMeta {
S
slguan 已提交
686
  char    tableId[TSDB_TABLE_ID_LEN + 1];  // note: This field must be at the front
S
slguan 已提交
687
  int32_t contLen;
S
slguan 已提交
688 689
  uint8_t numOfTags : 6;
  uint8_t precision : 2;
S
slguan 已提交
690
  uint8_t tableType : 4;
S
slguan 已提交
691
  uint8_t index : 4;  // used locally
H
hzcheng 已提交
692
  int16_t numOfColumns;
S
slguan 已提交
693 694 695 696 697
  int16_t rowSize;  // used locally, calculated in client
  int16_t sversion;
  SVPeerDesc vpeerDesc[TSDB_VNODES_SUPPORT];
  int32_t  sid;
  int32_t  vgid;
H
hzcheng 已提交
698
  uint64_t uid;
S
slguan 已提交
699
  SSchema  schema[];
S
slguan 已提交
700
} STableMeta;
H
hzcheng 已提交
701

S
slguan 已提交
702
typedef struct SMultiTableMeta {
S
slguan 已提交
703 704
  int32_t    numOfTables;
  int32_t    contLen;
S
slguan 已提交
705 706
  STableMeta metas[];
} SMultiTableMeta;
S
slguan 已提交
707

H
hzcheng 已提交
708
typedef struct {
S
slguan 已提交
709
  char name[TSDB_TABLE_ID_LEN + 1];
H
hzcheng 已提交
710 711 712 713 714 715 716 717 718
  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 已提交
719
  int8_t   type;
S
slguan 已提交
720
  char     db[TSDB_DB_NAME_LEN + 1];
H
hzcheng 已提交
721 722 723 724 725 726
  uint16_t payloadLen;
  char     payload[];
} SShowMsg;

typedef struct {
  uint64_t   qhandle;
S
slguan 已提交
727
  STableMeta tableMeta;
S
slguan 已提交
728 729 730
} SShowRsp;

typedef struct {
S
slguan 已提交
731
  char ip[32];
S
slguan 已提交
732
} SCreateMnodeMsg, SDropMnodeMsg, SCreateDnodeMsg, SDropDnodeMsg;
H
hzcheng 已提交
733 734 735 736

typedef struct {
  int32_t vnode;
  int32_t sid;
S
slguan 已提交
737
} STableCfgMsg;
H
hzcheng 已提交
738

S
slguan 已提交
739 740 741
typedef struct {
  int32_t vnode;
} SVpeerCfgMsg;
H
hzcheng 已提交
742 743

typedef struct {
744 745
  char ip[32];
  char config[64];
S
slguan 已提交
746
} SCfgDnodeMsg;
H
hzcheng 已提交
747 748

typedef struct {
S
slguan 已提交
749
  char     sql[TSDB_SHOW_SQL_LEN + 1];
H
hzcheng 已提交
750 751 752
  uint32_t queryId;
  int64_t  useconds;
  int64_t  stime;
S
slguan 已提交
753
} SQueryDesc;
H
hzcheng 已提交
754 755

typedef struct {
S
slguan 已提交
756
  char     sql[TSDB_SHOW_SQL_LEN + 1];
H
hzcheng 已提交
757 758 759 760 761 762 763
  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 已提交
764
} SStreamDesc;
H
hzcheng 已提交
765 766 767

typedef struct {
  int32_t numOfQueries;
S
slguan 已提交
768 769
  SQueryDesc  qdesc[];
} SQqueryList;
H
hzcheng 已提交
770 771 772

typedef struct {
  int32_t numOfStreams;
S
slguan 已提交
773 774
  SStreamDesc  sdesc[];
} SStreamList;
S
slguan 已提交
775 776

typedef struct {
S
slguan 已提交
777 778 779
  SQqueryList qlist;
  SStreamList slist;
} SHeartBeatMsg;
S
slguan 已提交
780 781 782 783 784 785

typedef struct {
  uint32_t  queryId;
  uint32_t  streamId;
  int8_t    killConnection;
  SRpcIpSet ipList;
S
slguan 已提交
786
} SHeartBeatRsp;
H
hzcheng 已提交
787 788

typedef struct {
S
slguan 已提交
789
  char queryId[TSDB_KILL_MSG_LEN + 1];
S
slguan 已提交
790
} SKillQueryMsg, SKillStreamMsg, SKillConnectionMsg;
H
hzcheng 已提交
791 792

typedef struct {
S
slguan 已提交
793
  int32_t  vnode;
H
hzcheng 已提交
794 795 796
  int32_t  sid;
  uint64_t uid;
  uint64_t stime;  // stream starting time
S
slguan 已提交
797
  int32_t  status;
H
hzcheng 已提交
798 799
} SAlterStreamMsg;

S
slguan 已提交
800
#pragma pack(pop)
H
hzcheng 已提交
801 802 803 804 805 806

#ifdef __cplusplus
}
#endif

#endif