taosmsg.h 21.2 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 51 52 53 54 55
#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
56
#define TSDB_MSG_TYPE_MD_ALTER_STREAM_RSP 24
H
hjxilinx 已提交
57
#define TSDB_MSG_TYPE_MD_CONFIG_DNODE     25
58
#define TSDB_MSG_TYPE_MD_CONFIG_DNODE_RSP 26
S
slguan 已提交
59

S
slguan 已提交
60
// message from client to mnode
H
hjxilinx 已提交
61 62 63 64 65 66 67 68 69 70 71 72 73 74 75
#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
76
#define TSDB_MSG_TYPE_CM_CREATE_DNODE_RSP 46
H
hjxilinx 已提交
77 78 79
#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
80
#define TSDB_MSG_TYPE_CM_CONFIG_DNODE_RSP TSDB_MSG_TYPE_MD_CONFIG_DNODE_RSP
H
hjxilinx 已提交
81 82 83 84 85 86 87 88 89
#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
90
#define TSDB_MSG_TYPE_CM_CREATE_TABLE_RSP 58
H
hjxilinx 已提交
91 92 93 94 95 96 97
#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
98
#define TSDB_MSG_TYPE_CM_STABLE_VGROUP_RSP 66
H
hjxilinx 已提交
99 100 101
#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
102
#define TSDB_MSG_TYPE_CM_ALTER_STREAM_RSP 70
H
hjxilinx 已提交
103 104 105 106 107
#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
108 109 110 111 112
#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 已提交
113

S
slguan 已提交
114
// message from dnode to mnode
115 116 117 118 119 120 121 122 123 124 125 126 127 128 129
#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 已提交
130 131

// IE type
132 133 134 135 136 137 138
#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 已提交
139 140

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

160 161 162 163
#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 已提交
164

165 166
#define TSDB_ALTER_TABLE_ADD_COLUMN 5
#define TSDB_ALTER_TABLE_DROP_COLUMN 6
H
hzcheng 已提交
167

168 169 170 171 172
#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 已提交
173

174 175
#define TSDB_ALTER_USER_PASSWD 0x1
#define TSDB_ALTER_USER_PRIVILEGES 0x2
H
hzcheng 已提交
176

177
#define TSDB_KILL_MSG_LEN 30
H
hzcheng 已提交
178

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

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

extern char *taosMsg[];

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

typedef struct {
H
hjxilinx 已提交
192 193 194 195 196 197 198 199
  int32_t numOfVnodes;
} SMsgDesc;

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

200 201
// Submit message for one table
typedef struct SSubmitBlk {
202 203 204 205 206 207 208
  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[];
209 210 211 212 213 214
} SSubmitBlk;

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

S
slguan 已提交
220
typedef struct {
221 222 223 224
  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 已提交
225 226 227
} SShellSubmitRspBlock;

typedef struct {
228 229 230 231 232
  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 已提交
233
  SShellSubmitRspBlock failedBlocks[];
S
slguan 已提交
234 235
} SShellSubmitRspMsg;

S
slguan 已提交
236
typedef struct SSchema {
S
slguan 已提交
237
  uint8_t type;
H
hjxilinx 已提交
238
  char    name[TSDB_COL_NAME_LEN];
S
slguan 已提交
239 240
  int16_t colId;
  int16_t bytes;
S
slguan 已提交
241
} SSchema;
H
hzcheng 已提交
242

S
slguan 已提交
243
typedef struct {
244
  int32_t  vnode;  // the index of vnode
S
slguan 已提交
245
  uint32_t ip;
246
} SVnodeDesc;
S
slguan 已提交
247

S
slguan 已提交
248
typedef struct {
249 250 251 252 253 254 255 256 257 258 259 260 261 262 263
  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;
  char     tableId[TSDB_TABLE_ID_LEN];
  char     superTableId[TSDB_TABLE_ID_LEN];
  char     data[];
S
slguan 已提交
264
} SMDCreateTableMsg;
S
slguan 已提交
265

H
hzcheng 已提交
266
typedef struct {
267 268 269 270 271 272 273 274 275
  char    tableId[TSDB_TABLE_ID_LEN];
  char    db[TSDB_DB_NAME_LEN];
  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
  int32_t contLen;
  int8_t  reserved[16];
  char    schema[];
276
} SCMCreateTableMsg;
H
hzcheng 已提交
277 278

typedef struct {
279
  char   tableId[TSDB_TABLE_ID_LEN];
280
  int8_t igNotExists;
281
} SCMDropTableMsg;
H
hzcheng 已提交
282 283

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

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

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

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

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

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

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

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

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

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

S
slguan 已提交
356
typedef struct {
357
  int32_t vgId;
S
slguan 已提交
358
} SMDDropVnodeMsg;
H
hzcheng 已提交
359 360 361 362 363 364

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 已提交
365
   * whether current table schema is up-to-date.
H
hzcheng 已提交
366 367
   *
   * colIdxInBuf is used to denote the index of column in pQuery->colList,
S
slguan 已提交
368
   * this value is invalid in client side, as well as in cache block of vnode either.
H
hzcheng 已提交
369
   */
S
slguan 已提交
370 371
  int16_t  colIdx;
  int16_t  colIdxInBuf;
372
  uint16_t flag;  // denote if it is a tag or not
H
hjxilinx 已提交
373
  char     name[TSDB_COL_NAME_LEN];
H
hzcheng 已提交
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
} 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;
402
  SSqlBinaryExprInfo binExprInfo;
H
hzcheng 已提交
403 404
  int16_t            resBytes;
  int16_t            resType;
S
slguan 已提交
405
  int16_t            interResBytes;
H
hzcheng 已提交
406 407
} SSqlFunctionExpr;

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

441
typedef struct STableIdInfo {
H
hzcheng 已提交
442
  int32_t sid;
443
  int64_t uid;
444
  TSKEY   key;  // last accessed ts, for subscription
445
} STableIdInfo;
H
hzcheng 已提交
446

H
hjxilinx 已提交
447 448 449 450 451
typedef struct STimeWindow {
  TSKEY skey;
  TSKEY ekey;
} STimeWindow;

H
hzcheng 已提交
452 453
/*
 * the outputCols is equalled to or larger than numOfCols
S
slguan 已提交
454
 * e.g., select min(colName), max(colName), avg(colName) from table
H
hzcheng 已提交
455 456 457
 * the outputCols will be 3 while the numOfCols is 1.
 */
typedef struct {
458
  SMsgHead    head;
H
hjxilinx 已提交
459
  STimeWindow window;
460 461 462 463 464 465 466 467
  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)
468
  uint16_t    tagCondLen;       // tag length in current query
H
hjxilinx 已提交
469
  uint16_t    nameCondLen;      // table name in/like query expression string length
470 471
  int16_t     numOfGroupCols;   // num of group by columns
  int16_t     orderByIdx;
H
hjxilinx 已提交
472
  int16_t     orderType;        // used in group by xx order by xxx
473 474 475
  uint64_t    groupbyTagIds;
  int64_t     limit;
  int64_t     offset;
476
  uint16_t    queryType;        // denote another query process
477 478 479 480 481 482
  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 已提交
483 484 485 486 487
  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 已提交
488
} SQueryTableMsg;
H
hzcheng 已提交
489 490

typedef struct {
H
hjxilinx 已提交
491
  int32_t  code;
H
hzcheng 已提交
492
  uint64_t qhandle;
S
slguan 已提交
493
} SQueryTableRsp;
H
hzcheng 已提交
494 495

typedef struct {
496
  SMsgHead header;
H
hzcheng 已提交
497
  uint64_t qhandle;
H
hjxilinx 已提交
498
  uint16_t free;
S
slguan 已提交
499
} SRetrieveTableMsg;
H
hzcheng 已提交
500

501
typedef struct SRetrieveTableRsp {
H
hzcheng 已提交
502
  int32_t numOfRows;
503
  int8_t  completed;  // all results are returned to client
H
hzcheng 已提交
504
  int16_t precision;
505
  int64_t offset;  // updated offset value for multi-vnode projection query
H
hzcheng 已提交
506 507
  int64_t useconds;
  char    data[];
S
slguan 已提交
508
} SRetrieveTableRsp;
H
hzcheng 已提交
509 510

typedef struct {
S
slguan 已提交
511
  int32_t vgId;
512
  int32_t vnode;
S
slguan 已提交
513 514 515 516 517 518
  int64_t totalStorage;
  int64_t compStorage;
  int64_t pointsWritten;
  uint8_t status;
  uint8_t syncStatus;
  uint8_t accessState;
519
  uint8_t reserved[5];
H
hzcheng 已提交
520 521 522 523
} SVnodeLoad;

typedef struct {
  uint32_t vnode;
524 525
  uint8_t  accessState;
  uint8_t  reserved[3];
H
hzcheng 已提交
526 527
} SVnodeAccess;

528 529 530
/*
 * NOTE: sizeof(SVnodeCfg) < TSDB_FILE_HEADER_LEN / 4
 */
H
hzcheng 已提交
531
typedef struct {
S
slguan 已提交
532 533
  char     acct[TSDB_USER_LEN + 1];
  char     db[TSDB_DB_NAME_LEN + 1];
H
hzcheng 已提交
534 535 536 537 538 539 540 541 542 543 544 545 546
  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 已提交
547
  int16_t blocksPerTable;
548 549 550 551 552
  int8_t  compression;
  int8_t  commitLog;
  int8_t  replications;
  int8_t  repStrategy;
  int8_t  loadLatest;  // load into mem or not
H
hjxilinx 已提交
553
  uint8_t precision;   // time resolution
554
  int8_t  reserved[16];
555
} SVnodeCfg, SDbCfg, SCMCreateDbMsg, SCMAlterDbMsg;
H
hzcheng 已提交
556

557
typedef struct {
S
slguan 已提交
558
  char    db[TSDB_TABLE_ID_LEN + 1];
559
  uint8_t ignoreNotExists;
560
} SCMDropDbMsg, SCMUseDbMsg;
H
hzcheng 已提交
561 562 563 564 565 566 567 568 569 570 571

// 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 已提交
572
typedef struct {
S
slguan 已提交
573
  int32_t  dnodeId;
S
slguan 已提交
574 575 576 577 578
  uint32_t moduleStatus;
  uint32_t createdTime;
  uint32_t numOfVnodes;
} SDnodeState;

H
hzcheng 已提交
579 580
typedef struct {
  uint32_t   version;
S
slguan 已提交
581 582
  int32_t    dnodeId;
  char       dnodeName[TSDB_DNODE_NAME_LEN];
S
slguan 已提交
583
  uint32_t   privateIp;
H
hzcheng 已提交
584
  uint32_t   publicIp;
585 586
  uint32_t   lastReboot;        // time stamp for last reboot
  uint16_t   numOfTotalVnodes;  // from config file
S
slguan 已提交
587
  uint16_t   openVnodes;
H
hzcheng 已提交
588
  uint16_t   numOfCores;
589
  float      diskAvailable;  // GB
H
hzcheng 已提交
590
  uint8_t    alternativeRole;
S
slguan 已提交
591
  uint8_t    reserve[15];
H
hzcheng 已提交
592
  SVnodeLoad load[];
593
} SDMStatusMsg;
H
hzcheng 已提交
594

S
slguan 已提交
595
typedef struct {
S
slguan 已提交
596
  SRpcIpSet    ipList;
S
slguan 已提交
597
  SDnodeState  dnodeState;
S
slguan 已提交
598
  SVnodeAccess vnodeAccess[];
599
} SDMStatusRsp;
S
slguan 已提交
600

H
hzcheng 已提交
601 602
typedef struct {
  SVnodeCfg  cfg;
603
  SVnodeDesc vpeerDesc[TSDB_MAX_MPEERS];
S
slguan 已提交
604
} SMDCreateVnodeMsg;
H
hzcheng 已提交
605 606

typedef struct {
S
slguan 已提交
607
  char    tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
608 609
  int16_t createFlag;
  char    tags[];
610
} SCMTableInfoMsg;
H
hzcheng 已提交
611 612

typedef struct {
S
slguan 已提交
613 614
  int32_t numOfTables;
  char    tableIds[];
615
} SCMMultiTableInfoMsg;
H
hzcheng 已提交
616

H
hjxilinx 已提交
617 618 619
typedef struct SCMSTableVgroupMsg {
  char tableId[TSDB_TABLE_ID_LEN];
} SCMSTableVgroupMsg;
S
slguan 已提交
620 621 622 623

typedef struct {
  int32_t  numOfDnodes;
  uint32_t dnodeIps[];
H
hjxilinx 已提交
624
} SCMSTableVgroupRspMsg;
S
slguan 已提交
625

S
slguan 已提交
626 627 628
typedef struct {
  int16_t elemLen;

S
slguan 已提交
629
  char    tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
630 631 632 633 634 635 636 637 638 639
  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 已提交
640 641 642 643

  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 已提交
644 645
  int16_t numOfGroupCols;  // num of group by columns
  int32_t groupbyTagColumnList;
S
slguan 已提交
646
} SSuperTableMetaElemMsg;
S
slguan 已提交
647 648

typedef struct {
S
slguan 已提交
649
  int32_t numOfTables;
S
slguan 已提交
650 651 652
  int32_t join;
  int32_t joinCondLen;  // for join condition
  int32_t metaElem[TSDB_MAX_JOIN_TABLE_NUM];
S
slguan 已提交
653
} SSuperTableMetaMsg;
H
hzcheng 已提交
654 655

typedef struct {
656
  SVnodeDesc vpeerDesc[TSDB_VNODES_SUPPORT];
H
hzcheng 已提交
657 658
  int16_t    index;  // used locally
  int32_t    numOfSids;
659
  int32_t    pSidExtInfoList[];  // offset value of STableIdInfo
H
hzcheng 已提交
660 661 662
} SVnodeSidList;

typedef struct {
S
slguan 已提交
663
  int32_t  numOfTables;
H
hzcheng 已提交
664 665
  int32_t  numOfVnodes;
  uint16_t tagLen; /* tag value length */
S
slguan 已提交
666 667
  int32_t  list[]; /* offset of SVnodeSidList, compared to the SSuperTableMeta struct */
} SSuperTableMeta;
H
hzcheng 已提交
668

H
hjxilinx 已提交
669
typedef struct STableMetaMsg {
670 671 672 673 674 675 676 677 678
  int32_t    contLen;
  
  char       tableId[TSDB_TABLE_ID_LEN];       // table id
  char       stableId[TSDB_TABLE_ID_LEN];  // stable name if it is created according to super table
  uint8_t    numOfTags;
  uint8_t    precision;
  uint8_t    tableType;
  int16_t    numOfColumns;
  int16_t    sversion;
679
  int8_t     numOfVpeers;
680
  SVnodeDesc vpeerDesc[TSDB_VNODES_SUPPORT];
681 682 683 684
  int32_t    sid;
  int32_t    vgId;
  uint64_t   uid;
  SSchema    schema[];
H
hjxilinx 已提交
685
} STableMetaMsg;
H
hzcheng 已提交
686

S
slguan 已提交
687
typedef struct SMultiTableMeta {
688 689
  int32_t       numOfTables;
  int32_t       contLen;
H
hjxilinx 已提交
690
  STableMetaMsg metas[];
S
slguan 已提交
691
} SMultiTableMeta;
S
slguan 已提交
692

H
hzcheng 已提交
693
typedef struct {
S
slguan 已提交
694
  char name[TSDB_TABLE_ID_LEN + 1];
H
hzcheng 已提交
695 696 697 698 699 700 701 702 703
  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 已提交
704
  int8_t   type;
S
slguan 已提交
705
  char     db[TSDB_DB_NAME_LEN + 1];
H
hzcheng 已提交
706 707
  uint16_t payloadLen;
  char     payload[];
708
} SCMShowMsg;
H
hzcheng 已提交
709

H
hjxilinx 已提交
710 711 712
typedef struct SCMShowRsp {
  uint64_t      qhandle;
  STableMetaMsg tableMeta;
713
} SCMShowRsp;
S
slguan 已提交
714 715

typedef struct {
S
slguan 已提交
716
  char ip[32];
717
} SCMCreateDnodeMsg, SCMDropDnodeMsg;
H
hzcheng 已提交
718 719

typedef struct {
S
slguan 已提交
720 721 722
  uint32_t dnode;
  int32_t  vnode;
  int32_t  sid;
723
} SDMConfigTableMsg;
H
hzcheng 已提交
724

S
slguan 已提交
725
typedef struct {
S
slguan 已提交
726 727
  uint32_t dnodeId;
  int32_t  vgId;
728
} SDMConfigVnodeMsg;
H
hzcheng 已提交
729 730

typedef struct {
731 732
  char ip[32];
  char config[64];
S
slguan 已提交
733
} SMDCfgDnodeMsg, SCMCfgDnodeMsg;
H
hzcheng 已提交
734 735

typedef struct {
S
slguan 已提交
736
  char     sql[TSDB_SHOW_SQL_LEN + 1];
H
hzcheng 已提交
737 738 739
  uint32_t queryId;
  int64_t  useconds;
  int64_t  stime;
S
slguan 已提交
740
} SQueryDesc;
H
hzcheng 已提交
741 742

typedef struct {
S
slguan 已提交
743
  char     sql[TSDB_SHOW_SQL_LEN + 1];
H
hzcheng 已提交
744 745 746 747 748 749 750
  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 已提交
751
} SStreamDesc;
H
hzcheng 已提交
752 753

typedef struct {
754 755
  int32_t    numOfQueries;
  SQueryDesc qdesc[];
S
slguan 已提交
756
} SQqueryList;
H
hzcheng 已提交
757 758

typedef struct {
759 760
  int32_t     numOfStreams;
  SStreamDesc sdesc[];
S
slguan 已提交
761
} SStreamList;
S
slguan 已提交
762 763

typedef struct {
S
slguan 已提交
764 765
  SQqueryList qlist;
  SStreamList slist;
766
} SCMHeartBeatMsg;
S
slguan 已提交
767 768 769 770 771 772

typedef struct {
  uint32_t  queryId;
  uint32_t  streamId;
  int8_t    killConnection;
  SRpcIpSet ipList;
773
} SCMHeartBeatRsp;
H
hzcheng 已提交
774 775

typedef struct {
S
slguan 已提交
776
  char queryId[TSDB_KILL_MSG_LEN + 1];
777
} SCMKillQueryMsg, SCMKillStreamMsg, SCMKillConnMsg;
H
hzcheng 已提交
778 779

typedef struct {
S
slguan 已提交
780
  int32_t  vnode;
H
hzcheng 已提交
781 782 783
  int32_t  sid;
  uint64_t uid;
  uint64_t stime;  // stream starting time
S
slguan 已提交
784
  int32_t  status;
S
slguan 已提交
785
  char     tableId[TSDB_TABLE_ID_LEN + 1];
786
} SMDAlterStreamMsg;
H
hzcheng 已提交
787

S
slguan 已提交
788
#pragma pack(pop)
H
hzcheng 已提交
789 790 791 792 793 794

#ifdef __cplusplus
}
#endif

#endif