diff --git a/src/dnode/inc/dnodeRead.h b/src/dnode/inc/dnodeRead.h index c7339e9bfb961977530777f4ce87f91951ffb434..1cd2e44342a3c67331195ebf345d77d2abf7aaf7 100644 --- a/src/dnode/inc/dnodeRead.h +++ b/src/dnode/inc/dnodeRead.h @@ -20,6 +20,12 @@ extern "C" { #endif +/* + * Dnode handle read messages + * The processing result is returned by callback function with pShellObj parameter +*/ +int32_t dnodeReadData(SQueryMeterMsg *msg, void *pShellObj, void (*callback)(SQueryMeterRsp *rspMsg, void *pShellObj)); + #ifdef __cplusplus } #endif diff --git a/src/dnode/inc/dnodeVnodeMgmt.h b/src/dnode/inc/dnodeVnodeMgmt.h index 10ac2a712f628f5504069f31b435fadb798b7f48..9c677ba9e0f3e6f05062de0d6580918c248ce6ea 100644 --- a/src/dnode/inc/dnodeVnodeMgmt.h +++ b/src/dnode/inc/dnodeVnodeMgmt.h @@ -53,7 +53,7 @@ int32_t dnodeConfigVnode(int vid, SVnodeCfg *cfg); /* * Modify vnode replication information */ -int32_t dnodeConfigVnodePeers(int vid, SVpeerCfg *cfg); +int32_t dnodeConfigVnodePeers(int vid, /*SVpeerCfgMsg *cfg*/); /* * Remove vnode from local repository @@ -65,6 +65,7 @@ int32_t dnodeDropVnode(int vid); */ tsdb_repo_t* dnodeGetVnode(int vid); + #ifdef __cplusplus } #endif diff --git a/src/dnode/inc/dnodeWrite.h b/src/dnode/inc/dnodeWrite.h index 2a334fa75c55247c213800b9902f222557754dca..5d33c7305119d8a06274ccf694e64b7bd55984d7 100644 --- a/src/dnode/inc/dnodeWrite.h +++ b/src/dnode/inc/dnodeWrite.h @@ -20,6 +20,32 @@ extern "C" { #endif +/* + * Check if table already exists + */ +int32_t dnodeCheckTableExist(int vid, int sid, int64_t uid); + +/* + * Create table with specified configuration and open it + */ +int32_t dnodeCreateTable(int vid, int sid, SMeterObj *table); + +/* + * Modify table configuration information + */ +int32_t dnodeAlterTable(int vid, SMeterObj *table); + +/* + * Remove table from local repository + */ +int32_t dnodeDropTable(int vid, int sid, int64_t uid); + +/* + * Write data based on dnode + */ +int32_t dnodeWriteData(SShellSubmitMsg *msg); + + #ifdef __cplusplus } #endif