taosmsg.h 20.6 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
31 32 33 34 35 36 37 38 39 40 41

#ifdef TAOS_MESSAGE_C
#define TAOS_DEFINE_MESSAGE_TYPE( name, msg ) msg, msg "-rsp",
char *taosMsg[] = {
  "null",
#else
#define TAOS_DEFINE_MESSAGE_TYPE( name, msg ) name, name##_RSP,
enum {
  TSDB_MESSAGE_NULL = 0,
#endif

42 43 44 45
// message from client to dnode
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_SUBMIT, "submit" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_QUERY, "query" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_FETCH, "fetch" )
46
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_UPDATE_TAG_VAL, "update-tag-val" )
J
jtao1735 已提交
47 48 49
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY1, "dummy1" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY2, "dummy2" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY3, "dummy3" )
S
slguan 已提交
50

S
slguan 已提交
51
// message from mnode to dnode
52 53 54 55 56 57 58 59
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_MD_CREATE_TABLE, "create-table" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_MD_DROP_TABLE, "drop-table" )	
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_MD_ALTER_TABLE, "alter-table" )	
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_MD_CREATE_VNODE, "create-vnode" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_MD_DROP_VNODE, "drop-vnode" )	
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_MD_DROP_STABLE, "drop-stable" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_MD_ALTER_STREAM, "alter-stream" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_MD_CONFIG_DNODE, "config-dnode" )
J
jtao1735 已提交
60 61 62 63
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY4, "dummy4" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY5, "dummy5" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY6, "dummy6" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY7, "dummy7" )
S
slguan 已提交
64

S
slguan 已提交
65
// message from client to mnode
66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_CONNECT, "connect" )	 
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_CREATE_ACCT, "create-acct" )	
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_ALTER_ACCT, "alter-acct" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_DROP_ACCT, "drop-acct" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_CREATE_USER, "create-user" )	
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_ALTER_USER, "alter-user" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_DROP_USER, "drop-user" ) 
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_CREATE_DNODE, "create-dnode" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_DROP_DNODE, "drop-dnode" )   
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_CREATE_DB, "create-db" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_DROP_DB, "drop-db" )	  
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_USE_DB, "use-db" )	 
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_ALTER_DB, "alter-db" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_CREATE_TABLE, "create-table" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_DROP_TABLE, "drop-table" )	
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_ALTER_TABLE, "alter-table" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_TABLE_META, "table-meta" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_STABLE_VGROUP, "stable-vgroup" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_TABLES_META, "tables-meta" )	  
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_ALTER_STREAM, "alter-stream" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_SHOW, "show" )
J
jtao1735 已提交
87
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_RETRIEVE, "retrieve" )     
88 89 90 91 92
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_KILL_QUERY, "kill-query" )	
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_KILL_STREAM, "kill-stream" )	
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_KILL_CONN, "kill-conn" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_CONFIG_DNODE, "cm-config-dnode" ) 
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_HEARTBEAT, "heartbeat" )
J
jtao1735 已提交
93 94 95 96
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY8, "dummy8" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY9, "dummy9" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY10, "dummy10" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY11, "dummy11" )
S
slguan 已提交
97

S
slguan 已提交
98
// message from dnode to mnode
99 100 101 102
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DM_CONFIG_TABLE, "config-table" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DM_CONFIG_VNODE, "config-vnode" )	
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DM_STATUS, "status" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DM_GRANT, "grant" )
S
Shengliang Guan 已提交
103
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DM_AUTH, "auth" )
J
jtao1735 已提交
104 105 106
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY12, "dummy12" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY13, "dummy13" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY14, "dummy14" )
107 108 109 110

#ifndef TAOS_MESSAGE_C
  TSDB_MSG_TYPE_MAX  // 105
#endif
111

112
};
H
hzcheng 已提交
113 114

// IE type
115 116 117 118 119 120 121
#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 已提交
122 123

enum _mgmt_table {
S
slguan 已提交
124
  TSDB_MGMT_TABLE_ACCT,
H
hzcheng 已提交
125 126 127
  TSDB_MGMT_TABLE_USER,
  TSDB_MGMT_TABLE_DB,
  TSDB_MGMT_TABLE_TABLE,
128
  TSDB_MGMT_TABLE_DNODE,
S
slguan 已提交
129
  TSDB_MGMT_TABLE_MNODE,
H
hzcheng 已提交
130 131
  TSDB_MGMT_TABLE_VGROUP,
  TSDB_MGMT_TABLE_METRIC,
S
slguan 已提交
132
  TSDB_MGMT_TABLE_MODULE,
H
hzcheng 已提交
133 134
  TSDB_MGMT_TABLE_QUERIES,
  TSDB_MGMT_TABLE_STREAMS,
S
slguan 已提交
135
  TSDB_MGMT_TABLE_CONFIGS,
H
hzcheng 已提交
136
  TSDB_MGMT_TABLE_CONNS,
S
slguan 已提交
137 138
  TSDB_MGMT_TABLE_SCORES,
  TSDB_MGMT_TABLE_GRANTS,
L
lihui 已提交
139
  TSDB_MGMT_TABLE_VNODES,
S
Shengliang Guan 已提交
140
  TSDB_MGMT_TABLE_STREAMTABLES,
H
hzcheng 已提交
141 142 143
  TSDB_MGMT_TABLE_MAX,
};

144 145
#define TSDB_ALTER_TABLE_ADD_TAG_COLUMN    1
#define TSDB_ALTER_TABLE_DROP_TAG_COLUMN   2
146
#define TSDB_ALTER_TABLE_CHANGE_TAG_COLUMN 3
147
#define TSDB_ALTER_TABLE_UPDATE_TAG_VAL    4
H
hzcheng 已提交
148

149 150
#define TSDB_ALTER_TABLE_ADD_COLUMN        5
#define TSDB_ALTER_TABLE_DROP_COLUMN       6
H
hzcheng 已提交
151

152 153 154 155 156
#define TSDB_FILL_NONE      0
#define TSDB_FILL_NULL      1
#define TSDB_FILL_SET_VALUE 2
#define TSDB_FILL_LINEAR    3
#define TSDB_FILL_PREV      4
H
hzcheng 已提交
157

158 159
#define TSDB_ALTER_USER_PASSWD 0x1
#define TSDB_ALTER_USER_PRIVILEGES 0x2
H
hzcheng 已提交
160

161
#define TSDB_KILL_MSG_LEN 30
H
hzcheng 已提交
162

163
#define TSDB_VN_READ_ACCCESS ((char)0x1)
S
slguan 已提交
164 165
#define TSDB_VN_WRITE_ACCCESS ((char)0x2)
#define TSDB_VN_ALL_ACCCESS (TSDB_VN_READ_ACCCESS | TSDB_VN_WRITE_ACCCESS)
H
hzcheng 已提交
166

167
#define TSDB_COL_NORMAL 0x0u
168 169
#define TSDB_COL_TAG    0x1u
#define TSDB_COL_JOIN   0x2u
H
hzcheng 已提交
170 171 172

extern char *taosMsg[];

S
slguan 已提交
173
#pragma pack(push, 1)
H
hzcheng 已提交
174

175
typedef struct {
J
jtao1735 已提交
176
  char     fqdn[TSDB_FQDN_LEN];
177 178 179
  uint16_t port;
} SIpAddr;

H
hzcheng 已提交
180
typedef struct {
H
hjxilinx 已提交
181 182 183 184 185 186 187 188
  int32_t numOfVnodes;
} SMsgDesc;

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

189 190
// Submit message for one table
typedef struct SSubmitBlk {
191 192 193 194 195 196 197
  uint64_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[];
198 199 200 201 202 203
} SSubmitBlk;

// Submit message for this TSDB
typedef struct SSubmitMsg {
  SMsgHead   header;
  int32_t    length;
204 205
  int32_t    compressed : 2;
  int32_t    numOfBlocks : 30;
206 207
  SSubmitBlk blocks[];
} SSubmitMsg;
H
hzcheng 已提交
208

S
slguan 已提交
209
typedef struct {
210 211 212 213
  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 已提交
214 215 216
} SShellSubmitRspBlock;

typedef struct {
217 218 219 220 221
  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 已提交
222
  SShellSubmitRspBlock failedBlocks[];
S
slguan 已提交
223 224
} SShellSubmitRspMsg;

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

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

H
hzcheng 已提交
251
typedef struct {
S
slguan 已提交
252
  char    tableId[TSDB_TABLE_ID_LEN + 1];
B
Bomin Zhang 已提交
253
  char    db[TSDB_DB_NAME_LEN];
254
  int8_t  igExists;
S
slguan 已提交
255
  int8_t  getMeta;
256 257 258 259 260 261
  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[];
262
} SCMCreateTableMsg;
H
hzcheng 已提交
263 264

typedef struct {
S
slguan 已提交
265
  char   tableId[TSDB_TABLE_ID_LEN + 1];
266
  int8_t igNotExists;
267
} SCMDropTableMsg;
H
hzcheng 已提交
268 269

typedef struct {
S
slguan 已提交
270
  char    tableId[TSDB_TABLE_ID_LEN + 1];
B
Bomin Zhang 已提交
271
  char    db[TSDB_DB_NAME_LEN];
272
  int16_t type; /* operation type   */
273 274
  int16_t numOfCols; /* number of schema */
  int32_t tagValLen;
S
slguan 已提交
275
  SSchema schema[];
276 277
  // tagVal is padded after schema
  // char    tagVal[];
278
} SCMAlterTableMsg;
H
hzcheng 已提交
279

280 281 282 283 284 285 286 287 288 289 290 291
typedef struct {
  SMsgHead  head;
  int64_t   uid;
  int32_t   tid;
  int16_t   tversion;
  int16_t   colId;
  int16_t   type;
  int16_t   bytes;
  int32_t   tagValLen;
  char      data[];
} SUpdateTableTagValMsg;

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 {
B
Bomin Zhang 已提交
299
  char      acctId[TSDB_ACCT_LEN];
S
slguan 已提交
300 301 302
  char      serverVersion[TSDB_VERSION_LEN];
  int8_t    writeAuth;
  int8_t    superAuth;
S
Shengliang Guan 已提交
303 304 305
  int8_t    reserved1;
  int8_t    reserved2;
  int32_t   connId;
S
slguan 已提交
306
  SRpcIpSet ipList;
307
} SCMConnectRsp;
S
slguan 已提交
308

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

typedef struct {
B
Bomin Zhang 已提交
324 325
  char     user[TSDB_USER_LEN];
  char     pass[TSDB_KEY_LEN];
S
slguan 已提交
326
  SAcctCfg cfg;
327
} SCMCreateAcctMsg, SCMAlterAcctMsg;
H
hzcheng 已提交
328 329

typedef struct {
B
Bomin Zhang 已提交
330
  char user[TSDB_USER_LEN];
331
} SCMDropUserMsg, SCMDropAcctMsg;
S
slguan 已提交
332 333

typedef struct {
B
Bomin Zhang 已提交
334 335
  char   user[TSDB_USER_LEN];
  char   pass[TSDB_KEY_LEN];
S
slguan 已提交
336 337
  int8_t privilege;
  int8_t flag;
338
} SCMCreateUserMsg, SCMAlterUserMsg;
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 {
349 350 351
  int32_t  contLen;
  int32_t  vgId;
  uint64_t uid;
S
slguan 已提交
352
  char    tableId[TSDB_TABLE_ID_LEN + 1];
S
slguan 已提交
353
} SMDDropSTableMsg;
S
slguan 已提交
354

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

359
typedef struct SColIndex {
360 361 362
  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 已提交
363
  char     name[TSDB_COL_NAME_LEN];
364
} SColIndex;
H
hzcheng 已提交
365 366 367

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

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

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

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

  union {
    struct {
      int64_t lowerBndi;
      int64_t upperBndi;
    };
    struct {
      double lowerBndd;
      double upperBndd;
    };
    struct {
      int64_t pz;
      int64_t len;
    };
  };
S
slguan 已提交
411 412 413 414 415 416 417 418 419 420 421 422 423
} 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 已提交
424

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

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

H
hzcheng 已提交
436 437
/*
 * the outputCols is equalled to or larger than numOfCols
S
slguan 已提交
438
 * e.g., select min(colName), max(colName), avg(colName) from table
H
hzcheng 已提交
439 440 441
 * the outputCols will be 3 while the numOfCols is 1.
 */
typedef struct {
442
  SMsgHead    head;
H
hjxilinx 已提交
443
  STimeWindow window;
444 445 446 447 448 449 450 451
  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)
452
  uint16_t    tagCondLen;       // tag length in current query
453 454
  int16_t     numOfGroupCols;   // num of group by columns
  int16_t     orderByIdx;
H
hjxilinx 已提交
455
  int16_t     orderType;        // used in group by xx order by xxx
456 457
  int64_t     limit;
  int64_t     offset;
458
  uint16_t    queryType;        // denote another query process
H
hjxilinx 已提交
459
  int16_t     numOfOutput;  // final output columns numbers
weixin_48148422's avatar
weixin_48148422 已提交
460
  int16_t     tagNameRelType;   // relation of tag criteria and tbname criteria
461
  int16_t     fillType;      // interpolate type
462
  uint64_t    fillVal;       // default value array list
S
slguan 已提交
463 464 465 466
  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
467
  int32_t     numOfTags;      // number of tags columns involved
S
slguan 已提交
468
  SColumnInfo colList[];
S
slguan 已提交
469
} SQueryTableMsg;
H
hzcheng 已提交
470 471

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

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

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

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

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

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

// 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 已提交
538 539 540 541 542
typedef struct {
  int32_t  vgId;
  int8_t   accessState;
} SDMVgroupAccess;

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

typedef struct {
  int32_t   nodeId;
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
551
  char      nodeEp[TSDB_EP_LEN];
S
slguan 已提交
552 553 554 555 556
} SDMMnodeInfo;

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

H
hzcheng 已提交
560 561
typedef struct {
  uint32_t   version;
S
slguan 已提交
562
  int32_t    dnodeId;
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
563
  char       dnodeEp[TSDB_EP_LEN];
S
slguan 已提交
564
  uint32_t   moduleStatus;
565 566
  uint32_t   lastReboot;        // time stamp for last reboot
  uint16_t   numOfTotalVnodes;  // from config file
S
slguan 已提交
567
  uint16_t   openVnodes;
H
hzcheng 已提交
568
  uint16_t   numOfCores;
569
  float      diskAvailable;  // GB
H
hzcheng 已提交
570
  uint8_t    alternativeRole;
S
slguan 已提交
571
  uint8_t    reserve[15];
H
hzcheng 已提交
572
  SVnodeLoad load[];
573
} SDMStatusMsg;
H
hzcheng 已提交
574

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

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

typedef struct {
  int32_t  nodeId;
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
605
  char     nodeEp[TSDB_EP_LEN];
S
slguan 已提交
606 607 608
} SMDVnodeDesc;

typedef struct {
B
Bomin Zhang 已提交
609
  char db[TSDB_DB_NAME_LEN];
S
slguan 已提交
610
  SMDVnodeCfg  cfg;
J
jtao1735 已提交
611
  SMDVnodeDesc nodes[TSDB_MAX_REPLICA];
S
slguan 已提交
612
} SMDCreateVnodeMsg;
H
hzcheng 已提交
613 614

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

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

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

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

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

H
hjxilinx 已提交
640
typedef struct STableMetaMsg {
S
slguan 已提交
641
  int32_t       contLen;
S
slguan 已提交
642
  char          tableId[TSDB_TABLE_ID_LEN + 1];   // table id
S
slguan 已提交
643 644 645 646 647
  uint8_t       numOfTags;
  uint8_t       precision;
  uint8_t       tableType;
  int16_t       numOfColumns;
  int16_t       sversion;
648
  int16_t       tversion;
S
slguan 已提交
649 650 651 652
  int32_t       sid;
  uint64_t      uid;
  SCMVgroupInfo vgroup;
  SSchema       schema[];
H
hjxilinx 已提交
653
} STableMetaMsg;
H
hzcheng 已提交
654

S
slguan 已提交
655
typedef struct SMultiTableMeta {
656 657
  int32_t       numOfTables;
  int32_t       contLen;
H
hjxilinx 已提交
658
  STableMetaMsg metas[];
S
slguan 已提交
659
} SMultiTableMeta;
S
slguan 已提交
660

H
hzcheng 已提交
661
typedef struct {
662
  int32_t dataLen;
S
slguan 已提交
663
  char name[TSDB_TABLE_ID_LEN + 1];
H
hzcheng 已提交
664 665 666 667 668 669 670 671 672
  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 已提交
673
  int8_t   type;
B
Bomin Zhang 已提交
674
  char     db[TSDB_DB_NAME_LEN];
H
hzcheng 已提交
675 676
  uint16_t payloadLen;
  char     payload[];
677
} SCMShowMsg;
H
hzcheng 已提交
678

H
hjxilinx 已提交
679 680 681
typedef struct SCMShowRsp {
  uint64_t      qhandle;
  STableMetaMsg tableMeta;
682
} SCMShowRsp;
S
slguan 已提交
683 684

typedef struct {
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
685
  char     ep[TSDB_EP_LEN];  // end point, hostname:port
686
} SCMCreateDnodeMsg, SCMDropDnodeMsg;
H
hzcheng 已提交
687 688

typedef struct {
S
Shengliang Guan 已提交
689 690 691
  int32_t dnodeId;
  int32_t vgId;
  int32_t sid;
692
} SDMConfigTableMsg;
H
hzcheng 已提交
693

S
slguan 已提交
694
typedef struct {
S
slguan 已提交
695 696
  uint32_t dnodeId;
  int32_t  vgId;
697
} SDMConfigVnodeMsg;
H
hzcheng 已提交
698 699

typedef struct {
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
700
  char ep[TSDB_EP_LEN];  // end point, hostname:port
701
  char config[64];
S
slguan 已提交
702
} SMDCfgDnodeMsg, SCMCfgDnodeMsg;
H
hzcheng 已提交
703 704

typedef struct {
H
hjxilinx 已提交
705
  char     sql[TSDB_SHOW_SQL_LEN];
H
hzcheng 已提交
706 707 708
  uint32_t queryId;
  int64_t  useconds;
  int64_t  stime;
S
slguan 已提交
709
} SQueryDesc;
H
hzcheng 已提交
710 711

typedef struct {
H
hjxilinx 已提交
712
  char     sql[TSDB_SHOW_SQL_LEN];
H
hzcheng 已提交
713 714 715 716 717 718 719
  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 已提交
720
} SStreamDesc;
H
hzcheng 已提交
721

S
slguan 已提交
722
typedef struct {
S
Shengliang Guan 已提交
723
  uint32_t connId;
724 725 726
  int32_t  numOfQueries;
  int32_t  numOfStreams;
  char     pData[];
727
} SCMHeartBeatMsg;
S
slguan 已提交
728 729 730 731

typedef struct {
  uint32_t  queryId;
  uint32_t  streamId;
732 733
  uint32_t  totalDnodes;
  uint32_t  onlineDnodes;
S
Shengliang Guan 已提交
734
  uint32_t  connId;
S
slguan 已提交
735 736
  int8_t    killConnection;
  SRpcIpSet ipList;
737
} SCMHeartBeatRsp;
H
hzcheng 已提交
738 739

typedef struct {
S
slguan 已提交
740
  char queryId[TSDB_KILL_MSG_LEN + 1];
741
} SCMKillQueryMsg, SCMKillStreamMsg, SCMKillConnMsg;
H
hzcheng 已提交
742 743

typedef struct {
S
slguan 已提交
744
  int32_t  vnode;
H
hzcheng 已提交
745 746 747
  int32_t  sid;
  uint64_t uid;
  uint64_t stime;  // stream starting time
S
slguan 已提交
748
  int32_t  status;
S
slguan 已提交
749
  char     tableId[TSDB_TABLE_ID_LEN + 1];
750
} SMDAlterStreamMsg;
H
hzcheng 已提交
751

S
Shengliang Guan 已提交
752
typedef struct {
B
Bomin Zhang 已提交
753
  char user[TSDB_USER_LEN];
S
Shengliang Guan 已提交
754 755 756 757 758 759
  char spi;
  char encrypt;
  char secret[TSDB_KEY_LEN + 1];
  char ckey[TSDB_KEY_LEN + 1];
} SDMAuthMsg, SDMAuthRsp;

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

#ifdef __cplusplus
}
#endif

#endif