mndDef.h 7.0 KB
Newer Older
H
refact  
Hongze Cheng 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
/*
 * 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/>.
 */

S
Shengliang Guan 已提交
16 17
#ifndef _TD_MND_DEF_H_
#define _TD_MND_DEF_H_
S
Shengliang Guan 已提交
18

19
#include "os.h"
S
Shengliang Guan 已提交
20 21 22

#include "cJSON.h"
#include "sync.h"
S
Shengliang Guan 已提交
23
#include "taosmsg.h"
S
Shengliang Guan 已提交
24
#include "thash.h"
S
Shengliang Guan 已提交
25 26 27
#include "tlog.h"
#include "trpc.h"
#include "ttimer.h"
S
Shengliang Guan 已提交
28

S
Shengliang Guan 已提交
29
#include "mnode.h"
S
Shengliang Guan 已提交
30

S
Shengliang Guan 已提交
31 32 33
#ifdef __cplusplus
extern "C" {
#endif
S
Shengliang Guan 已提交
34

S
Shengliang Guan 已提交
35 36 37 38 39 40 41 42 43 44 45
extern int32_t mDebugFlag;

// mnode log function
#define mFatal(...) { if (mDebugFlag & DEBUG_FATAL) { taosPrintLog("MND FATAL ", 255, __VA_ARGS__); }}
#define mError(...) { if (mDebugFlag & DEBUG_ERROR) { taosPrintLog("MND ERROR ", 255, __VA_ARGS__); }}
#define mWarn(...)  { if (mDebugFlag & DEBUG_WARN)  { taosPrintLog("MND WARN ", 255, __VA_ARGS__); }}
#define mInfo(...)  { if (mDebugFlag & DEBUG_INFO)  { taosPrintLog("MND ", 255, __VA_ARGS__); }}
#define mDebug(...) { if (mDebugFlag & DEBUG_DEBUG) { taosPrintLog("MND ", mDebugFlag, __VA_ARGS__); }}
#define mTrace(...) { if (mDebugFlag & DEBUG_TRACE) { taosPrintLog("MND ", mDebugFlag, __VA_ARGS__); }}

typedef enum {
46 47 48 49 50 51 52 53
  MND_AUTH_ACCT_START = 0,
  MND_AUTH_ACCT_USER,
  MND_AUTH_ACCT_DNODE,
  MND_AUTH_ACCT_MNODE,
  MND_AUTH_ACCT_DB,
  MND_AUTH_ACCT_TABLE,
  MND_AUTH_ACCT_MAX
} EAuthAcct;
S
Shengliang Guan 已提交
54 55

typedef enum {
56 57 58 59 60 61
  MND_AUTH_OP_START = 0,
  MND_AUTH_OP_CREATE_USER,
  MND_AUTH_OP_ALTER_USER,
  MND_AUTH_OP_DROP_USER,
  MND_AUTH_MAX
} EAuthOp;
S
Shengliang Guan 已提交
62

S
Shengliang Guan 已提交
63
typedef enum {
64 65 66
  TRN_STAGE_PREPARE = 0,
  TRN_STAGE_EXECUTE = 1,
  TRN_STAGE_ROLLBACK = 2,
S
Shengliang Guan 已提交
67
  TRN_STAGE_COMMIT = 3,
68
  TRN_STAGE_OVER = 4,
S
Shengliang Guan 已提交
69 70
} ETrnStage;

71
typedef enum { TRN_POLICY_ROLLBACK = 0, TRN_POLICY_RETRY = 1 } ETrnPolicy;
S
Shengliang Guan 已提交
72

S
Shengliang Guan 已提交
73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93
typedef enum {
  DND_STATUS_OFFLINE = 0,
  DND_STATUS_READY = 1,
  DND_STATUS_CREATING = 2,
  DND_STATUS_DROPPING = 3
} EDndStatus;

typedef enum {
  DND_REASON_ONLINE = 0,
  DND_REASON_STATUS_MSG_TIMEOUT,
  DND_REASON_STATUS_NOT_RECEIVED,
  DND_REASON_VERSION_NOT_MATCH,
  DND_REASON_DNODE_ID_NOT_MATCH,
  DND_REASON_CLUSTER_ID_NOT_MATCH,
  DND_REASON_STATUS_INTERVAL_NOT_MATCH,
  DND_REASON_TIME_ZONE_NOT_MATCH,
  DND_REASON_LOCALE_NOT_MATCH,
  DND_REASON_CHARSET_NOT_MATCH,
  DND_REASON_OTHERS
} EDndReason;

S
Shengliang Guan 已提交
94
typedef struct {
S
Shengliang Guan 已提交
95 96 97 98 99 100 101 102 103 104
  int32_t    id;
  ETrnStage  stage;
  ETrnPolicy policy;
  void      *rpcHandle;
  SArray    *redoLogs;
  SArray    *undoLogs;
  SArray    *commitLogs;
  SArray    *redoActions;
  SArray    *undoActions;
} STrans;
S
Shengliang Guan 已提交
105

S
Shengliang Guan 已提交
106
typedef struct {
S
Shengliang Guan 已提交
107
  int32_t id;
S
Shengliang Guan 已提交
108
  char    name[TSDB_CLUSTER_ID_LEN];
S
Shengliang Guan 已提交
109 110 111 112
  int64_t createdTime;
  int64_t updateTime;
} SClusterObj;

S
Shengliang Guan 已提交
113
typedef struct {
S
Shengliang Guan 已提交
114 115 116 117
  int32_t    id;
  int64_t    createdTime;
  int64_t    updateTime;
  int64_t    rebootTime;
118
  int64_t    lastAccessTime;
S
Shengliang Guan 已提交
119
  int32_t    accessTimes;
S
Shengliang Guan 已提交
120 121 122 123 124 125
  int16_t    numOfMnodes;
  int16_t    numOfVnodes;
  int16_t    numOfQnodes;
  int16_t    numOfSupportMnodes;
  int16_t    numOfSupportVnodes;
  int16_t    numOfSupportQnodes;
S
Shengliang Guan 已提交
126
  int16_t    numOfCores;
S
Shengliang Guan 已提交
127 128 129 130 131
  EDndStatus status;
  EDndReason offlineReason;
  uint16_t   port;
  char       fqdn[TSDB_FQDN_LEN];
  char       ep[TSDB_EP_LEN];
S
Shengliang Guan 已提交
132 133
} SDnodeObj;

S
Shengliang Guan 已提交
134
typedef struct {
S
Shengliang Guan 已提交
135
  int32_t    id;
S
Shengliang Guan 已提交
136 137
  int64_t    createdTime;
  int64_t    updateTime;
S
Shengliang Guan 已提交
138
  ESyncState role;
S
Shengliang Guan 已提交
139 140
  int32_t    roleTerm;
  int64_t    roleTime;
141
  SDnodeObj *pDnode;
S
Shengliang Guan 已提交
142 143 144 145 146 147 148
} SMnodeObj;

typedef struct {
  int32_t maxUsers;
  int32_t maxDbs;
  int32_t maxTimeSeries;
  int32_t maxStreams;
S
Shengliang Guan 已提交
149 150
  int64_t maxStorage;   // In unit of GB
  int32_t accessState;  // Configured only by command
S
Shengliang Guan 已提交
151 152 153 154 155 156 157
} SAcctCfg;

typedef struct {
  int32_t numOfUsers;
  int32_t numOfDbs;
  int32_t numOfTimeSeries;
  int32_t numOfStreams;
S
Shengliang Guan 已提交
158 159
  int64_t totalStorage;  // Total storage wrtten from this account
  int64_t compStorage;   // Compressed storage on disk
S
Shengliang Guan 已提交
160 161
} SAcctInfo;

S
Shengliang Guan 已提交
162
typedef struct {
S
Shengliang Guan 已提交
163 164 165 166
  char      acct[TSDB_USER_LEN];
  int64_t   createdTime;
  int64_t   updateTime;
  int32_t   acctId;
S
Shengliang Guan 已提交
167
  int32_t   status;
S
Shengliang Guan 已提交
168 169 170 171
  SAcctCfg  cfg;
  SAcctInfo info;
} SAcctObj;

S
Shengliang Guan 已提交
172
typedef struct {
S
Shengliang Guan 已提交
173
  char      user[TSDB_USER_LEN];
174
  char      pass[TSDB_PASSWORD_LEN];
S
Shengliang Guan 已提交
175 176 177
  char      acct[TSDB_USER_LEN];
  int64_t   createdTime;
  int64_t   updateTime;
178
  int8_t    superUser;
S
Shengliang Guan 已提交
179
  int32_t   acctId;
S
Shengliang Guan 已提交
180
  SHashObj *prohibitDbHash;
S
Shengliang Guan 已提交
181 182 183
} SUserObj;

typedef struct {
184
  int32_t numOfVgroups;
S
Shengliang Guan 已提交
185 186 187 188 189 190
  int32_t cacheBlockSize;
  int32_t totalBlocks;
  int32_t daysPerFile;
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
S
Shengliang Guan 已提交
191 192
  int32_t minRows;
  int32_t maxRows;
S
Shengliang Guan 已提交
193 194
  int32_t commitTime;
  int32_t fsyncPeriod;
S
Shengliang Guan 已提交
195
  int8_t  walLevel;
S
Shengliang Guan 已提交
196 197 198 199 200 201 202 203
  int8_t  precision;
  int8_t  compression;
  int8_t  replications;
  int8_t  quorum;
  int8_t  update;
  int8_t  cacheLastRow;
} SDbCfg;

S
Shengliang Guan 已提交
204
typedef struct {
S
Shengliang Guan 已提交
205 206 207 208 209
  char    name[TSDB_FULL_DB_NAME_LEN];
  char    acct[TSDB_USER_LEN];
  int64_t createdTime;
  int64_t updateTime;
  int64_t uid;
S
Shengliang Guan 已提交
210 211
  int32_t cfgVersion;
  int32_t vgVersion;
S
Shengliang Guan 已提交
212
  int8_t  hashMethod;  // default is 1
S
Shengliang Guan 已提交
213
  SDbCfg  cfg;
S
Shengliang Guan 已提交
214 215 216 217
} SDbObj;

typedef struct {
  int32_t    dnodeId;
S
Shengliang Guan 已提交
218
  ESyncState role;
S
Shengliang Guan 已提交
219 220
} SVnodeGid;

S
Shengliang Guan 已提交
221
typedef struct {
S
Shengliang Guan 已提交
222
  int32_t   vgId;
S
Shengliang Guan 已提交
223 224
  int64_t   createdTime;
  int64_t   updateTime;
S
Shengliang Guan 已提交
225
  int32_t   version;
S
Shengliang Guan 已提交
226 227
  uint32_t  hashBegin;
  uint32_t  hashEnd;
S
Shengliang Guan 已提交
228
  char      dbName[TSDB_FULL_DB_NAME_LEN];
S
Shengliang Guan 已提交
229
  int64_t   dbUid;
S
Shengliang Guan 已提交
230
  int32_t   numOfTables;
S
Shengliang Guan 已提交
231
  int32_t   numOfTimeSeries;
S
Shengliang Guan 已提交
232 233 234
  int64_t   totalStorage;
  int64_t   compStorage;
  int64_t   pointsWritten;
S
Shengliang Guan 已提交
235 236 237
  int8_t    compact;
  int8_t    replica;
  SVnodeGid vnodeGid[TSDB_MAX_REPLICA];
S
Shengliang Guan 已提交
238 239
} SVgObj;

S
Shengliang Guan 已提交
240
typedef struct {
S
Shengliang Guan 已提交
241 242
  char     name[TSDB_TABLE_FNAME_LEN];
  char     db[TSDB_FULL_DB_NAME_LEN];
243 244
  int64_t  createdTime;
  int64_t  updateTime;
S
Shengliang Guan 已提交
245
  uint64_t uid;
S
Shengliang Guan 已提交
246
  uint64_t dbUid;
S
Shengliang Guan 已提交
247
  int32_t  version;
S
Shengliang Guan 已提交
248 249
  int32_t  numOfColumns;
  int32_t  numOfTags;
S
Shengliang Guan 已提交
250
  SRWLatch lock;
S
Shengliang Guan 已提交
251 252
  SSchema *pSchema;
} SStbObj;
S
Shengliang Guan 已提交
253

S
Shengliang Guan 已提交
254
typedef struct {
S
Shengliang Guan 已提交
255 256
  char    name[TSDB_FUNC_NAME_LEN];
  int64_t createdTime;
S
Shengliang Guan 已提交
257 258 259 260 261 262 263 264 265 266 267 268
  int8_t  funcType;
  int8_t  scriptType;
  int8_t  align;
  int8_t  outputType;
  int32_t outputLen;
  int32_t bufSize;
  int64_t sigature;
  int32_t commentSize;
  int32_t codeSize;
  char   *pComment;
  char   *pCode;
  char    pData[];
S
Shengliang Guan 已提交
269 270
} SFuncObj;

S
Shengliang Guan 已提交
271 272 273 274 275 276 277 278 279 280 281 282 283 284 285
typedef struct {
  int32_t id;
  int8_t  type;
  int8_t  replica;
  int16_t numOfColumns;
  int32_t rowSize;
  int32_t numOfRows;
  int32_t numOfReads;
  int32_t payloadLen;
  void   *pIter;
  SMnode *pMnode;
  char    db[TSDB_FULL_DB_NAME_LEN];
  int16_t offset[TSDB_MAX_COLUMNS];
  int32_t bytes[TSDB_MAX_COLUMNS];
  char    payload[];
S
Shengliang Guan 已提交
286 287
} SShowObj;

S
Shengliang Guan 已提交
288
typedef struct SMnodeMsg {
S
Shengliang Guan 已提交
289
  char    user[TSDB_USER_LEN];
S
Shengliang Guan 已提交
290 291
  char    db[TSDB_FULL_DB_NAME_LEN];
  int32_t acctId;
292
  SMnode *pMnode;
S
Shengliang Guan 已提交
293 294 295 296 297 298 299 300 301
  int16_t received;
  int16_t successed;
  int16_t expected;
  int16_t retry;
  int32_t code;
  int64_t createdTime;
  SRpcMsg rpcMsg;
  int32_t contLen;
  void   *pCont;
S
Shengliang Guan 已提交
302
} SMnodeMsg;
S
Shengliang Guan 已提交
303

S
Shengliang Guan 已提交
304 305
typedef struct {
  int32_t id;
S
Shengliang Guan 已提交
306
  int32_t code;
S
Shengliang Guan 已提交
307 308 309
  void   *rpcHandle;
} STransMsg;

S
Shengliang Guan 已提交
310 311 312
#ifdef __cplusplus
}
#endif
S
Shengliang Guan 已提交
313

S
Shengliang Guan 已提交
314
#endif /*_TD_MND_DEF_H_*/