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
#define TSDB_MSG_TYPE_REG                    1
#define TSDB_MSG_TYPE_REG_RSP                2
S
slguan 已提交
34 35 36 37
#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
S
slguan 已提交
38 39
#define TSDB_MSG_TYPE_RETRIEVE               7
#define TSDB_MSG_TYPE_RETRIEVE_RSP           8
S
slguan 已提交
40

S
slguan 已提交
41
// message from mnode to dnode
S
slguan 已提交
42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60
#define TSDB_MSG_TYPE_MD_CREATE_TABLE        9
#define TSDB_MSG_TYPE_MD_CREATE_TABLE_RSP    10
#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
#define TSDB_MSG_TYPE_MD_CREATE_VNODE_RSP    16
#define TSDB_MSG_TYPE_MD_DROP_VNODE          17
#define TSDB_MSG_TYPE_MD_DROP_VNODE_RSP      18
#define TSDB_MSG_TYPE_MD_ALTER_VNODE         19
#define TSDB_MSG_TYPE_MD_ALTER_VNODE_RSP     20
#define TSDB_MSG_TYPE_MD_DROP_STABLE         21
#define TSDB_MSG_TYPE_MD_DROP_STABLE_RSP     22
#define TSDB_MSG_TYPE_MD_ALTER_STREAM        23
#define TSDB_MSG_TYPE_MD_ALTER_STREAM_RSP    24
#define TSDB_MSG_TYPE_MD_CONFIG_DNODE        25
#define TSDB_MSG_TYPE_MD_CONFIG_DNODE_RSP    26

S
slguan 已提交
61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79
// message from client to mnode
#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
#define TSDB_MSG_TYPE_CM_CREATE_DNODE_RSP    46
#define TSDB_MSG_TYPE_CM_DROP_DNODE          47
#define TSDB_MSG_TYPE_CM_DROP_DNODE_RSP      48
S
slguan 已提交
80 81
#define TSDB_MSG_TYPE_CM_CONFIG_DNODE        TSDB_MSG_TYPE_MD_CONFIG_DNODE
#define TSDB_MSG_TYPE_CM_CONFIG_DNODE_RSP    TSDB_MSG_TYPE_MD_CONFIG_DNODE_RSP
S
slguan 已提交
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
#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
#define TSDB_MSG_TYPE_CM_CREATE_TABLE_RSP    58
#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_META         65
#define TSDB_MSG_TYPE_CM_STABLE_META_RSP     66
#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
#define TSDB_MSG_TYPE_CM_ALTER_STREAM_RSP    70
#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
#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 已提交
114

S
slguan 已提交
115 116 117 118 119 120 121 122 123
// message from dnode to mnode
#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
S
slguan 已提交
124

S
slguan 已提交
125 126 127 128
#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
S
slguan 已提交
129

S
slguan 已提交
130
#define TSDB_MSG_TYPE_MAX                    105
H
hzcheng 已提交
131 132 133 134 135 136 137 138 139 140 141

// 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 已提交
142
  TSDB_MGMT_TABLE_ACCT,
H
hzcheng 已提交
143 144 145
  TSDB_MGMT_TABLE_USER,
  TSDB_MGMT_TABLE_DB,
  TSDB_MGMT_TABLE_TABLE,
146
  TSDB_MGMT_TABLE_DNODE,
S
slguan 已提交
147
  TSDB_MGMT_TABLE_MNODE,
H
hzcheng 已提交
148 149
  TSDB_MGMT_TABLE_VGROUP,
  TSDB_MGMT_TABLE_METRIC,
S
slguan 已提交
150
  TSDB_MGMT_TABLE_MODULE,
H
hzcheng 已提交
151 152
  TSDB_MGMT_TABLE_QUERIES,
  TSDB_MGMT_TABLE_STREAMS,
S
slguan 已提交
153
  TSDB_MGMT_TABLE_CONFIGS,
H
hzcheng 已提交
154
  TSDB_MGMT_TABLE_CONNS,
S
slguan 已提交
155 156
  TSDB_MGMT_TABLE_SCORES,
  TSDB_MGMT_TABLE_GRANTS,
L
lihui 已提交
157
  TSDB_MGMT_TABLE_VNODES,
H
hzcheng 已提交
158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179
  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
slguan 已提交
180 181 182
#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 已提交
183

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

extern char *taosMsg[];

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

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

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

S
slguan 已提交
208
typedef struct {
S
slguan 已提交
209
  int32_t index; // index of failed block in submit blocks
S
slguan 已提交
210 211 212 213 214 215
  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 已提交
216
  int32_t code;         // 0-success, > 0 error code
S
slguan 已提交
217 218 219 220
  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 已提交
221
  SShellSubmitRspBlock failedBlocks[];
S
slguan 已提交
222 223
} SShellSubmitRspMsg;

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

S
slguan 已提交
231
typedef struct {
232
  int32_t  vgId;
S
slguan 已提交
233 234
  int32_t  vnode;  //the index of vnode
  uint32_t ip;
235
} SVnodeDesc;
S
slguan 已提交
236

S
slguan 已提交
237 238
typedef struct {
  int32_t numOfVnodes;
S
slguan 已提交
239
} SMsgDesc;
S
slguan 已提交
240

S
slguan 已提交
241
typedef struct {
S
slguan 已提交
242 243
  int32_t contLen;
  int32_t vgId;
S
slguan 已提交
244
} SMsgHead;
S
slguan 已提交
245 246 247 248

typedef struct {
  int32_t    contLen;
  int32_t    vgId;
S
slguan 已提交
249 250 251 252 253 254 255 256 257 258 259 260 261
  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;
  char       tableId[TSDB_TABLE_ID_LEN + 1];
  char       superTableId[TSDB_TABLE_ID_LEN + 1];
  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 268 269 270
  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
S
slguan 已提交
271 272
  int32_t   contLen;
  int8_t    reserved[16];
S
slguan 已提交
273
  char      schema[];
274
} SCMCreateTableMsg;
H
hzcheng 已提交
275 276

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

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

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

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

H
hzcheng 已提交
304 305 306 307 308 309 310 311 312 313 314
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 已提交
315
  int8_t  accessState;   // Configured only by command
S
slguan 已提交
316
} SAcctCfg;
H
hzcheng 已提交
317 318

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

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

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

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

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

S
slguan 已提交
347
typedef struct {
S
slguan 已提交
348 349
  int32_t contLen;
  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 359 360 361 362

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 已提交
363
   * whether current table schema is up-to-date.
H
hzcheng 已提交
364 365
   *
   * colIdxInBuf is used to denote the index of column in pQuery->colList,
S
slguan 已提交
366
   * this value is invalid in client side, as well as in cache block of vnode either.
H
hzcheng 已提交
367
   */
S
slguan 已提交
368 369 370
  int16_t  colIdx;
  int16_t  colIdxInBuf;
  uint16_t flag;         // denote if it is a tag or not
H
hjxilinx 已提交
371
  char     name[TSDB_COL_NAME_LEN];
H
hzcheng 已提交
372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402
} 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 已提交
403
  int16_t            interResBytes;
H
hzcheng 已提交
404 405
} SSqlFunctionExpr;

S
slguan 已提交
406
typedef struct SColumnFilterInfo {
H
hzcheng 已提交
407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424
  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 已提交
425 426 427 428 429 430 431 432 433 434 435 436 437
} 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 已提交
438 439 440 441

/*
 * enable vnode to understand how to group several tables with different tag;
 */
S
slguan 已提交
442
typedef struct STableSidExtInfo {
H
hzcheng 已提交
443
  int32_t sid;
444
  int64_t uid;
445
  TSKEY   key;   // key for subscription
H
hzcheng 已提交
446
  char    tags[];
S
slguan 已提交
447
} STableSidExtInfo;
H
hzcheng 已提交
448 449 450

/*
 * the outputCols is equalled to or larger than numOfCols
S
slguan 已提交
451
 * e.g., select min(colName), max(colName), avg(colName) from table
H
hzcheng 已提交
452 453 454 455 456
 * the outputCols will be 3 while the numOfCols is 1.
 */
typedef struct {
  int16_t  vnode;
  int32_t  numOfSids;
S
slguan 已提交
457
  uint64_t pSidExtInfo;  // table id & tag info ptr, in windows pointer may
H
hzcheng 已提交
458 459 460 461 462 463 464 465 466 467 468

  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)

469
  int64_t intervalTime;  // time interval for aggregation, in million second
470
  int64_t slidingTime;       // value for sliding window
S
slguan 已提交
471

S
slguan 已提交
472 473
  // tag schema, used to parse tag information in pSidExtInfo
  uint64_t pTagSchema;
H
hzcheng 已提交
474 475 476 477

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

S
slguan 已提交
478
  int16_t  numOfGroupCols;  // num of group by columns
H
hzcheng 已提交
479 480 481 482 483 484 485
  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 已提交
486
  int16_t queryType;        // denote another query process
H
hzcheng 已提交
487 488 489 490 491 492 493 494
  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 已提交
495 496 497 498 499 500 501
  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 已提交
502
} SQueryTableMsg;
H
hzcheng 已提交
503 504 505 506

typedef struct {
  char     code;
  uint64_t qhandle;
S
slguan 已提交
507
} SQueryTableRsp;
H
hzcheng 已提交
508 509 510

typedef struct {
  uint64_t qhandle;
H
hjxilinx 已提交
511
  uint16_t free;
S
slguan 已提交
512
} SRetrieveTableMsg;
H
hzcheng 已提交
513 514 515 516 517 518 519

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 已提交
520
} SRetrieveTableRsp;
H
hzcheng 已提交
521 522 523 524 525 526 527 528 529 530

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 已提交
531
  uint8_t  syncStatus;
S
slguan 已提交
532
  uint8_t  reserved[15];
H
hzcheng 已提交
533 534 535 536 537 538 539
} SVnodeLoad;

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

540 541 542
/*
 * NOTE: sizeof(SVnodeCfg) < TSDB_FILE_HEADER_LEN / 4
 */
H
hzcheng 已提交
543
typedef struct {
S
slguan 已提交
544 545
  char     acct[TSDB_USER_LEN + 1];
  char     db[TSDB_DB_NAME_LEN + 1];
H
hzcheng 已提交
546 547 548 549 550 551 552 553 554 555 556 557 558
  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 已提交
559
  int16_t blocksPerTable;
560 561 562 563 564
  int8_t  compression;
  int8_t  commitLog;
  int8_t  replications;
  int8_t  repStrategy;
  int8_t  loadLatest;  // load into mem or not
H
hjxilinx 已提交
565
  uint8_t precision;   // time resolution
566
  int8_t  reserved[16];
567
} SVnodeCfg, SDbCfg, SCMCreateDbMsg, SCMAlterDbMsg;
H
hzcheng 已提交
568

569
typedef struct {
S
slguan 已提交
570
  char    db[TSDB_TABLE_ID_LEN + 1];
571
  uint8_t ignoreNotExists;
572
} SCMDropDbMsg, SCMUseDbMsg;
H
hzcheng 已提交
573 574 575 576 577 578 579 580 581 582 583

// 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 已提交
584 585 586 587 588 589 590
typedef struct {
  uint32_t moduleStatus;
  uint32_t createdTime;
  uint32_t numOfVnodes;
  uint32_t reserved;
} SDnodeState;

H
hzcheng 已提交
591 592
typedef struct {
  uint32_t   version;
S
slguan 已提交
593
  uint32_t   privateIp;
H
hzcheng 已提交
594
  uint32_t   publicIp;
S
slguan 已提交
595 596 597
  uint32_t   lastReboot;       // time stamp for last reboot
  uint16_t   numOfTotalVnodes; // from config file
  uint16_t   openVnodes;
H
hzcheng 已提交
598
  uint16_t   numOfCores;
S
slguan 已提交
599
  float      diskAvailable;    // GB
H
hzcheng 已提交
600
  uint8_t    alternativeRole;
S
slguan 已提交
601
  uint8_t    reserve[15];
H
hzcheng 已提交
602
  SVnodeLoad load[];
603
} SDMStatusMsg;
H
hzcheng 已提交
604

S
slguan 已提交
605
typedef struct {
S
slguan 已提交
606 607 608 609
  int32_t      code;
  SDnodeState  dnodeState;
  SRpcIpSet    ipList;
  SVnodeAccess vnodeAccess[];
610
} SDMStatusRsp;
S
slguan 已提交
611

H
hzcheng 已提交
612 613 614
typedef struct {
  int32_t    vnode;
  SVnodeCfg  cfg;
615
  SVnodeDesc vpeerDesc[TSDB_MAX_MPEERS];
S
slguan 已提交
616
} SMDCreateVnodeMsg;
H
hzcheng 已提交
617 618

typedef struct {
S
slguan 已提交
619
  char    tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
620 621
  int16_t createFlag;
  char    tags[];
622
} SCMTableInfoMsg;
H
hzcheng 已提交
623 624

typedef struct {
S
slguan 已提交
625 626
  int32_t numOfTables;
  char    tableIds[];
627
} SCMMultiTableInfoMsg;
H
hzcheng 已提交
628

S
slguan 已提交
629
typedef struct {
S
slguan 已提交
630
  char    tableId[TSDB_TABLE_ID_LEN + 1];
631
} SCMSuperTableInfoMsg;
S
slguan 已提交
632 633 634 635

typedef struct {
  int32_t  numOfDnodes;
  uint32_t dnodeIps[];
636
} SCMSuperTableInfoRsp;
S
slguan 已提交
637

S
slguan 已提交
638 639 640
typedef struct {
  int16_t elemLen;

S
slguan 已提交
641
  char    tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
642 643 644 645 646 647 648 649 650 651
  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 已提交
652 653 654 655

  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 已提交
656 657
  int16_t numOfGroupCols;  // num of group by columns
  int32_t groupbyTagColumnList;
S
slguan 已提交
658
} SSuperTableMetaElemMsg;
S
slguan 已提交
659 660

typedef struct {
S
slguan 已提交
661
  int32_t numOfTables;
S
slguan 已提交
662 663 664
  int32_t join;
  int32_t joinCondLen;  // for join condition
  int32_t metaElem[TSDB_MAX_JOIN_TABLE_NUM];
S
slguan 已提交
665
} SSuperTableMetaMsg;
H
hzcheng 已提交
666 667

typedef struct {
668
  SVnodeDesc vpeerDesc[TSDB_VNODES_SUPPORT];
H
hzcheng 已提交
669 670
  int16_t    index;  // used locally
  int32_t    numOfSids;
S
slguan 已提交
671
  int32_t    pSidExtInfoList[];  // offset value of STableSidExtInfo
H
hzcheng 已提交
672 673 674
} SVnodeSidList;

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

H
hjxilinx 已提交
681 682
typedef struct STableMetaMsg {
  char    tableId[TSDB_TABLE_ID_LEN];  // note: This field must be at the front
S
slguan 已提交
683
  int32_t contLen;
H
hjxilinx 已提交
684 685 686 687
  uint8_t numOfTags;
  uint8_t precision;
  uint8_t tableType;
//  uint8_t index : 4;  // used locally
H
hzcheng 已提交
688
  int16_t numOfColumns;
H
hjxilinx 已提交
689
//  int16_t rowSize;  // used locally, calculated in client
S
slguan 已提交
690
  int16_t sversion;
S
slguan 已提交
691
  int8_t  numOfVpeers;
692
  SVnodeDesc vpeerDesc[TSDB_VNODES_SUPPORT];
S
slguan 已提交
693 694
  int32_t  sid;
  int32_t  vgid;
H
hzcheng 已提交
695
  uint64_t uid;
S
slguan 已提交
696
  SSchema  schema[];
H
hjxilinx 已提交
697
} STableMetaMsg;
H
hzcheng 已提交
698

S
slguan 已提交
699
typedef struct SMultiTableMeta {
S
slguan 已提交
700 701
  int32_t    numOfTables;
  int32_t    contLen;
H
hjxilinx 已提交
702
  STableMetaMsg metas[];
S
slguan 已提交
703
} SMultiTableMeta;
S
slguan 已提交
704

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

H
hjxilinx 已提交
722 723 724
typedef struct SCMShowRsp {
  uint64_t      qhandle;
  STableMetaMsg tableMeta;
725
} SCMShowRsp;
S
slguan 已提交
726 727

typedef struct {
S
slguan 已提交
728
  char ip[32];
729
} SCMCreateDnodeMsg, SCMDropDnodeMsg;
H
hzcheng 已提交
730 731

typedef struct {
S
slguan 已提交
732 733 734
  uint32_t dnode;
  int32_t  vnode;
  int32_t  sid;
735
} SDMConfigTableMsg;
H
hzcheng 已提交
736

S
slguan 已提交
737
typedef struct {
S
slguan 已提交
738
  uint32_t dnode;
S
slguan 已提交
739
  int32_t vnode;
740
} SDMConfigVnodeMsg;
H
hzcheng 已提交
741 742

typedef struct {
743 744
  char ip[32];
  char config[64];
S
slguan 已提交
745
} SMDCfgDnodeMsg, SCMCfgDnodeMsg;
H
hzcheng 已提交
746 747

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

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

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

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

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

typedef struct {
  uint32_t  queryId;
  uint32_t  streamId;
  int8_t    killConnection;
  SRpcIpSet ipList;
785
} SCMHeartBeatRsp;
H
hzcheng 已提交
786 787

typedef struct {
S
slguan 已提交
788
  char queryId[TSDB_KILL_MSG_LEN + 1];
789
} SCMKillQueryMsg, SCMKillStreamMsg, SCMKillConnMsg;
H
hzcheng 已提交
790 791

typedef struct {
S
slguan 已提交
792
  int32_t  vnode;
H
hzcheng 已提交
793 794 795
  int32_t  sid;
  uint64_t uid;
  uint64_t stime;  // stream starting time
S
slguan 已提交
796
  int32_t  status;
S
slguan 已提交
797
  char     tableId[TSDB_TABLE_ID_LEN + 1];
798
} SMDAlterStreamMsg;
H
hzcheng 已提交
799

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

#ifdef __cplusplus
}
#endif

#endif