mnodeDef.h 6.9 KB
Newer Older
S
slguan 已提交
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/>.
 */

16 17
#ifndef TDENGINE_MNODE_DEF_H
#define TDENGINE_MNODE_DEF_H
S
slguan 已提交
18 19 20 21 22 23 24 25 26 27 28 29 30 31

#ifdef __cplusplus
extern "C" {
#endif

#include "taosdef.h"
#include "taosmsg.h"

struct SVgObj;
struct SDbObj;
struct SAcctObj;
struct SUserObj;
struct SMnodeObj;

H
Hui Li 已提交
32 33 34 35
/*
struct define notes:
1. The first field must be the xxxxId field or name field , e.g. 'int32_t dnodeId', 'int32_t mnodeId', 'char name[]', 'char user[]', ...
2. From the dnodeId field to the updataEnd field, these information will be falled disc;
H
Hui Li 已提交
36
3. The fields behind the updataEnd field can be changed;
H
Hui Li 已提交
37 38
*/

S
Shengliang Guan 已提交
39 40 41 42 43 44 45 46
typedef struct SClusterObj {
  int32_t clusterId;
  int64_t createdTime;
  int8_t  reserved[36];
  int8_t  updateEnd[4];
  int32_t refCount;
} SClusterObj;

S
slguan 已提交
47 48 49
typedef struct SDnodeObj {
  int32_t    dnodeId;
  int32_t    openVnodes;
H
Hui Li 已提交
50
  int64_t    createdTime;
S
Shengliang Guan 已提交
51
  int32_t    resever0;         // from dnode status msg, config information
S
slguan 已提交
52
  int32_t    customScore;      // config by user
H
Hui Li 已提交
53
  uint32_t   lastAccess;
S
slguan 已提交
54
  uint16_t   numOfCores;       // from dnode status msg
H
Hui Li 已提交
55 56 57
  uint16_t   dnodePort;
  char       dnodeFqdn[TSDB_FQDN_LEN];
  char       dnodeEp[TSDB_EP_LEN];
S
slguan 已提交
58 59 60
  int8_t     alternativeRole;  // from dnode status msg, 0-any, 1-mgmt, 2-dnode
  int8_t     status;           // set in balance function
  int8_t     isMgmt;
S
Shengliang Guan 已提交
61 62
  int8_t     reserve1[11];  
  int8_t     updateEnd[4];
S
slguan 已提交
63 64 65
  int32_t    refCount;
  uint32_t   moduleStatus;
  uint32_t   lastReboot;       // time stamp for last reboot
66
  float      score;            // calc in balance function
S
slguan 已提交
67 68 69 70 71
  float      diskAvailable;    // from dnode status msg
  int16_t    diskAvgUsage;     // calc from sys.disk
  int16_t    cpuAvgUsage;      // calc from sys.cpu
  int16_t    memoryAvgUsage;   // calc from sys.mem
  int16_t    bandwidthUsage;   // calc from sys.band
S
Shengliang Guan 已提交
72
  int8_t     reserved2[2];
S
slguan 已提交
73 74 75 76
} SDnodeObj;

typedef struct SMnodeObj {
  int32_t    mnodeId;
H
Hui Li 已提交
77
  int8_t     reserved0[4];
S
slguan 已提交
78
  int64_t    createdTime;
S
Shengliang Guan 已提交
79 80
  int8_t     reserved1[4];
  int8_t     updateEnd[4];
S
slguan 已提交
81 82
  int32_t    refCount;
  int8_t     role;
H
Hui Li 已提交
83
  int8_t     reserved2[3];
S
slguan 已提交
84 85
} SMnodeObj;

86
typedef struct STableObj {
87
  char  *tableId;
S
slguan 已提交
88 89 90 91
  int8_t type;
} STableObj;

typedef struct SSuperTableObj {
H
Hui Li 已提交
92
  STableObj  info; 
L
liu0x54 已提交
93 94
  int8_t     reserved0[1]; // for fill struct STableObj to 4byte align
  int16_t    nextColId;
H
Hui Li 已提交
95
  int32_t    sversion;
S
slguan 已提交
96 97
  uint64_t   uid;
  int64_t    createdTime;
S
TD-355  
Shengliang Guan 已提交
98
  int32_t    tversion;
S
slguan 已提交
99 100
  int32_t    numOfColumns;
  int32_t    numOfTags;
S
Shengliang Guan 已提交
101
  int8_t     updateEnd[4];
S
slguan 已提交
102 103 104
  int32_t    refCount;
  int32_t    numOfTables;
  SSchema *  schema;
105
  void *     vgHash;
H
Hui Li 已提交
106
  int8_t     reserved2[6];
S
slguan 已提交
107 108 109
} SSuperTableObj;

typedef struct {
H
Hui Li 已提交
110
  STableObj  info;  
L
liu0x54 已提交
111 112
  int8_t     reserved0[1]; // for fill struct STableObj to 4byte align
  int16_t    nextColId;    //used by normal table
H
Hui Li 已提交
113
  int32_t    sversion;     //used by normal table  
S
slguan 已提交
114
  uint64_t   uid;
H
Hui Li 已提交
115
  uint64_t   suid;
S
slguan 已提交
116 117 118 119 120
  int64_t    createdTime;
  int32_t    numOfColumns; //used by normal table
  int32_t    sid;
  int32_t    vgId;
  int32_t    sqlLen;
S
Shengliang Guan 已提交
121
  int8_t     updateEnd[4];
H
Hui Li 已提交
122
  int32_t    refCount;
S
slguan 已提交
123 124 125 126 127
  char*      sql;          //used by normal table
  SSchema*   schema;       //used by normal table
  SSuperTableObj *superTable;
} SChildTableObj;

S
slguan 已提交
128 129 130 131 132 133 134
typedef struct {
  int32_t    dnodeId;
  int8_t     role;
  int8_t     reserved[3];
  SDnodeObj* pDnode;
} SVnodeGid;

S
slguan 已提交
135
typedef struct SVgObj {
S
slguan 已提交
136 137
  uint32_t       vgId;
  int32_t        numOfVnodes;
H
Hui Li 已提交
138
  int64_t        createdTime;
S
slguan 已提交
139 140
  int32_t        lbDnodeId;
  int32_t        lbTime;
H
Hui Li 已提交
141
  char           dbName[TSDB_ACCT_LEN + TSDB_DB_NAME_LEN];
S
slguan 已提交
142
  int8_t         inUse;
143
  int8_t         accessState;
144 145
  int8_t         status;
  int8_t         reserved0[4];
H
Hui Li 已提交
146
  SVnodeGid      vnodeGid[TSDB_MAX_REPLICA];
S
Shengliang Guan 已提交
147 148
  int8_t         reserved1[4];
  int8_t         updateEnd[4];
S
slguan 已提交
149 150 151 152 153
  int32_t        refCount;
  int32_t        numOfTables;
  int64_t        totalStorage;
  int64_t        compStorage;
  int64_t        pointsWritten;
H
Hui Li 已提交
154
  struct SDbObj *pDb;
S
slguan 已提交
155
  void *         idPool;
S
slguan 已提交
156 157
} SVgObj;

S
slguan 已提交
158
typedef struct {
S
slguan 已提交
159 160
  int32_t cacheBlockSize;
  int32_t totalBlocks;
S
slguan 已提交
161 162 163 164 165
  int32_t maxTables;
  int32_t daysPerFile;
  int32_t daysToKeep;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
S
slguan 已提交
166 167
  int32_t minRowsPerFileBlock;
  int32_t maxRowsPerFileBlock;
S
slguan 已提交
168
  int32_t commitTime;
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
169
  int32_t fsyncPeriod;
S
slguan 已提交
170 171
  int8_t  precision;
  int8_t  compression;
H
hjxilinx 已提交
172
  int8_t  walLevel;
S
slguan 已提交
173
  int8_t  replications;
H
Hui Li 已提交
174
  int8_t  reserved[12];
S
slguan 已提交
175 176
} SDbCfg;

S
slguan 已提交
177
typedef struct SDbObj {
B
Bomin Zhang 已提交
178
  char    name[TSDB_ACCT_LEN + TSDB_DB_NAME_LEN];
H
Hui Li 已提交
179
  int8_t  reserved0[4];
B
Bomin Zhang 已提交
180
  char    acct[TSDB_USER_LEN];
S
slguan 已提交
181
  int64_t createdTime;
S
slguan 已提交
182
  int32_t cfgVersion;
S
slguan 已提交
183
  SDbCfg  cfg;
S
slguan 已提交
184
  int8_t  status;
S
Shengliang Guan 已提交
185 186
  int8_t  reserved1[11];
  int8_t  updateEnd[4];
S
slguan 已提交
187 188 189 190
  int32_t refCount;
  int32_t numOfVgroups;
  int32_t numOfTables;
  int32_t numOfSuperTables;
191 192 193
  int32_t vgListSize; 
  int32_t vgListIndex;
  SVgObj **vgList;
S
slguan 已提交
194
  struct SAcctObj *pAcct;
195
  pthread_mutex_t  mutex;
S
slguan 已提交
196 197 198
} SDbObj;

typedef struct SUserObj {
B
Bomin Zhang 已提交
199 200 201
  char              user[TSDB_USER_LEN];
  char              pass[TSDB_KEY_LEN];
  char              acct[TSDB_USER_LEN];
S
slguan 已提交
202 203 204
  int64_t           createdTime;
  int8_t            superAuth;
  int8_t            writeAuth;
S
Shengliang Guan 已提交
205 206
  int8_t            reserved[10];
  int8_t            updateEnd[4];
S
slguan 已提交
207 208 209 210 211 212 213 214 215 216 217 218
  int32_t           refCount;
  struct SAcctObj * pAcct;
} SUserObj;

typedef struct {
  int64_t totalStorage;  // Total storage wrtten from this account
  int64_t compStorage;   // Compressed storage on disk
  int64_t queryTime;
  int64_t totalPoints;
  int64_t inblound;
  int64_t outbound;
  int64_t sKey;
H
Hui Li 已提交
219 220 221 222 223 224 225
  int32_t numOfUsers;
  int32_t numOfDbs;
  int32_t numOfTimeSeries;
  int32_t numOfPointsPerSecond;
  int32_t numOfConns;
  int32_t numOfQueries;
  int32_t numOfStreams;
S
slguan 已提交
226
  int8_t  accessState;   // Checked by mgmt heartbeat message
H
Hui Li 已提交
227
  int8_t  reserved[3];
S
slguan 已提交
228 229 230
} SAcctInfo;

typedef struct SAcctObj {
B
Bomin Zhang 已提交
231
  char      user[TSDB_USER_LEN];
B
Bomin Zhang 已提交
232
  char      pass[TSDB_KEY_LEN];
S
slguan 已提交
233 234
  SAcctCfg  cfg;
  int64_t   createdTime;
H
Hui Li 已提交
235
  int32_t   acctId;
S
slguan 已提交
236
  int8_t    status;
S
Shengliang Guan 已提交
237 238
  int8_t    reserved0[7];
  int8_t    updateEnd[4];
H
Hui Li 已提交
239 240
  int32_t   refCount;
  int8_t    reserved1[4];
S
Shengliang Guan 已提交
241
  SAcctInfo acctInfo;
S
slguan 已提交
242 243 244 245
  pthread_mutex_t  mutex;
} SAcctObj;

typedef struct {
B
Bomin Zhang 已提交
246
  char     db[TSDB_DB_NAME_LEN];
H
Hui Li 已提交
247
  int8_t   type;
S
slguan 已提交
248
  int16_t  numOfColumns;
H
Hui Li 已提交
249
  int32_t  index;
S
slguan 已提交
250 251
  int32_t  rowSize;
  int32_t  numOfRows;
H
Hui Li 已提交
252
  void *   pIter;
S
slguan 已提交
253 254
  int16_t  offset[TSDB_MAX_COLUMNS];
  int16_t  bytes[TSDB_MAX_COLUMNS];
H
Hui Li 已提交
255
  int32_t  numOfReads;
256 257
  int8_t   maxReplica;
  int8_t   reserved0[0];
S
slguan 已提交
258 259 260 261 262 263 264 265 266
  uint16_t payloadLen;
  char     payload[];
} SShowObj;

#ifdef __cplusplus
}
#endif

#endif