MORPH
SIGN IN SIGN UP
TarsCloud / Tars UNCLAIMED

Tars is a high-performance RPC framework based on name service and Tars protocol, also integrated administration platform, and implemented hosting-service via flexible schedule.

0 0 14 C++
Normal View History Raw
tars 1.0.1
2017-01-18 16:19:06 +08:00
/**
* Tencent is pleased to support the open source community by making Tars available.
*
* Copyright (C) 2016THL A29 Limited, a Tencent company. All rights reserved.
*
* Licensed under the BSD 3-Clause License (the "License"); you may not use this file except
* in compliance with the License. You may obtain a copy of the License at
*
* https://opensource.org/licenses/BSD-3-Clause
*
* Unless required by applicable law or agreed to in writing, software distributed
* under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
* CONDITIONS OF ANY KIND, either express or implied. See the License for the
* specific language governing permissions and limitations under the License.
*/
#ifndef __NODE_IMP_H_
#define __NODE_IMP_H_
#include "Node.h"
#include <unistd.h>
#include "PlatformInfo.h"
#include "Activator.h"
#include "KeepAliveThread.h"
#include "tars_patch.h"
using namespace tars;
using namespace std;
class NodeImp : public Node
{
public:
/**
* 构造函数
*/
NodeImp()
{
}
/**
* 析构函数
*/
~NodeImp()
{
}
/**
* 初始化
*/
virtual void initialize();
/**
* 退出
*/
virtual void destroy()
{
}
/**
* 销毁指定服务
* @param application 服务所属应用名
* @param serverName 服务名
* @return int
*/
virtual int destroyServer( const string& application, const string& serverName, string &result,TarsCurrentPtr current );
/**
* 增强的发布接口
* pushRequest 插入发布请求到队列
* @param req 发布请求
* @return int 0成功 其它失败
*/
int patchPro(const tars::PatchRequest & req, string & result, TarsCurrentPtr current);
/**
* 加载指定文件
* @param out result 失败说明
* @return int 0成功 非0失败
*/
virtual int addFile(const string &application,const string &serverName,const string &file, string &result, TarsCurrentPtr current);
/**
* 获取node名称
* @return string
*/
virtual string getName( TarsCurrentPtr current ) ;
/**
* 获取node上负载
* @return LoadInfo
*/
virtual tars::LoadInfo getLoad( TarsCurrentPtr current ) ;
/**
* 关闭node
* @return int
*/
virtual int shutdown( string &result, TarsCurrentPtr current );
/**
* 关闭nodes上所有服务
* @return int
*/
virtual int stopAllServers( string &result,TarsCurrentPtr current );
/**
* 载入指定服务
* @param application 服务所属应用名
* @param serverName 服务名
* @return int
*/
virtual int loadServer( const string& application, const string& serverName, string &result, TarsCurrentPtr current );
/**
* 启动指定服务
* @param application 服务所属应用名
* @param serverName 服务名
* @return int
*/
virtual int startServer( const string& application, const string& serverName, string &result, TarsCurrentPtr current ) ;
/**
* 停止指定服务
* @param application 服务所属应用名
* @param serverName 服务名
* @return int
*/
virtual int stopServer( const string& application, const string& serverName, string &result, TarsCurrentPtr current ) ;
/**
* 通知服务
* @param application
* @param serverName
* @param result
* @param current
*
* @return int
*/
virtual int notifyServer( const string& application, const string& serverName, const string &command, string &result, TarsCurrentPtr current );
/**
* 获取指定服务pid进程号
* @param application 服务所属应用名
* @param serverName 服务名
* @return int
*/
int getServerPid( const string& application, const string& serverName, string &result, TarsCurrentPtr current);
/**
* 获取指定服务registry设置的状态
* @param application 服务所属应用名
* @param serverName 服务名
* @return int
*/
virtual ServerState getSettingState( const string& application, const string& serverName, string &result, TarsCurrentPtr current ) ;
/**
* 获取指定服务状态
* @param application 服务所属应用名
* @param serverName 服务名
* @return ServerState
*/
virtual ServerState getState( const string& application, const string& serverName, string &result, TarsCurrentPtr current ) ;
/**
* 获取指定服务在node的信息
* @param application 服务所属应用名
* @param serverName 服务名
* @return ServerState
*/
virtual int getStateInfo(const std::string & application,const std::string & serverName,tars::ServerStateInfo &info,std::string &result,tars::TarsCurrentPtr current);
/**
* 同步指定服务状态
* @param application 服务所属应用名
* @param serverName 服务名
* @return int
*/
virtual int synState( const string& application, const string& serverName, string &result, TarsCurrentPtr current ) ;
/**
* 发布服务进度
* @param application 服务所属应用名
* @param serverName 服务名
* @out tPatchInfo 下载信息
* @return int
*/
virtual int getPatchPercent( const string& application, const string& serverName, PatchInfo &tPatchInfo, TarsCurrentPtr current);
virtual tars::Int32 delCache(const std::string & sFullCacheName, const std::string &sBackupPath, const std::string & sKey, std::string &result,TarsCurrentPtr current);
virtual tars::Int32 getUnusedShmKeys(tars::Int32 count,vector<tars::Int32> &shm_keys,tars::TarsCurrentPtr current);
private:
string keyToStr(key_t key_value);
private:
string _downloadPath; //文件下载目录
NodeInfo _nodeInfo; //node信息
PlatformInfo _platformInfo; //平台信息
RegistryPrx _registryPrx; //主控代理
};
typedef TC_AutoPtr<NodeImp> NodeImpPtr;
#endif
Reference in New Issue Copy Permalink