taosmsg.h 24.4 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"
B
Bomin Zhang 已提交
29
#include "tdataformat.h"
H
hzcheng 已提交
30 31

// message type
32 33 34 35 36 37 38 39 40 41 42

#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

43 44 45 46
// 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" )
47
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_UPDATE_TAG_VAL, "update-tag-val" )
J
jtao1735 已提交
48 49 50
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 已提交
51

52
// message from mnode to dnode
53 54 55 56 57 58 59 60
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" )
S
Shengliang Guan 已提交
61
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_MD_ALTER_VNODE, "alter-vnode" )
S
TD-1671  
Shengliang Guan 已提交
62
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_MD_CREATE_MNODE, "create-mnode" )
J
jtao1735 已提交
63 64
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY6, "dummy6" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DUMMY7, "dummy7" )
S
slguan 已提交
65

66
// message from client to mnode
67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87
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 已提交
88
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_RETRIEVE, "retrieve" )     
89 90 91 92 93
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 已提交
94 95 96 97
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 已提交
98

99
// message from dnode to mnode
100 101 102 103
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" )
104
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_DM_AUTH, "auth" )
J
jtao1735 已提交
105 106 107
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" )
108
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_NETWORK_TEST, "nettest" )
H
Hui Li 已提交
109

110 111 112 113 114 115
// message for topic
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_CREATE_TP, "create-tp" )
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_DROP_TP, "drop-tp" )	  
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_USE_TP, "use-tp" )	 
TAOS_DEFINE_MESSAGE_TYPE( TSDB_MSG_TYPE_CM_ALTER_TP, "alter-tp" )

116 117 118
#ifndef TAOS_MESSAGE_C
  TSDB_MSG_TYPE_MAX  // 105
#endif
119

120
};
H
hzcheng 已提交
121 122

// IE type
123 124 125 126 127 128 129
#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 已提交
130 131

enum _mgmt_table {
S
slguan 已提交
132
  TSDB_MGMT_TABLE_ACCT,
H
hzcheng 已提交
133 134 135
  TSDB_MGMT_TABLE_USER,
  TSDB_MGMT_TABLE_DB,
  TSDB_MGMT_TABLE_TABLE,
136
  TSDB_MGMT_TABLE_DNODE,
S
slguan 已提交
137
  TSDB_MGMT_TABLE_MNODE,
H
hzcheng 已提交
138 139
  TSDB_MGMT_TABLE_VGROUP,
  TSDB_MGMT_TABLE_METRIC,
S
slguan 已提交
140
  TSDB_MGMT_TABLE_MODULE,
H
hzcheng 已提交
141 142
  TSDB_MGMT_TABLE_QUERIES,
  TSDB_MGMT_TABLE_STREAMS,
H
Haojun Liao 已提交
143
  TSDB_MGMT_TABLE_VARIABLES,
H
hzcheng 已提交
144
  TSDB_MGMT_TABLE_CONNS,
S
slguan 已提交
145 146
  TSDB_MGMT_TABLE_SCORES,
  TSDB_MGMT_TABLE_GRANTS,
L
lihui 已提交
147
  TSDB_MGMT_TABLE_VNODES,
148
  TSDB_MGMT_TABLE_STREAMTABLES,
S
Shengliang Guan 已提交
149
  TSDB_MGMT_TABLE_CLUSTER,
150
  TSDB_MGMT_TABLE_TP,
D
dapan1121 已提交
151
  TSDB_MGMT_TABLE_FUNCTION,
H
hzcheng 已提交
152 153 154
  TSDB_MGMT_TABLE_MAX,
};

155 156
#define TSDB_ALTER_TABLE_ADD_TAG_COLUMN    1
#define TSDB_ALTER_TABLE_DROP_TAG_COLUMN   2
157
#define TSDB_ALTER_TABLE_CHANGE_TAG_COLUMN 3
158
#define TSDB_ALTER_TABLE_UPDATE_TAG_VAL    4
H
hzcheng 已提交
159

160 161
#define TSDB_ALTER_TABLE_ADD_COLUMN        5
#define TSDB_ALTER_TABLE_DROP_COLUMN       6
S
Shengliang Guan 已提交
162
#define TSDB_ALTER_TABLE_CHANGE_COLUMN     7
H
hzcheng 已提交
163

164 165 166 167 168 169 170 171
#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
#define TSDB_FILL_NEXT             5

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

174
#define TSDB_KILL_MSG_LEN          30
H
hzcheng 已提交
175

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

180 181 182 183
#define TSDB_COL_NORMAL             0x0u    // the normal column of the table
#define TSDB_COL_TAG                0x1u    // the tag column type
#define TSDB_COL_UDC                0x2u    // the user specified normal string column, it is a dummy column
#define TSDB_COL_NULL               0x4u    // the column filter NULL or not
Y
TD-1230  
yihaoDeng 已提交
184

185 186 187 188
#define TSDB_COL_IS_TAG(f)          (((f&(~(TSDB_COL_NULL)))&TSDB_COL_TAG) != 0)
#define TSDB_COL_IS_NORMAL_COL(f)   ((f&(~(TSDB_COL_NULL))) == TSDB_COL_NORMAL)
#define TSDB_COL_IS_UD_COL(f)       ((f&(~(TSDB_COL_NULL))) == TSDB_COL_UDC)
#define TSDB_COL_REQ_NULL(f)        (((f)&TSDB_COL_NULL) != 0)
Y
TD-1230  
yihaoDeng 已提交
189

H
hzcheng 已提交
190 191 192

extern char *taosMsg[];

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

195
// null-terminated string instead of char array to avoid too many memory consumption in case of more than 1M tableMeta
196
typedef struct {
J
jtao1735 已提交
197
  char     fqdn[TSDB_FQDN_LEN];
198
  uint16_t port;
199 200 201 202 203 204
} SEpAddrMsg;

typedef struct {
  char*    fqdn;
  uint16_t port;
} SEpAddr1;
205

H
hzcheng 已提交
206
typedef struct {
207 208 209 210 211 212 213 214
  int32_t numOfVnodes;
} SMsgDesc;

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

215 216
// Submit message for one table
typedef struct SSubmitBlk {
217 218 219 220
  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
221 222
  int32_t  dataLen;    // data part length, not including the SSubmitBlk head
  int32_t  schemaLen;  // schema length, if length is 0, no schema exists
223 224
  int16_t  numOfRows;  // total number of rows in current submit block
  char     data[];
225 226 227 228 229 230
} SSubmitBlk;

// Submit message for this TSDB
typedef struct SSubmitMsg {
  SMsgHead   header;
  int32_t    length;
231
  int32_t    numOfBlocks;
S
TD-1037  
Shengliang Guan 已提交
232
  char       blocks[];
233
} SSubmitMsg;
H
hzcheng 已提交
234

S
slguan 已提交
235
typedef struct {
236 237 238 239
  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 已提交
240 241 242
} SShellSubmitRspBlock;

typedef struct {
243 244 245 246 247
  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 已提交
248
  SShellSubmitRspBlock failedBlocks[];
S
slguan 已提交
249 250
} SShellSubmitRspMsg;

S
slguan 已提交
251
typedef struct SSchema {
S
slguan 已提交
252
  uint8_t type;
B
Bomin Zhang 已提交
253
  char    name[TSDB_COL_NAME_LEN];
S
slguan 已提交
254 255
  int16_t colId;
  int16_t bytes;
S
slguan 已提交
256
} SSchema;
H
hzcheng 已提交
257

S
slguan 已提交
258
typedef struct {
259 260 261 262 263
  int32_t  contLen;
  int32_t  vgId;
  int8_t   tableType;
  int16_t  numOfColumns;
  int16_t  numOfTags;
H
Haojun Liao 已提交
264
  int32_t  tid;
265
  int32_t  sversion;
266
  int32_t  tversion;
267 268 269 270 271
  int32_t  tagDataLen;
  int32_t  sqlDataLen;
  uint64_t uid;
  uint64_t superTableUid;
  uint64_t createdTime;
H
Haojun Liao 已提交
272 273
  char     tableFname[TSDB_TABLE_FNAME_LEN];
  char     stableFname[TSDB_TABLE_FNAME_LEN];
274
  char     data[];
S
slguan 已提交
275
} SMDCreateTableMsg;
S
slguan 已提交
276

H
hzcheng 已提交
277
typedef struct {
278
  int32_t len;  // one create table message
279
  char    tableName[TSDB_TABLE_FNAME_LEN];
280
  int8_t  igExists;
S
slguan 已提交
281
  int8_t  getMeta;
282 283 284 285 286
  int16_t numOfTags;
  int16_t numOfColumns;
  int16_t sqlLen;  // the length of SQL, it starts after schema , sql is a null-terminated string
  int8_t  reserved[16];
  char    schema[];
287 288 289 290 291
} SCreateTableMsg;

typedef struct {
  int32_t numOfTables;
  int32_t contLen;
292
} SCMCreateTableMsg;
H
hzcheng 已提交
293 294

typedef struct {
295
  char   name[TSDB_TABLE_FNAME_LEN];
296
  int8_t igNotExists;
297
} SCMDropTableMsg;
H
hzcheng 已提交
298 299

typedef struct {
H
Haojun Liao 已提交
300
  char    tableFname[TSDB_TABLE_FNAME_LEN];
301
  char    db[TSDB_ACCT_ID_LEN + TSDB_DB_NAME_LEN];
302
  int16_t type; /* operation type   */
303 304
  int16_t numOfCols; /* number of schema */
  int32_t tagValLen;
S
slguan 已提交
305
  SSchema schema[];
306 307
  // tagVal is padded after schema
  // char    tagVal[];
S
TD-1732  
Shengliang Guan 已提交
308
} SAlterTableMsg;
H
hzcheng 已提交
309

310 311 312 313 314 315
typedef struct {
  SMsgHead  head;
  int64_t   uid;
  int32_t   tid;
  int16_t   tversion;
  int16_t   colId;
316
  int8_t    type;
317
  int16_t   bytes;
318
  int32_t   tagValLen;
319 320
  int16_t   numOfTags;
  int32_t   schemaLen;
321 322 323
  char      data[];
} SUpdateTableTagValMsg;

S
slguan 已提交
324
typedef struct {
S
TD-1762  
Shengliang Guan 已提交
325 326 327 328
  char    clientVersion[TSDB_VERSION_LEN];
  char    msgVersion[TSDB_VERSION_LEN];
  char    db[TSDB_TABLE_FNAME_LEN];
  char    appName[TSDB_APPNAME_LEN];
H
Haojun Liao 已提交
329
  int32_t pid;
S
TD-1762  
Shengliang Guan 已提交
330
} SConnectMsg;
S
slguan 已提交
331 332

typedef struct {
333
  char      acctId[TSDB_ACCT_ID_LEN];
S
slguan 已提交
334
  char      serverVersion[TSDB_VERSION_LEN];
335
  char      clusterId[TSDB_CLUSTER_ID_LEN];
S
slguan 已提交
336 337
  int8_t    writeAuth;
  int8_t    superAuth;
338 339 340
  int8_t    reserved1;
  int8_t    reserved2;
  int32_t   connId;
341
  SRpcEpSet epSet;
S
TD-1762  
Shengliang Guan 已提交
342
} SConnectRsp;
S
slguan 已提交
343

H
hzcheng 已提交
344 345 346 347 348 349 350 351 352 353 354
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;
355
  int8_t  accessState;  // Configured only by command
S
slguan 已提交
356
} SAcctCfg;
H
hzcheng 已提交
357 358

typedef struct {
B
Bomin Zhang 已提交
359 360
  char     user[TSDB_USER_LEN];
  char     pass[TSDB_KEY_LEN];
S
slguan 已提交
361
  SAcctCfg cfg;
S
TD-1762  
Shengliang Guan 已提交
362
} SCreateAcctMsg, SAlterAcctMsg;
H
hzcheng 已提交
363 364

typedef struct {
B
Bomin Zhang 已提交
365
  char user[TSDB_USER_LEN];
S
TD-1732  
Shengliang Guan 已提交
366
} SDropUserMsg, SDropAcctMsg;
S
slguan 已提交
367 368

typedef struct {
B
Bomin Zhang 已提交
369 370
  char   user[TSDB_USER_LEN];
  char   pass[TSDB_KEY_LEN];
S
slguan 已提交
371 372
  int8_t privilege;
  int8_t flag;
S
TD-1732  
Shengliang Guan 已提交
373
} SCreateUserMsg, SAlterUserMsg;
H
hzcheng 已提交
374 375

typedef struct {
376 377
  int32_t  contLen;
  int32_t  vgId;
H
Haojun Liao 已提交
378
  int32_t  tid;
379
  uint64_t uid;
H
Haojun Liao 已提交
380
  char     tableFname[TSDB_TABLE_FNAME_LEN];
S
slguan 已提交
381
} SMDDropTableMsg;
H
hzcheng 已提交
382

383
typedef struct {
384 385 386
  int32_t  contLen;
  int32_t  vgId;
  uint64_t uid;
H
Haojun Liao 已提交
387
  char    tableFname[TSDB_TABLE_FNAME_LEN];
S
TD-1732  
Shengliang Guan 已提交
388
} SDropSTableMsg;
389

S
slguan 已提交
390
typedef struct {
391
  int32_t vgId;
S
TD-1732  
Shengliang Guan 已提交
392
} SDropVnodeMsg;
H
hzcheng 已提交
393

394
typedef struct SColIndex {
395 396 397
  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 已提交
398
  char     name[TSDB_COL_NAME_LEN];
399
} SColIndex;
H
hzcheng 已提交
400 401 402

/* sql function msg, to describe the message to vnode about sql function
 * operations in select clause */
403
typedef struct SSqlFuncMsg {
H
hzcheng 已提交
404 405
  int16_t functionId;
  int16_t numOfParams;
H
Haojun Liao 已提交
406
  int16_t resColId;      // result column id, id of the current output column
H
hzcheng 已提交
407

408
  SColIndex colInfo;
H
hzcheng 已提交
409 410 411 412 413 414 415 416 417
  struct ArgElem {
    int16_t argType;
    int16_t argBytes;
    union {
      double  d;
      int64_t i64;
      char *  pz;
    } argValue;
  } arg[3];
418
} SSqlFuncMsg;
H
hzcheng 已提交
419

420
typedef struct SExprInfo {
421 422
  SSqlFuncMsg base;
  struct tExprNode* pExpr;
423 424
  int16_t     bytes;
  int16_t     type;
425
  int32_t     interBytes;
H
Haojun Liao 已提交
426
  int64_t     uid;
427
} SExprInfo;
H
hzcheng 已提交
428

S
slguan 已提交
429
typedef struct SColumnFilterInfo {
H
hzcheng 已提交
430 431
  int16_t lowerRelOptr;
  int16_t upperRelOptr;
432
  int16_t filterstr;   // denote if current column is char(binary/nchar)
H
hzcheng 已提交
433 434 435 436 437 438 439 440 441 442 443 444 445 446 447

  union {
    struct {
      int64_t lowerBndi;
      int64_t upperBndi;
    };
    struct {
      double lowerBndd;
      double upperBndd;
    };
    struct {
      int64_t pz;
      int64_t len;
    };
  };
S
slguan 已提交
448 449 450 451 452 453 454 455 456 457 458
} 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;
459 460 461 462
  union{
    int64_t placeholder;
    SColumnFilterInfo *filters;
  };
S
slguan 已提交
463
} SColumnInfo;
H
hzcheng 已提交
464

465
typedef struct STableIdInfo {
466 467 468
  uint64_t uid;
  int32_t  tid;
  TSKEY    key;  // last accessed ts, for subscription
469
} STableIdInfo;
H
hzcheng 已提交
470

471 472 473 474 475
typedef struct STimeWindow {
  TSKEY skey;
  TSKEY ekey;
} STimeWindow;

H
hzcheng 已提交
476
typedef struct {
477
  SMsgHead    head;
478 479
  char        version[TSDB_VERSION_LEN];

480
  STimeWindow window;
481 482 483 484
  int32_t     numOfTables;
  int16_t     order;
  int16_t     orderColId;
  int16_t     numOfCols;        // the number of columns will be load from vnode
485
  SInterval   interval;
486
  uint16_t    tagCondLen;       // tag length in current query
487
  uint32_t    tbnameCondLen;    // table name filter condition string length
488 489
  int16_t     numOfGroupCols;   // num of group by columns
  int16_t     orderByIdx;
490
  int16_t     orderType;        // used in group by xx order by xxx
H
Haojun Liao 已提交
491
  int64_t     vgroupLimit;       // limit the number of rows for each table, used in order by + limit in stable projection query.
492
  int16_t     prjOrder;         // global order in super table projection query.
493 494
  int64_t     limit;
  int64_t     offset;
495
  uint32_t    queryType;        // denote another query process
H
Haojun Liao 已提交
496
  int16_t     numOfOutput;      // final output columns numbers
497
  int16_t     tagNameRelType;   // relation of tag criteria and tbname criteria
498 499
  int16_t     fillType;         // interpolate type
  uint64_t    fillVal;          // default value array list
H
Haojun Liao 已提交
500
  int32_t     secondStageOutput;
501 502 503 504 505
  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
  int32_t     numOfTags;        // number of tags columns involved
506
  int32_t     sqlstrLen;        // sql query string
507
  int32_t     prevResultLen;    // previous result length
S
slguan 已提交
508
  SColumnInfo colList[];
S
slguan 已提交
509
} SQueryTableMsg;
H
hzcheng 已提交
510 511

typedef struct {
512
  int32_t  code;
513
  uint64_t qhandle; // query handle
S
slguan 已提交
514
} SQueryTableRsp;
H
hzcheng 已提交
515 516

typedef struct {
517
  SMsgHead header;
H
hzcheng 已提交
518
  uint64_t qhandle;
519
  uint16_t free;
S
slguan 已提交
520
} SRetrieveTableMsg;
H
hzcheng 已提交
521

522
typedef struct SRetrieveTableRsp {
H
hzcheng 已提交
523
  int32_t numOfRows;
524
  int8_t  completed;  // all results are returned to client
H
hzcheng 已提交
525
  int16_t precision;
526
  int64_t offset;     // updated offset value for multi-vnode projection query
H
hzcheng 已提交
527 528
  int64_t useconds;
  char    data[];
S
slguan 已提交
529
} SRetrieveTableRsp;
H
hzcheng 已提交
530 531

typedef struct {
S
TD-2429  
Shengliang Guan 已提交
532 533 534 535 536 537 538 539 540 541 542
  int32_t  vgId;
  int32_t  dbCfgVersion;
  int64_t  totalStorage;
  int64_t  compStorage;
  int64_t  pointsWritten;
  uint64_t vnodeVersion;
  int32_t  vgCfgVersion;
  uint8_t  status;
  uint8_t  role;
  uint8_t  replica;
  uint8_t  reserved;
H
hzcheng 已提交
543 544 545
} SVnodeLoad;

typedef struct {
546
  char     db[TSDB_ACCT_ID_LEN + TSDB_DB_NAME_LEN];
S
slguan 已提交
547
  int32_t  cacheBlockSize; //MB
548 549
  int32_t  totalBlocks;
  int32_t  maxTables;
S
slguan 已提交
550
  int32_t  daysPerFile;
551
  int32_t  daysToKeep;
S
slguan 已提交
552 553 554 555
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
  int32_t  minRowsPerFileBlock;
  int32_t  maxRowsPerFileBlock;
556
  int32_t  commitTime;
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
557
  int32_t  fsyncPeriod;
558
  uint8_t  precision;   // time resolution
S
slguan 已提交
559
  int8_t   compression;
H
hjxilinx 已提交
560
  int8_t   walLevel;
S
slguan 已提交
561
  int8_t   replications;
562
  int8_t   quorum;
S
slguan 已提交
563
  int8_t   ignoreExist;
564
  int8_t   update;
565
  int8_t   cacheLastRow;
566 567 568
  int8_t   dbType;
  int16_t  partitions;
  int8_t   reserve[5];
S
TD-1732  
Shengliang Guan 已提交
569
} SCreateDbMsg, SAlterDbMsg;
H
hzcheng 已提交
570

D
dapan1121 已提交
571 572 573 574 575
typedef struct {
  int32_t  codeLen;
  char     code[];
} SCreateFuncMsg;

576
typedef struct {
H
Haojun Liao 已提交
577
  char    db[TSDB_TABLE_FNAME_LEN];
578
  uint8_t ignoreNotExists;
S
TD-1732  
Shengliang Guan 已提交
579
} SDropDbMsg, SUseDbMsg;
H
hzcheng 已提交
580 581 582 583 584 585 586 587 588 589 590

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

591 592 593
typedef struct {
  int32_t  vgId;
  int8_t   accessState;
S
TD-1732  
Shengliang Guan 已提交
594
} SVgroupAccess;
595

S
slguan 已提交
596
typedef struct {
597
  int32_t  dnodeId;
S
slguan 已提交
598 599
  uint32_t moduleStatus;
  uint32_t numOfVnodes;
600 601
  char     clusterId[TSDB_CLUSTER_ID_LEN];
  char     reserved[16];
S
TD-1762  
Shengliang Guan 已提交
602 603 604 605 606 607 608
} SDnodeCfg;

typedef struct {
  int32_t  dnodeId;
  uint16_t dnodePort;
  char     dnodeFqdn[TSDB_FQDN_LEN];
} SDnodeEp;
609 610

typedef struct {
S
TD-1762  
Shengliang Guan 已提交
611 612 613
  int32_t  dnodeNum;
  SDnodeEp dnodeEps[];
} SDnodeEps;
614 615

typedef struct {
S
TD-1762  
Shengliang Guan 已提交
616 617
  int32_t mnodeId;
  char    mnodeEp[TSDB_EP_LEN];
S
TD-2331  
Shengliang Guan 已提交
618
} SMInfo;
619 620

typedef struct {
S
TD-2331  
Shengliang Guan 已提交
621 622 623 624
  int8_t inUse;
  int8_t mnodeNum;
  SMInfo mnodeInfos[TSDB_MAX_REPLICA];
} SMInfos;
S
slguan 已提交
625

H
hzcheng 已提交
626
typedef struct {
H
Hui Li 已提交
627 628 629 630
  int32_t  numOfMnodes;               // tsNumOfMnodes
  int32_t  mnodeEqualVnodeNum;        // tsMnodeEqualVnodeNum
  int32_t  offlineThreshold;          // tsOfflineThreshold
  int32_t  statusInterval;            // tsStatusInterval
631 632
  int32_t  maxtablesPerVnode;
  int32_t  maxVgroupsPerDb;
H
Hui Li 已提交
633 634
  char     arbitrator[TSDB_EP_LEN];   // tsArbitrator
  char     timezone[64];              // tsTimezone
H
Hui Li 已提交
635
  int64_t  checkTime;                 // 1970-01-01 00:00:00.000
H
Hui Li 已提交
636 637
  char     locale[TSDB_LOCALE_LEN];   // tsLocale
  char     charset[TSDB_LOCALE_LEN];  // tsCharset
S
Shengliang Guan 已提交
638 639 640 641 642
  int8_t   enableBalance;             // tsEnableBalance
  int8_t   flowCtrl;
  int8_t   slaveQuery;
  int8_t   adjustMaster;
  int8_t   reserved[4];
H
Hui Li 已提交
643 644 645 646 647 648 649 650
} SClusterCfg;

typedef struct {
  uint32_t    version;
  int32_t     dnodeId;
  char        dnodeEp[TSDB_EP_LEN];
  uint32_t    moduleStatus;
  uint32_t    lastReboot;        // time stamp for last reboot
S
Shengliang Guan 已提交
651
  uint16_t    reserve1;          // from config file
H
Hui Li 已提交
652 653 654
  uint16_t    openVnodes;
  uint16_t    numOfCores;
  float       diskAvailable;  // GB
655
  char        clusterId[TSDB_CLUSTER_ID_LEN];
H
Hui Li 已提交
656
  uint8_t     alternativeRole;
S
Shengliang Guan 已提交
657
  uint8_t     reserve2[15];
H
Hui Li 已提交
658
  SClusterCfg clusterCfg;
H
Hui Li 已提交
659
  SVnodeLoad  load[];
S
TD-1732  
Shengliang Guan 已提交
660
} SStatusMsg;
H
hzcheng 已提交
661

S
slguan 已提交
662
typedef struct {
S
TD-2331  
Shengliang Guan 已提交
663
  SMInfos       mnodes;
S
TD-1732  
Shengliang Guan 已提交
664 665 666
  SDnodeCfg     dnodeCfg;
  SVgroupAccess vgAccess[];
} SStatusRsp;
S
slguan 已提交
667

H
hzcheng 已提交
668
typedef struct {
669
  uint32_t vgId;
S
TD-2270  
Shengliang Guan 已提交
670
  int32_t  dbCfgVersion;
671
  int32_t  maxTables;
S
slguan 已提交
672 673
  int32_t  cacheBlockSize;
  int32_t  totalBlocks;
674 675 676 677
  int32_t  daysPerFile;
  int32_t  daysToKeep;
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
S
slguan 已提交
678 679
  int32_t  minRowsPerFileBlock;
  int32_t  maxRowsPerFileBlock;
680
  int32_t  commitTime;
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
681
  int32_t  fsyncPeriod;
S
slguan 已提交
682
  int8_t   precision;
683
  int8_t   compression;
H
hjxilinx 已提交
684
  int8_t   walLevel;
S
TD-2429  
Shengliang Guan 已提交
685
  int8_t   vgReplica;
S
slguan 已提交
686
  int8_t   wals;
687
  int8_t   quorum;
688
  int8_t   update;
689
  int8_t   cacheLastRow;
S
TD-2270  
Shengliang Guan 已提交
690
  int32_t  vgCfgVersion;
S
TD-2429  
Shengliang Guan 已提交
691
  int8_t   dbReplica;
S
TD-3130  
Shengliang Guan 已提交
692 693
  int8_t   dbType;
  int8_t   reserved[8];
S
TD-1732  
Shengliang Guan 已提交
694
} SVnodeCfg;
695 696 697

typedef struct {
  int32_t  nodeId;
698
  char     nodeEp[TSDB_EP_LEN];
S
TD-1732  
Shengliang Guan 已提交
699
} SVnodeDesc;
700 701

typedef struct {
702
  char       db[TSDB_ACCT_ID_LEN + TSDB_DB_NAME_LEN];
S
TD-1732  
Shengliang Guan 已提交
703 704 705
  SVnodeCfg  cfg;
  SVnodeDesc nodes[TSDB_MAX_REPLICA];
} SCreateVnodeMsg, SAlterVnodeMsg;
H
hzcheng 已提交
706 707

typedef struct {
H
Haojun Liao 已提交
708
  char    tableFname[TSDB_TABLE_FNAME_LEN];
S
slguan 已提交
709 710
  int16_t createFlag;
  char    tags[];
S
TD-1732  
Shengliang Guan 已提交
711
} STableInfoMsg;
H
hzcheng 已提交
712 713

typedef struct {
S
slguan 已提交
714 715
  int32_t numOfTables;
  char    tableIds[];
S
TD-1732  
Shengliang Guan 已提交
716
} SMultiTableInfoMsg;
H
hzcheng 已提交
717

S
TD-1732  
Shengliang Guan 已提交
718
typedef struct SSTableVgroupMsg {
719
  int32_t numOfTables;
S
TD-1732  
Shengliang Guan 已提交
720
} SSTableVgroupMsg, SSTableVgroupRspMsg;
S
slguan 已提交
721

722
typedef struct {
723 724 725
  int32_t       vgId;
  int8_t        numOfEps;
  SEpAddr1      epAddr[TSDB_MAX_REPLICA];
S
TD-1732  
Shengliang Guan 已提交
726
} SVgroupInfo;
727

728 729 730 731
typedef struct {
  int32_t    vgId;
  int8_t     numOfEps;
  SEpAddrMsg epAddr[TSDB_MAX_REPLICA];
S
TD-1732  
Shengliang Guan 已提交
732
} SVgroupMsg;
733

S
slguan 已提交
734
typedef struct {
735
  int32_t numOfVgroups;
S
TD-1732  
Shengliang Guan 已提交
736
  SVgroupInfo vgroups[];
737 738
} SVgroupsInfo;

739 740
typedef struct {
  int32_t numOfVgroups;
S
TD-1732  
Shengliang Guan 已提交
741
  SVgroupMsg vgroups[];
742 743
} SVgroupsMsg;

744
typedef struct STableMetaMsg {
S
slguan 已提交
745
  int32_t       contLen;
H
Haojun Liao 已提交
746
  char          tableFname[TSDB_TABLE_FNAME_LEN];   // table id
S
slguan 已提交
747 748 749 750 751
  uint8_t       numOfTags;
  uint8_t       precision;
  uint8_t       tableType;
  int16_t       numOfColumns;
  int16_t       sversion;
752
  int16_t       tversion;
H
Haojun Liao 已提交
753
  int32_t       tid;
S
slguan 已提交
754
  uint64_t      uid;
S
TD-1732  
Shengliang Guan 已提交
755
  SVgroupMsg    vgroup;
756 757 758

  char          sTableName[TSDB_TABLE_FNAME_LEN];
  uint64_t      suid;
S
slguan 已提交
759
  SSchema       schema[];
760
} STableMetaMsg;
H
hzcheng 已提交
761

S
slguan 已提交
762
typedef struct SMultiTableMeta {
763 764
  int32_t       numOfTables;
  int32_t       contLen;
S
TD-1037  
Shengliang Guan 已提交
765
  char          metas[];
S
slguan 已提交
766
} SMultiTableMeta;
S
slguan 已提交
767

H
hzcheng 已提交
768
typedef struct {
769
  int32_t dataLen;
770 771
  char    name[TSDB_TABLE_FNAME_LEN];
  char   *data;
H
hzcheng 已提交
772 773 774 775 776 777 778 779
} STagData;

/*
 * sql: show tables like '%a_%'
 * payload is the query condition, e.g., '%a_%'
 * payloadLen is the length of payload
 */
typedef struct {
S
slguan 已提交
780
  int8_t   type;
781
  char     db[TSDB_ACCT_ID_LEN + TSDB_DB_NAME_LEN];
H
hzcheng 已提交
782 783
  uint16_t payloadLen;
  char     payload[];
S
TD-1732  
Shengliang Guan 已提交
784
} SShowMsg;
H
hzcheng 已提交
785

S
TD-1732  
Shengliang Guan 已提交
786
typedef struct SShowRsp {
787 788
  uint64_t      qhandle;
  STableMetaMsg tableMeta;
S
TD-1732  
Shengliang Guan 已提交
789
} SShowRsp;
S
slguan 已提交
790 791

typedef struct {
S
TD-1732  
Shengliang Guan 已提交
792 793
  char ep[TSDB_EP_LEN];  // end point, hostname:port
} SCreateDnodeMsg, SDropDnodeMsg;
H
hzcheng 已提交
794

S
TD-1671  
Shengliang Guan 已提交
795 796 797
typedef struct {
  int32_t dnodeId;
  char    dnodeEp[TSDB_EP_LEN];  // end point, hostname:port
S
TD-2331  
Shengliang Guan 已提交
798
  SMInfos mnodes;
S
TD-1732  
Shengliang Guan 已提交
799
} SCreateMnodeMsg;
S
TD-1671  
Shengliang Guan 已提交
800

H
hzcheng 已提交
801
typedef struct {
802 803
  int32_t dnodeId;
  int32_t vgId;
H
Haojun Liao 已提交
804
  int32_t tid;
S
TD-1732  
Shengliang Guan 已提交
805
} SConfigTableMsg;
H
hzcheng 已提交
806

S
slguan 已提交
807
typedef struct {
808 809
  uint32_t dnodeId;
  int32_t  vgId;
S
TD-1732  
Shengliang Guan 已提交
810
} SConfigVnodeMsg;
H
hzcheng 已提交
811 812

typedef struct {
813
  char ep[TSDB_EP_LEN];  // end point, hostname:port
814
  char config[64];
S
TD-1732  
Shengliang Guan 已提交
815
} SCfgDnodeMsg;
H
hzcheng 已提交
816 817

typedef struct {
818
  char     sql[TSDB_SHOW_SQL_LEN];
H
hzcheng 已提交
819 820 821
  uint32_t queryId;
  int64_t  useconds;
  int64_t  stime;
H
Haojun Liao 已提交
822
  uint64_t qHandle;
S
slguan 已提交
823
} SQueryDesc;
H
hzcheng 已提交
824 825

typedef struct {
826
  char     sql[TSDB_SHOW_SQL_LEN];
827
  char     dstTable[TSDB_TABLE_NAME_LEN];
H
hzcheng 已提交
828 829 830 831 832 833 834
  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 已提交
835
} SStreamDesc;
H
hzcheng 已提交
836

S
slguan 已提交
837
typedef struct {
H
Haojun Liao 已提交
838
  char     clientVer[TSDB_VERSION_LEN];
839
  uint32_t connId;
H
Haojun Liao 已提交
840
  int32_t  pid;
841 842
  int32_t  numOfQueries;
  int32_t  numOfStreams;
H
Haojun Liao 已提交
843
  char     appName[TSDB_APPNAME_LEN];
844
  char     pData[];
S
TD-1732  
Shengliang Guan 已提交
845
} SHeartBeatMsg;
S
slguan 已提交
846 847 848 849

typedef struct {
  uint32_t  queryId;
  uint32_t  streamId;
850 851
  uint32_t  totalDnodes;
  uint32_t  onlineDnodes;
852
  uint32_t  connId;
S
slguan 已提交
853
  int8_t    killConnection;
854
  SRpcEpSet epSet;
S
TD-1732  
Shengliang Guan 已提交
855
} SHeartBeatRsp;
H
hzcheng 已提交
856 857

typedef struct {
S
slguan 已提交
858
  char queryId[TSDB_KILL_MSG_LEN + 1];
S
TD-1732  
Shengliang Guan 已提交
859
} SKillQueryMsg, SKillStreamMsg, SKillConnMsg;
H
hzcheng 已提交
860 861

typedef struct {
S
slguan 已提交
862
  int32_t  vnode;
H
hzcheng 已提交
863 864 865
  int32_t  sid;
  uint64_t uid;
  uint64_t stime;  // stream starting time
S
slguan 已提交
866
  int32_t  status;
H
Haojun Liao 已提交
867
  char     tableFname[TSDB_TABLE_FNAME_LEN];
S
TD-1732  
Shengliang Guan 已提交
868
} SAlterStreamMsg;
H
hzcheng 已提交
869

870
typedef struct {
B
Bomin Zhang 已提交
871
  char user[TSDB_USER_LEN];
872 873
  char spi;
  char encrypt;
B
Bomin Zhang 已提交
874 875
  char secret[TSDB_KEY_LEN];
  char ckey[TSDB_KEY_LEN];
S
TD-1732  
Shengliang Guan 已提交
876
} SAuthMsg, SAuthRsp;
877

878 879 880 881 882 883 884 885
typedef struct {
  int8_t  finished;
  int8_t  reserved1[7];
  char    name[TSDB_STEP_NAME_LEN];
  char    desc[TSDB_STEP_DESC_LEN];
  char    reserved2[64];
} SStartupStep;

S
slguan 已提交
886
#pragma pack(pop)
H
hzcheng 已提交
887 888 889 890 891 892

#ifdef __cplusplus
}
#endif

#endif
新手
引导
客服 返回
顶部