/*
 * 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 _TD_VNODE_H_
#define _TD_VNODE_H_

#include "os.h"
#include "taosmsg.h"
#include "trpc.h"

#ifdef __cplusplus
extern "C" {
#endif

typedef struct SVnode SVnode;

typedef struct {
  char       dbName[TSDB_ACCT_ID_LEN + TSDB_DB_NAME_LEN];
  int32_t    cacheBlockSize;  // MB
  int32_t    totalBlocks;
  int32_t    daysPerFile;
  int32_t    daysToKeep0;
  int32_t    daysToKeep1;
  int32_t    daysToKeep2;
  int32_t    minRowsPerFileBlock;
  int32_t    maxRowsPerFileBlock;
  int8_t     precision;  // time resolution
  int8_t     compression;
  int8_t     cacheLastRow;
  int8_t     update;
  int8_t     quorum;
  int8_t     replica;
  int8_t     walLevel;
  int32_t    fsyncPeriod;  // millisecond
  SVnodeDesc replicas[TSDB_MAX_REPLICA];
} SVnodeCfg;

typedef struct {
  int64_t totalStorage;
  int64_t compStorage;
  int64_t pointsWritten;
  int64_t tablesNum;
} SVnodeStatisic;

typedef struct {
  int8_t syncRole;
} SVnodeStatus;

typedef struct SVnodeMsg {
  int32_t msgType;
  int32_t code;
  SRpcMsg rpcMsg;  // original message from rpc
  int32_t contLen;
  char    pCont[];
} SVnodeMsg;

int32_t vnodeInit();
void    vnodeCleanup();

int32_t vnodeGetStatistics(SVnode *pVnode, SVnodeStatisic *pStat);
int32_t vnodeGetStatus(SVnode *pVnode, SVnodeStatus *pStatus);

SVnode *vnodeOpen(int32_t vgId, const char *path);
void    vnodeClose(SVnode *pVnode);
int32_t vnodeAlter(SVnode *pVnode, const SVnodeCfg *pCfg);
SVnode *vnodeCreate(int32_t vgId, const char *path, const SVnodeCfg *pCfg);
int32_t vnodeDrop(SVnode *pVnode);
int32_t vnodeCompact(SVnode *pVnode);
int32_t vnodeSync(SVnode *pVnode);

void vnodeProcessMsg(SVnode *pVnode, SVnodeMsg *pMsg);

#ifdef __cplusplus
}
#endif

#endif /*_TD_VNODE_H_*/