Nebula
Nebula
neb 命名空间参考

class  Actor
 
class  ActorFactory
 
class  Chain
 
class  Cmd
 
class  Module
 
class  CmdBeat
 
class  CmdNodeNotice
 节点注册 更多...
 
class  CmdReloadCustomConf
 
class  CmdSetNodeConf
 
class  CmdSetNodeCustomConf
 
class  CmdToldWorker
 
class  CmdUpdateNodeId
 
class  ModuleHttpUpgrade
 
class  Context
 Actor上下文信息 更多...
 
class  HttpContext
 
class  PbContext
 
class  DynamicCreator
 
class  Model
 
class  Session
 
class  SessionLogger
 
class  SessionManagerLogger
 
class  SessionNode
 节点Session 更多...
 
class  Timer
 
class  HttpStep
 
class  PbStep
 
class  RedisStep
 StepRedis在回调后一定会被删除 更多...
 
class  Step
 
class  StepConnectWorker
 
class  StepIoTimeout
 IO超时回调步骤 更多...
 
class  StepTellWorker
 
class  Channel
 
class  RedisChannel
 
class  SocketChannel
 
class  SocketChannelImpl
 
class  Codec
 
struct  tagMsgHead
 与客户端通信消息头 更多...
 
class  CodecHttp
 
class  CodecPrivate
 
class  CodecProto
 
class  CodecWsExtentJson
 
class  CodecWsExtentPb
 
class  Labor
 
class  Manager
 
class  Worker
 
class  WorkerFriend
 
class  WorkerImpl
 
class  FileLogger
 
class  Logger
 
class  NetLogger
 
class  DbOperator
 StarMydis数据库请求协议生成器 更多...
 
class  MydisOperator
 存储请求协议生成器 更多...
 
class  Operator
 存储协议操作者 更多...
 
class  RedisOperator
 StarMydis Redis请求协议生成器 更多...
 
struct  StaticDescriptorInitializer_mydis_2eproto
 
class  Mydis_RedisOperate
 
class  Mydis_DbOperate_Condition
 
class  Mydis_DbOperate_ConditionGroup
 
class  Mydis_DbOperate_OrderBy
 
class  Mydis_DbOperate
 
class  Mydis
 
class  Record
 
class  Field
 
class  Result_DataLocate
 
class  Result
 
struct  StaticDescriptorInitializer_neb_5fsys_2eproto
 
class  ConfigInfo
 
class  WorkerLoad
 
class  TargetWorker
 
class  LogLevel
 
class  TraceLog
 
class  CBuffer
 
class  CTlv
 TLV应用层通信协议类 更多...
 
class  CJsonObject
 
class  CStreamCodec
 

类型定义

typedef unsigned int uint32_t
 

枚举

enum  E_CMD {
  CMD_UNDEFINE = 0, CMD_REQ_CONNECT_TO_WORKER = 1, CMD_RSP_CONNECT_TO_WORKER = 2, CMD_REQ_TELL_WORKER = 3,
  CMD_RSP_TELL_WORKER = 4, CMD_REQ_DISCONNECT = 5, CMD_RSP_DISCONNECT = 6, CMD_REQ_REFRESH_SERVER = 7,
  CMD_RSP_REFRESH_SERVER = 8, CMD_REQ_SET_LOG_LEVEL = 9, CMD_RSP_SET_LOG_LEVEL = 10, CMD_REQ_RELOAD_SO = 11,
  CMD_RSP_RELOAD_SO = 12, CMD_REQ_UPDATE_WORKER_LOAD = 13, CMD_RSP_UPDATE_WORKER_LOAD = 14, CMD_REQ_NODE_STATUS_REPORT = 101,
  CMD_RSP_NODE_STATUS_REPORT = 102, CMD_REQ_NODE_REGISTER = 103, CMD_RSP_NODE_REGISTER = 104, CMD_REQ_NODE_NOTICE = 105,
  CMD_RSP_NODE_NOTICE = 106, CMD_REQ_REFRESH_NODE_ID = 107, CMD_RSP_REFRESH_NODE_ID = 108, CMD_REQ_SERVER_DATA_STATUS_REPORT = 109,
  CMD_RSP_SERVER_DATA_STATUS_REPORT = 110, CMD_REQ_GET_LOAD_MIN_SERVER = 111, CMD_RSP_GET_LOAD_MIN_SERVER = 112, CMD_REQ_LEADER_ELECTION = 113,
  CMD_RSP_LEADER_ELECTION = 114, CMD_REQ_SET_NODE_CONFIG = 201, CMD_RSP_SET_NODE_CONFIG = 202, CMD_REQ_GET_NODE_CONFIG = 203,
  CMD_RSP_GET_NODE_CONFIG = 204, CMD_REQ_SET_NODE_CUSTOM_CONFIG = 205, CMD_RSP_SET_NODE_CUSTOM_CONFIG = 206, CMD_REQ_GET_NODE_CUSTOM_CONFIG = 207,
  CMD_RSP_GET_NODE_CUSTOM_CONFIG = 208, CMD_REQ_SET_CUSTOM_CONFIG = 209, CMD_RSP_SET_CUSTOM_CONFIG = 210, CMD_REQ_GET_CUSTOM_CONFIG = 211,
  CMD_RSP_GET_CUSTOM_CONFIG = 212, CMD_REQ_RELOAD_CUSTOM_CONFIG = 213, CMD_RSP_RELOAD_CUSTOM_CONFIG = 214, CMD_REQ_LOG4_TRACE = 401,
  CMD_RSP_LOG4_TRACE = 402, CMD_REQ_FROM_CLIENT = 501, CMD_RSP_FROM_CLIENT = 502, CMD_REQ_TO_CLIENT = 503,
  CMD_RSP_TO_CLIENT = 504, CMD_REQ_STORATE = 505, CMD_RSP_STORATE = 506, CMD_REQ_BEAT = 507,
  CMD_RSP_BEAT = 508, CMD_REQ_LOCATE_STORAGE = 511, CMD_RSP_LOCATE_STORAGE = 512, CMD_REQ_SYS_ERROR = 999,
  CMD_RSP_SYS_ERROR = 1000
}
 保留命令字 更多...
 
enum  E_HASH_ALGORITHM { HASH_fnv1a_64 = 0, HASH_fnv1_64 = 1, HASH_murmur3_32 = 2 }
 
enum  E_CODEC_TYPE {
  CODEC_UNKNOW = 0, CODEC_PROTO = 1, CODEC_NEBULA = 2, CODEC_HTTP = 3,
  CODEC_HTTP_CUSTOM = 4, CODEC_PRIVATE = 5, CODEC_WS_EXTEND_JSON = 6, CODEC_WS_EXTEND_PB = 7
}
 
enum  E_CODEC_STATUS {
  CODEC_STATUS_OK = 0, CODEC_STATUS_PAUSE = 1, CODEC_STATUS_WANT_READ = 2, CODEC_STATUS_WANT_WRITE = 3,
  CODEC_STATUS_INVALID = 4, CODEC_STATUS_ERR = 5, CODEC_STATUS_EOF = 6, CODEC_STATUS_INT = 7
}
 编解码状态 更多...
 
enum  E_CMD_STATUS {
  CMD_STATUS_START = 0, CMD_STATUS_RUNNING = 1, CMD_STATUS_COMPLETED = 2, CMD_STATUS_OK = 3,
  CMD_STATUS_FAULT = 4
}
 命令执行状态 更多...
 
enum  E_CHANNEL_STATUS {
  CHANNEL_STATUS_INIT = 0, CHANNEL_STATUS_TRY_CONNECT = 1, CHANNEL_STATUS_CONNECTED = 2, CHANNEL_STATUS_TRANSFER_TO_WORKER = 3,
  CHANNEL_STATUS_WORKER = 4, CHANNEL_STATUS_TELL_WORKER = 5, CHANNEL_STATUS_ESTABLISHED = 6, CHANNEL_STATUS_CLOSED = 7
}
 通信通道状态 更多...
 
enum  E_ERROR_NO {
  ERR_OK = 0, ERR_CHANNEL_EOF = 9001, ERR_TRANSFER_FD = 9002, ERR_PARASE_PROTOBUF = 10000,
  ERR_NO_SUCH_WORKER_INDEX = 10001, ERR_UNKNOWN_CMD = 10002, ERR_NEW = 10003, ERR_REDIS_CONN_CLOSE = 10004,
  ERR_DISCONNECT = 10005, ERR_NO_CALLBACK = 10006, ERR_DATA_TRANSFER = 10007, ERR_REPEAT_REGISTERED = 10008,
  ERR_SERVERINFO = 10009, ERR_SESSION = 10010, ERR_BODY_JSON = 10011, ERR_SERVERINFO_RECORD = 10012,
  ERR_NODE_NUM = 10013, ERR_SSL_INIT = 10014, ERR_SSL_CTX = 10015, ERR_SSL_CERTIFICATE = 10016,
  ERR_SSL_NEW_CONNECTION = 10017, ERR_SSL_HANDSHAKE = 10018, ERR_SSL_SHUTDOWN = 10019, ERR_FILE_NOT_EXIST = 10020,
  ERR_CONNECTION = 10021, ERR_INCOMPLET_DATAPROXY_DATA = 11001, ERR_INVALID_REDIS_ROUTE = 11002, ERR_REDIS_NODE_NOT_FOUND = 11003,
  ERR_REGISTERCALLBACK_REDIS = 11004, ERR_REDIS_CMD = 11005, ERR_UNEXPECTED_REDIS_REPLY = 11006, ERR_RESULTSET_EXCEED = 11007,
  ERR_LACK_CLUSTER_INFO = 11008, ERR_TIMEOUT = 11009, ERR_REDIS_AND_DB_CMD_NOT_MATCH = 11010, ERR_REDIS_NIL_AND_DB_FAILED = 11011,
  ERR_NO_RIGHT = 11012, ERR_QUERY = 11013, ERR_REDIS_STRUCTURE_WITH_DATASET = 11014, ERR_REDIS_STRUCTURE_WITHOUT_DATASET = 11015,
  ERR_DB_FIELD_NUM = 11016, ERR_DB_FIELD_ORDER_OR_FIELD_NAME = 11017, ERR_KEY_FIELD = 11018, ERR_KEY_FIELD_VALUE = 11019,
  ERR_JOIN_FIELDS = 11020, ERR_LACK_JOIN_FIELDS = 11021, ERR_REDIS_STRUCTURE_NOT_DEFINE = 11022, ERR_INVALID_CMD_FOR_HASH_DATASET = 11023,
  ERR_DB_TABLE_NOT_DEFINE = 11024, ERR_DB_OPERATE_MISSING = 11025, ERR_REQ_MISS_PARAM = 11026, ERR_LACK_TABLE_FIELD = 11027,
  ERR_TABLE_FIELD_NAME_EMPTY = 11028, ERR_UNDEFINE_REDIS_OPERATE = 11029, ERR_REDIS_READ_WRITE_CMD_NOT_MATCH = 11030
}
 系统错误码定义 更多...
 
enum  E_MEM_FIELD_OPERATOR { FIELD_OPERATOR_DB = 0x0001, FIELD_OPERATOR_REDIS = 0x0002 }
 
enum  Mydis_RedisOperate_OPERATE_TYPE { Mydis_RedisOperate_OPERATE_TYPE_T_READ = 0, Mydis_RedisOperate_OPERATE_TYPE_T_WRITE = 1, Mydis_RedisOperate_OPERATE_TYPE_Mydis_RedisOperate_OPERATE_TYPE_INT_MIN_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32min, Mydis_RedisOperate_OPERATE_TYPE_Mydis_RedisOperate_OPERATE_TYPE_INT_MAX_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32max }
 
enum  Mydis_DbOperate_Condition_E_RELATION {
  Mydis_DbOperate_Condition_E_RELATION_EQ = 0, Mydis_DbOperate_Condition_E_RELATION_NE = 1, Mydis_DbOperate_Condition_E_RELATION_GT = 2, Mydis_DbOperate_Condition_E_RELATION_LT = 3,
  Mydis_DbOperate_Condition_E_RELATION_GE = 4, Mydis_DbOperate_Condition_E_RELATION_LE = 5, Mydis_DbOperate_Condition_E_RELATION_LIKE = 6, Mydis_DbOperate_Condition_E_RELATION_IN = 7,
  Mydis_DbOperate_Condition_E_RELATION_Mydis_DbOperate_Condition_E_RELATION_INT_MIN_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32min, Mydis_DbOperate_Condition_E_RELATION_Mydis_DbOperate_Condition_E_RELATION_INT_MAX_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32max
}
 
enum  Mydis_DbOperate_ConditionGroup_E_RELATION { Mydis_DbOperate_ConditionGroup_E_RELATION_AND = 0, Mydis_DbOperate_ConditionGroup_E_RELATION_OR = 1, Mydis_DbOperate_ConditionGroup_E_RELATION_Mydis_DbOperate_ConditionGroup_E_RELATION_INT_MIN_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32min, Mydis_DbOperate_ConditionGroup_E_RELATION_Mydis_DbOperate_ConditionGroup_E_RELATION_INT_MAX_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32max }
 
enum  Mydis_DbOperate_OrderBy_E_RELATION { Mydis_DbOperate_OrderBy_E_RELATION_ASC = 0, Mydis_DbOperate_OrderBy_E_RELATION_DESC = 1, Mydis_DbOperate_OrderBy_E_RELATION_Mydis_DbOperate_OrderBy_E_RELATION_INT_MIN_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32min, Mydis_DbOperate_OrderBy_E_RELATION_Mydis_DbOperate_OrderBy_E_RELATION_INT_MAX_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32max }
 
enum  Mydis_DbOperate_E_QUERY_TYPE {
  Mydis_DbOperate_E_QUERY_TYPE_SELECT = 0, Mydis_DbOperate_E_QUERY_TYPE_INSERT = 1, Mydis_DbOperate_E_QUERY_TYPE_INSERT_IGNORE = 2, Mydis_DbOperate_E_QUERY_TYPE_UPDATE = 3,
  Mydis_DbOperate_E_QUERY_TYPE_REPLACE = 4, Mydis_DbOperate_E_QUERY_TYPE_DELETE = 5, Mydis_DbOperate_E_QUERY_TYPE_Mydis_DbOperate_E_QUERY_TYPE_INT_MIN_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32min, Mydis_DbOperate_E_QUERY_TYPE_Mydis_DbOperate_E_QUERY_TYPE_INT_MAX_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32max
}
 
enum  Result_E_RESULT_FROM { Result_E_RESULT_FROM_FROM_DB = 0, Result_E_RESULT_FROM_FROM_REDIS = 1, Result_E_RESULT_FROM_Result_E_RESULT_FROM_INT_MIN_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32min, Result_E_RESULT_FROM_Result_E_RESULT_FROM_INT_MAX_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32max }
 
enum  E_COL_TYPE {
  STRING = 0, INT = 1, BIGINT = 2, FLOAT = 3,
  DOUBLE = 4, E_COL_TYPE_INT_MIN_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32min, E_COL_TYPE_INT_MAX_SENTINEL_DO_NOT_USE_ = ::google::protobuf::kint32max
}
 
enum  E_STREAM_CODEC_TYPE {
  STREAM_CODEC_UNKNOW = 0, STREAM_CODEC_TLV = 1, STREAM_CODEC_PROTOBUF = 2, STREAM_CODEC_HTTP = 3,
  STREAM_CODEC_HTTP_CUSTOM = 4
}
 

函数

unsigned long long ntohll (unsigned long long val)
 
unsigned long long htonll (unsigned long long val)
 
void protobuf_AssignDesc_mydis_2eproto () GOOGLE_ATTRIBUTE_COLD
 
void protobuf_ShutdownFile_mydis_2eproto ()
 
void protobuf_AddDesc_mydis_2eproto () GOOGLE_ATTRIBUTE_COLD
 
const
::google::protobuf::EnumDescriptor * 
E_COL_TYPE_descriptor ()
 
bool E_COL_TYPE_IsValid (int value)
 
const
::google::protobuf::EnumDescriptor * 
Mydis_RedisOperate_OPERATE_TYPE_descriptor ()
 
bool Mydis_RedisOperate_OPERATE_TYPE_IsValid (int value)
 
const
::google::protobuf::EnumDescriptor * 
Mydis_DbOperate_E_QUERY_TYPE_descriptor ()
 
bool Mydis_DbOperate_E_QUERY_TYPE_IsValid (int value)
 
const
::google::protobuf::EnumDescriptor * 
Mydis_DbOperate_Condition_E_RELATION_descriptor ()
 
bool Mydis_DbOperate_Condition_E_RELATION_IsValid (int value)
 
const
::google::protobuf::EnumDescriptor * 
Mydis_DbOperate_ConditionGroup_E_RELATION_descriptor ()
 
bool Mydis_DbOperate_ConditionGroup_E_RELATION_IsValid (int value)
 
const
::google::protobuf::EnumDescriptor * 
Mydis_DbOperate_OrderBy_E_RELATION_descriptor ()
 
bool Mydis_DbOperate_OrderBy_E_RELATION_IsValid (int value)
 
const
::google::protobuf::EnumDescriptor * 
Result_E_RESULT_FROM_descriptor ()
 
bool Result_E_RESULT_FROM_IsValid (int value)
 
const ::std::string & Mydis_RedisOperate_OPERATE_TYPE_Name (Mydis_RedisOperate_OPERATE_TYPE value)
 
bool Mydis_RedisOperate_OPERATE_TYPE_Parse (const ::std::string &name, Mydis_RedisOperate_OPERATE_TYPE *value)
 
const ::std::string & Mydis_DbOperate_Condition_E_RELATION_Name (Mydis_DbOperate_Condition_E_RELATION value)
 
bool Mydis_DbOperate_Condition_E_RELATION_Parse (const ::std::string &name, Mydis_DbOperate_Condition_E_RELATION *value)
 
const ::std::string & Mydis_DbOperate_ConditionGroup_E_RELATION_Name (Mydis_DbOperate_ConditionGroup_E_RELATION value)
 
bool Mydis_DbOperate_ConditionGroup_E_RELATION_Parse (const ::std::string &name, Mydis_DbOperate_ConditionGroup_E_RELATION *value)
 
const ::std::string & Mydis_DbOperate_OrderBy_E_RELATION_Name (Mydis_DbOperate_OrderBy_E_RELATION value)
 
bool Mydis_DbOperate_OrderBy_E_RELATION_Parse (const ::std::string &name, Mydis_DbOperate_OrderBy_E_RELATION *value)
 
const ::std::string & Mydis_DbOperate_E_QUERY_TYPE_Name (Mydis_DbOperate_E_QUERY_TYPE value)
 
bool Mydis_DbOperate_E_QUERY_TYPE_Parse (const ::std::string &name, Mydis_DbOperate_E_QUERY_TYPE *value)
 
const ::std::string & Result_E_RESULT_FROM_Name (Result_E_RESULT_FROM value)
 
bool Result_E_RESULT_FROM_Parse (const ::std::string &name, Result_E_RESULT_FROM *value)
 
const ::std::string & E_COL_TYPE_Name (E_COL_TYPE value)
 
bool E_COL_TYPE_Parse (const ::std::string &name, E_COL_TYPE *value)
 
void protobuf_AssignDesc_neb_5fsys_2eproto () GOOGLE_ATTRIBUTE_COLD
 
void protobuf_ShutdownFile_neb_5fsys_2eproto ()
 
void protobuf_AddDesc_neb_5fsys_2eproto () GOOGLE_ATTRIBUTE_COLD
 
unsigned char ToHex (unsigned char x)
 
unsigned char FromHex (unsigned char x)
 
std::string UrlEncode (const std::string &str)
 
std::string UrlDecode (const std::string &str)
 
std::string CharToHex (char c)
 
char HexToChar (const std::string &sHex)
 
std::string EncodeHexToString (const std::string &sSrc)
 
std::string DecodeStringToHex (const std::string &sSrc)
 
void EncodeParameter (const std::map< std::string, std::string > &mapParameters, std::string &strParameter)
 
void DecodeParameter (const std::string &strParameter, std::map< std::string, std::string > &mapParameters)
 

变量

const unsigned int gc_uiCmdReq = 0x00000001
 请求(奇数为请求,偶数为应答,通过 gc_iCmdReq & iCmd 来判断,比运算快) 更多...
 
const unsigned int gc_uiCmdBit = 0x0000FFFF
 命令为无符号短整型 更多...
 
const unsigned long FNV_64_INIT = 0x100000001b3
 
const unsigned long FNV_64_PRIME = 0xcbf29ce484222325
 
const unsigned int gc_uiGzipBit = 0x10000000
 采用zip压缩 更多...
 
const unsigned int gc_uiZipBit = 0x20000000
 采用gzip压缩 更多...
 
const unsigned int gc_uiRc5Bit = 0x01000000
 采用12轮Rc5加密 更多...
 
const unsigned int gc_uiAesBit = 0x02000000
 采用128位aes加密 更多...
 
const uint8 WEBSOCKET_FIN = 0x80
 
const uint8 WEBSOCKET_RSV1 = 0x40
 
const uint8 WEBSOCKET_RSV2 = 0x20
 
const uint8 WEBSOCKET_RSV3 = 0x10
 
const uint8 WEBSOCKET_OPCODE = 0x0F
 
const uint8 WEBSOCKET_FRAME_CONTINUE = 0
 
const uint8 WEBSOCKET_FRAME_TEXT = 1
 
const uint8 WEBSOCKET_FRAME_BINARY = 2
 
const uint8 WEBSOCKET_FRAME_CLOSE = 8
 
const uint8 WEBSOCKET_FRAME_PING = 9
 
const uint8 WEBSOCKET_FRAME_PONG = 10
 
const uint8 WEBSOCKET_MASK = 0x80
 
const uint8 WEBSOCKET_PAYLOAD_LEN = 0x7F
 
const uint8 WEBSOCKET_PAYLOAD_LEN_UINT16 = 126
 
const uint8 WEBSOCKET_PAYLOAD_LEN_UINT64 = 127
 
const int gc_iBeatInterval = NODE_BEAT
 心跳间隔时间(单位:秒) 更多...
 
const int gc_iMaxEpollEvents = 100
 每次epoll_wait能处理的最大事件数 更多...
 
const int gc_iMaxBuffLen = 65535
 最大缓冲区大小 更多...
 
const int gc_iErrBuffLen = 256
 错误信息缓冲区大小 更多...
 
const int gc_iAddrLen = 64
 IP地址长度 更多...
 
const uint32 gc_uiMsgHeadSize = 15
 
const uint32 gc_uiClientMsgHeadSize = 14
 
const ev_tstamp gc_dNoTimeout = -1
 
const ev_tstamp gc_dDefaultTimeout = 0
 
const unsigned int gc_uiMaxLogLineLen = 1024
 
const unsigned int gc_uiMaxLogFileSize = 2048000
 
const unsigned int gc_uiMaxRollLogFileIndex = 9
 
const std::string LogLevMsg [Logger::LEV_MAX]
 
struct
neb::StaticDescriptorInitializer_mydis_2eproto 
static_descriptor_initializer_mydis_2eproto_
 
const
Mydis_RedisOperate_OPERATE_TYPE 
Mydis_RedisOperate_OPERATE_TYPE_OPERATE_TYPE_MIN = Mydis_RedisOperate_OPERATE_TYPE_T_READ
 
const
Mydis_RedisOperate_OPERATE_TYPE 
Mydis_RedisOperate_OPERATE_TYPE_OPERATE_TYPE_MAX = Mydis_RedisOperate_OPERATE_TYPE_T_WRITE
 
const int Mydis_RedisOperate_OPERATE_TYPE_OPERATE_TYPE_ARRAYSIZE = Mydis_RedisOperate_OPERATE_TYPE_OPERATE_TYPE_MAX + 1
 
const
Mydis_DbOperate_Condition_E_RELATION 
Mydis_DbOperate_Condition_E_RELATION_E_RELATION_MIN = Mydis_DbOperate_Condition_E_RELATION_EQ
 
const
Mydis_DbOperate_Condition_E_RELATION 
Mydis_DbOperate_Condition_E_RELATION_E_RELATION_MAX = Mydis_DbOperate_Condition_E_RELATION_IN
 
const int Mydis_DbOperate_Condition_E_RELATION_E_RELATION_ARRAYSIZE = Mydis_DbOperate_Condition_E_RELATION_E_RELATION_MAX + 1
 
const
Mydis_DbOperate_ConditionGroup_E_RELATION 
Mydis_DbOperate_ConditionGroup_E_RELATION_E_RELATION_MIN = Mydis_DbOperate_ConditionGroup_E_RELATION_AND
 
const
Mydis_DbOperate_ConditionGroup_E_RELATION 
Mydis_DbOperate_ConditionGroup_E_RELATION_E_RELATION_MAX = Mydis_DbOperate_ConditionGroup_E_RELATION_OR
 
const int Mydis_DbOperate_ConditionGroup_E_RELATION_E_RELATION_ARRAYSIZE = Mydis_DbOperate_ConditionGroup_E_RELATION_E_RELATION_MAX + 1
 
const
Mydis_DbOperate_OrderBy_E_RELATION 
Mydis_DbOperate_OrderBy_E_RELATION_E_RELATION_MIN = Mydis_DbOperate_OrderBy_E_RELATION_ASC
 
const
Mydis_DbOperate_OrderBy_E_RELATION 
Mydis_DbOperate_OrderBy_E_RELATION_E_RELATION_MAX = Mydis_DbOperate_OrderBy_E_RELATION_DESC
 
const int Mydis_DbOperate_OrderBy_E_RELATION_E_RELATION_ARRAYSIZE = Mydis_DbOperate_OrderBy_E_RELATION_E_RELATION_MAX + 1
 
const Mydis_DbOperate_E_QUERY_TYPE Mydis_DbOperate_E_QUERY_TYPE_E_QUERY_TYPE_MIN = Mydis_DbOperate_E_QUERY_TYPE_SELECT
 
const Mydis_DbOperate_E_QUERY_TYPE Mydis_DbOperate_E_QUERY_TYPE_E_QUERY_TYPE_MAX = Mydis_DbOperate_E_QUERY_TYPE_DELETE
 
const int Mydis_DbOperate_E_QUERY_TYPE_E_QUERY_TYPE_ARRAYSIZE = Mydis_DbOperate_E_QUERY_TYPE_E_QUERY_TYPE_MAX + 1
 
const Result_E_RESULT_FROM Result_E_RESULT_FROM_E_RESULT_FROM_MIN = Result_E_RESULT_FROM_FROM_DB
 
const Result_E_RESULT_FROM Result_E_RESULT_FROM_E_RESULT_FROM_MAX = Result_E_RESULT_FROM_FROM_REDIS
 
const int Result_E_RESULT_FROM_E_RESULT_FROM_ARRAYSIZE = Result_E_RESULT_FROM_E_RESULT_FROM_MAX + 1
 
const E_COL_TYPE E_COL_TYPE_MIN = STRING
 
const E_COL_TYPE E_COL_TYPE_MAX = DOUBLE
 
const int E_COL_TYPE_ARRAYSIZE = E_COL_TYPE_MAX + 1
 
struct
neb::StaticDescriptorInitializer_neb_5fsys_2eproto 
static_descriptor_initializer_neb_5fsys_2eproto_
 

类型定义说明

typedef unsigned int neb::uint32_t

枚举类型说明

通信通道状态

枚举值
CHANNEL_STATUS_INIT 

初始化完毕,尚未连接 socket()返回

CHANNEL_STATUS_TRY_CONNECT 

发起连接

CHANNEL_STATUS_CONNECTED 

连接成功

CHANNEL_STATUS_TRANSFER_TO_WORKER 

连接从Manager传送给Worker过程中

CHANNEL_STATUS_WORKER 

连接成功从Manager传送给Worker

CHANNEL_STATUS_TELL_WORKER 

将本Worker信息告知对端Worker

CHANNEL_STATUS_ESTABLISHED 

与对端Worker的连接就绪(可以正常收发消息)

CHANNEL_STATUS_CLOSED 

被丢弃待回收

enum neb::E_CMD

保留命令字

注解
小于等于500的命令字为保留命令字,业务层禁止使用500及以下的命令字,建议业务层命令字从1001开始编号 并且遵从奇数表示请求命令字,偶数表示应答命令字,应答命令字 = 请求命令字 + 1
枚举值
CMD_UNDEFINE 

未定义

CMD_REQ_CONNECT_TO_WORKER 

连接到Worker进程请求(Manager进程在收到这个包之后才会将文件描述符转发给对应Worker进程)

CMD_RSP_CONNECT_TO_WORKER 

连接到Worker进程应答(无须响应)

CMD_REQ_TELL_WORKER 

将己方Worker信息告知对方,并请求对方作对等的回应

CMD_RSP_TELL_WORKER 

收到对方Worker告知的信息,并将己方的对等信息回应之

CMD_REQ_DISCONNECT 

连接断开(由框架层触发通知并以Cmd的形式通知到系统Cmd,断开原因有error、timeout之类)

CMD_RSP_DISCONNECT 

连接断开应答(无效CMD)

CMD_REQ_REFRESH_SERVER 

刷新Server配置请求(由Manager进程根据配置文件变化情况刷新Server配置,如修改日志级别,重新加载动态库等)

CMD_RSP_REFRESH_SERVER 

刷新Server配置应答

CMD_REQ_SET_LOG_LEVEL 

设置日志级别请求(manager to worker)

CMD_RSP_SET_LOG_LEVEL 

设置日志级别响应(无须响应)

CMD_REQ_RELOAD_SO 

重新加载so请求(manager to worker)

CMD_RSP_RELOAD_SO 

重新加载so响应(无须响应)

CMD_REQ_UPDATE_WORKER_LOAD 

更新Worker进程负载信息请求

CMD_RSP_UPDATE_WORKER_LOAD 

更新Worker进程负载信息应答(一般无须应答)

CMD_REQ_NODE_STATUS_REPORT 

节点Server状态上报请求(各节点向控制中心上报自身状态信息)

CMD_RSP_NODE_STATUS_REPORT 

节点Server状态上报应答

CMD_REQ_NODE_REGISTER 

节点注册,各个节点启动时主动注册到Center模块

CMD_RSP_NODE_REGISTER 

节点注册应答

CMD_REQ_NODE_NOTICE 

节点通知,各个节点启动时主动注册到Center模块,发的通知

CMD_RSP_NODE_NOTICE 

节点通知应答通知(Manager应答,Worker无须应答)

CMD_REQ_REFRESH_NODE_ID 

更新节点ID请求(Manager发往Worker)

CMD_RSP_REFRESH_NODE_ID 

更新节点ID应答(一般无须应答)

CMD_REQ_SERVER_DATA_STATUS_REPORT 

服务器数据状态上报请求

CMD_RSP_SERVER_DATA_STATUS_REPORT 

服务器数据状态上报应答

CMD_REQ_GET_LOAD_MIN_SERVER 

获取低负载服务器请求

CMD_RSP_GET_LOAD_MIN_SERVER 

获取低负载服务器应答

CMD_REQ_LEADER_ELECTION 

分布式leader选举请求

CMD_RSP_LEADER_ELECTION 

分布式leader选举响应(通过心跳结合优先权选举,无须响应)

CMD_REQ_SET_NODE_CONFIG 

更新框架配置文件请求

CMD_RSP_SET_NODE_CONFIG 

更新框架配置文件应答

CMD_REQ_GET_NODE_CONFIG 

获取框架配置文件请求

CMD_RSP_GET_NODE_CONFIG 

获取框架配置文件应答

CMD_REQ_SET_NODE_CUSTOM_CONFIG 

更新框架配置文件中自定义部分配置请求

CMD_RSP_SET_NODE_CUSTOM_CONFIG 

更新框架配置文件中自定义部分配置应答

CMD_REQ_GET_NODE_CUSTOM_CONFIG 

获取框架配置文件中自定义部分配置请求

CMD_RSP_GET_NODE_CUSTOM_CONFIG 

获取框架配置文件中自定义部分配置应答

CMD_REQ_SET_CUSTOM_CONFIG 

更新自定义配置文件请求

CMD_RSP_SET_CUSTOM_CONFIG 

更新自定义配置文件响应

CMD_REQ_GET_CUSTOM_CONFIG 

获取自定义配置文件请求

CMD_RSP_GET_CUSTOM_CONFIG 

获取自定义配置文件响应

CMD_REQ_RELOAD_CUSTOM_CONFIG 

重新加载自定义配置文件请求

CMD_RSP_RELOAD_CUSTOM_CONFIG 

重新加载自定义配置文件响应

CMD_REQ_LOG4_TRACE 

分布式网络日志请求

CMD_RSP_LOG4_TRACE 

分布式网络日志响应(无须响应)

CMD_REQ_FROM_CLIENT 

客户端发送过来需由接入层转发的数据,传输的MsgHead里的Cmd不会被改变(无业务逻辑直接转发的场景,如登录等接入层有业务逻辑的场景不适用)

CMD_RSP_FROM_CLIENT 

无意义,不会被使用

CMD_REQ_TO_CLIENT 

往客户端发送的数据,传输的MsgHead里的Cmd不会被改变(直接转发,不需要做任何处理)

CMD_RSP_TO_CLIENT 

无意义,不会被使用

CMD_REQ_STORATE 

存储请求

CMD_RSP_STORATE 

存储响应

CMD_REQ_BEAT 

心跳请求

CMD_RSP_BEAT 

心跳响应

CMD_REQ_LOCATE_STORAGE 

定位数据存储位置请求

CMD_RSP_LOCATE_STORAGE 

定位数据存储位置响应

CMD_REQ_SYS_ERROR 

系统错误请求(无意义,不会被使用)

CMD_RSP_SYS_ERROR 

系统错误响应

命令执行状态

枚举值
CMD_STATUS_START 

创建命令执行者,但未开始执行

CMD_STATUS_RUNNING 

正在执行命令

CMD_STATUS_COMPLETED 

命令执行完毕

CMD_STATUS_OK 

单步OK,但命令最终状态仍需调用者判断

CMD_STATUS_FAULT 

命令执行出错并且不必重试

编解码状态

注解
编解码状态用于判断编解码是否成功,其中解码发生CODEC_STATUS_ERR情况时 调用方需关闭对应连接;解码发生CODEC_STATUS_PAUSE时,解码函数应将缓冲区读位 置重置回读开始前的位置。
枚举值
CODEC_STATUS_OK 

编解码成功

CODEC_STATUS_PAUSE 

编解码暂停(数据不完整,等待数据完整之后再解码)

CODEC_STATUS_WANT_READ 

等待对端握手信息(此时,应该不再监听FD的可写事件,直到对端握手信息到达。此状态用于SSL连接握手)

CODEC_STATUS_WANT_WRITE 

等待己端握手信息(此时,应发起握手信息,并添加FD的可写事件监听。此状态用于SSL连接握手)或握手成功等待数据发送

CODEC_STATUS_INVALID 

使用了错误的编解码方式(此时为调用错误,应修改调用方式)

CODEC_STATUS_ERR 

编解码失败

CODEC_STATUS_EOF 

连接正常关闭

CODEC_STATUS_INT 

连接非正常关闭

枚举值
CODEC_UNKNOW 

未知

CODEC_PROTO 

Protobuf编解码

CODEC_NEBULA 

Nebula Protobuf 与CODEC_PROTO完全相同,只为程序判断内部服务器之间连接而用

CODEC_HTTP 

HTTP编解码

CODEC_HTTP_CUSTOM 

带自定义HTTP头的http编解码

CODEC_PRIVATE 

私有协议编解码

CODEC_WS_EXTEND_JSON 

带Extension data的websocket协议扩展,Application data为json

CODEC_WS_EXTEND_PB 

带Extension data的websocket协议扩展,Application data为pb

枚举值
STRING 
INT 
BIGINT 
FLOAT 
DOUBLE 
E_COL_TYPE_INT_MIN_SENTINEL_DO_NOT_USE_ 
E_COL_TYPE_INT_MAX_SENTINEL_DO_NOT_USE_ 

系统错误码定义

枚举值
ERR_OK 

正确

ERR_CHANNEL_EOF 

连接关闭

ERR_TRANSFER_FD 

传输文件描述符出错(errno为0时返回)

ERR_PARASE_PROTOBUF 

解析Protobuf出错

ERR_NO_SUCH_WORKER_INDEX 

未知的Worker进程编号

ERR_UNKNOWN_CMD 

未知命令字

ERR_NEW 

new出错(无法分配堆内存)

ERR_REDIS_CONN_CLOSE 

redis连接已关闭

ERR_DISCONNECT 

已存在的连接发生错误

ERR_NO_CALLBACK 

回调不存在或已超时

ERR_DATA_TRANSFER 

数据传输出错

ERR_REPEAT_REGISTERED 

重复注册

ERR_SERVERINFO 

服务器信息错误

ERR_SESSION 

获取会话错误

ERR_BODY_JSON 

消息体json解析错误

ERR_SERVERINFO_RECORD 

存档服务器信息错误

ERR_NODE_NUM 

系统节点数超过最大限制65535

ERR_SSL_INIT 

初始化SSL错误

ERR_SSL_CTX 

创建SSL上下文错误

ERR_SSL_CERTIFICATE 

加载SSL证书错误

ERR_SSL_NEW_CONNECTION 

新建SSL连接错误

ERR_SSL_HANDSHAKE 

建立SSL连接错误

ERR_SSL_SHUTDOWN 

关闭SSL连接错误

ERR_FILE_NOT_EXIST 

文件不存在

ERR_CONNECTION 

连接错误

ERR_INCOMPLET_DATAPROXY_DATA 

DataProxy请求数据包不完整

ERR_INVALID_REDIS_ROUTE 

无效的redis路由信息

ERR_REDIS_NODE_NOT_FOUND 

未找到合适的redis节点

ERR_REGISTERCALLBACK_REDIS 

注册RedisStep错误

ERR_REDIS_CMD 

redis命令执行出错

ERR_UNEXPECTED_REDIS_REPLY 

不符合预期的redis结果

ERR_RESULTSET_EXCEED 

数据包超过protobuf最大限制

ERR_LACK_CLUSTER_INFO 

缺少集群信息

ERR_TIMEOUT 

超时

ERR_REDIS_AND_DB_CMD_NOT_MATCH 

redis读写操作与DB读写操作不匹配

ERR_REDIS_NIL_AND_DB_FAILED 

redis结果集为空,但发送DB操作失败

ERR_NO_RIGHT 

数据操作权限不足

ERR_QUERY 

查询出错,如拼写SQL错误

ERR_REDIS_STRUCTURE_WITH_DATASET 

redis数据结构由DB的各字段值序列化(或串联)而成,请求与存储不符

ERR_REDIS_STRUCTURE_WITHOUT_DATASET 

redis数据结构并非由DB的各字段值序列化(或串联)而成,请求与存储不符

ERR_DB_FIELD_NUM 

redis数据结构由DB的各字段值序列化(或串联)而成,请求的字段数量错误

ERR_DB_FIELD_ORDER_OR_FIELD_NAME 

redis数据结构由DB的各字段值序列化(或串联)而成,请求字段顺序或字段名错误

ERR_KEY_FIELD 

redis数据结构由DB的各字段值序列化(或串联)而成,指定的key_field错误或未指定,或未在对应表的数据字典中找到该字段

ERR_KEY_FIELD_VALUE 

redis数据结构指定的key_field所对应的值缺失或值为空

ERR_JOIN_FIELDS 

redis数据结构由DB字段串联而成,串联的字段错误

ERR_LACK_JOIN_FIELDS 

redis数据结构由DB字段串联而成,缺失串联字段

ERR_REDIS_STRUCTURE_NOT_DEFINE 

redis数据结构未在DataProxy的配置中定义

ERR_INVALID_CMD_FOR_HASH_DATASET 

redis hash数据结构由DB的各字段值序列化(或串联)而成,而请求中的hash命令不当

ERR_DB_TABLE_NOT_DEFINE 

表未在DataProxy的配置中定义

ERR_DB_OPERATE_MISSING 

redis数据结构存在对应的DB表,但数据请求缺失对数据库表操作

ERR_REQ_MISS_PARAM 

请求参数缺失

ERR_LACK_TABLE_FIELD 

数据库表字段缺失

ERR_TABLE_FIELD_NAME_EMPTY 

数据库表字段名为空

ERR_UNDEFINE_REDIS_OPERATE 

未定义或不支持的redis数据操作(只支持string和hash的dataset update操作)

ERR_REDIS_READ_WRITE_CMD_NOT_MATCH 

redis读命令与写命令不对称

枚举值
HASH_fnv1a_64 
HASH_fnv1_64 
HASH_murmur3_32 
枚举值
FIELD_OPERATOR_DB 

对数据库有效

FIELD_OPERATOR_REDIS 

对Redis有效

枚举值
STREAM_CODEC_UNKNOW 

未知

STREAM_CODEC_TLV 

TLV编解码

STREAM_CODEC_PROTOBUF 

Protobuf编解码

STREAM_CODEC_HTTP 

HTTP编解码

STREAM_CODEC_HTTP_CUSTOM 

带自定义HTTP头的http编解码

枚举值
Mydis_DbOperate_Condition_E_RELATION_EQ 
Mydis_DbOperate_Condition_E_RELATION_NE 
Mydis_DbOperate_Condition_E_RELATION_GT 
Mydis_DbOperate_Condition_E_RELATION_LT 
Mydis_DbOperate_Condition_E_RELATION_GE 
Mydis_DbOperate_Condition_E_RELATION_LE 
Mydis_DbOperate_Condition_E_RELATION_LIKE 
Mydis_DbOperate_Condition_E_RELATION_IN 
Mydis_DbOperate_Condition_E_RELATION_Mydis_DbOperate_Condition_E_RELATION_INT_MIN_SENTINEL_DO_NOT_USE_ 
Mydis_DbOperate_Condition_E_RELATION_Mydis_DbOperate_Condition_E_RELATION_INT_MAX_SENTINEL_DO_NOT_USE_ 
枚举值
Mydis_DbOperate_ConditionGroup_E_RELATION_AND 
Mydis_DbOperate_ConditionGroup_E_RELATION_OR 
Mydis_DbOperate_ConditionGroup_E_RELATION_Mydis_DbOperate_ConditionGroup_E_RELATION_INT_MIN_SENTINEL_DO_NOT_USE_ 
Mydis_DbOperate_ConditionGroup_E_RELATION_Mydis_DbOperate_ConditionGroup_E_RELATION_INT_MAX_SENTINEL_DO_NOT_USE_ 
枚举值
Mydis_DbOperate_E_QUERY_TYPE_SELECT 
Mydis_DbOperate_E_QUERY_TYPE_INSERT 
Mydis_DbOperate_E_QUERY_TYPE_INSERT_IGNORE 
Mydis_DbOperate_E_QUERY_TYPE_UPDATE 
Mydis_DbOperate_E_QUERY_TYPE_REPLACE 
Mydis_DbOperate_E_QUERY_TYPE_DELETE 
Mydis_DbOperate_E_QUERY_TYPE_Mydis_DbOperate_E_QUERY_TYPE_INT_MIN_SENTINEL_DO_NOT_USE_ 
Mydis_DbOperate_E_QUERY_TYPE_Mydis_DbOperate_E_QUERY_TYPE_INT_MAX_SENTINEL_DO_NOT_USE_ 
枚举值
Mydis_DbOperate_OrderBy_E_RELATION_ASC 
Mydis_DbOperate_OrderBy_E_RELATION_DESC 
Mydis_DbOperate_OrderBy_E_RELATION_Mydis_DbOperate_OrderBy_E_RELATION_INT_MIN_SENTINEL_DO_NOT_USE_ 
Mydis_DbOperate_OrderBy_E_RELATION_Mydis_DbOperate_OrderBy_E_RELATION_INT_MAX_SENTINEL_DO_NOT_USE_ 
枚举值
Mydis_RedisOperate_OPERATE_TYPE_T_READ 
Mydis_RedisOperate_OPERATE_TYPE_T_WRITE 
Mydis_RedisOperate_OPERATE_TYPE_Mydis_RedisOperate_OPERATE_TYPE_INT_MIN_SENTINEL_DO_NOT_USE_ 
Mydis_RedisOperate_OPERATE_TYPE_Mydis_RedisOperate_OPERATE_TYPE_INT_MAX_SENTINEL_DO_NOT_USE_ 
枚举值
Result_E_RESULT_FROM_FROM_DB 
Result_E_RESULT_FROM_FROM_REDIS 
Result_E_RESULT_FROM_Result_E_RESULT_FROM_INT_MIN_SENTINEL_DO_NOT_USE_ 
Result_E_RESULT_FROM_Result_E_RESULT_FROM_INT_MAX_SENTINEL_DO_NOT_USE_ 

函数说明

std::string neb::CharToHex ( char  c)

+ 这是这个函数的调用关系图:

void neb::DecodeParameter ( const std::string &  strParameter,
std::map< std::string, std::string > &  mapParameters 
)
std::string neb::DecodeStringToHex ( const std::string &  sSrc)

+ 函数调用图:

const ::google::protobuf::EnumDescriptor * neb::E_COL_TYPE_descriptor ( )

+ 这是这个函数的调用关系图:

bool neb::E_COL_TYPE_IsValid ( int  value)
const ::std::string& neb::E_COL_TYPE_Name ( E_COL_TYPE  value)
inline

+ 函数调用图:

bool neb::E_COL_TYPE_Parse ( const ::std::string &  name,
E_COL_TYPE *  value 
)
inline

+ 函数调用图:

std::string neb::EncodeHexToString ( const std::string &  sSrc)

+ 函数调用图:

void neb::EncodeParameter ( const std::map< std::string, std::string > &  mapParameters,
std::string &  strParameter 
)

+ 这是这个函数的调用关系图:

unsigned char neb::FromHex ( unsigned char  x)

+ 这是这个函数的调用关系图:

char neb::HexToChar ( const std::string &  sHex)

+ 这是这个函数的调用关系图:

unsigned long long neb::htonll ( unsigned long long  val)

+ 这是这个函数的调用关系图:

const ::google::protobuf::EnumDescriptor * neb::Mydis_DbOperate_Condition_E_RELATION_descriptor ( )

+ 这是这个函数的调用关系图:

bool neb::Mydis_DbOperate_Condition_E_RELATION_IsValid ( int  value)

+ 这是这个函数的调用关系图:

const ::std::string& neb::Mydis_DbOperate_Condition_E_RELATION_Name ( Mydis_DbOperate_Condition_E_RELATION  value)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

bool neb::Mydis_DbOperate_Condition_E_RELATION_Parse ( const ::std::string &  name,
Mydis_DbOperate_Condition_E_RELATION *  value 
)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

const ::google::protobuf::EnumDescriptor * neb::Mydis_DbOperate_ConditionGroup_E_RELATION_descriptor ( )

+ 这是这个函数的调用关系图:

bool neb::Mydis_DbOperate_ConditionGroup_E_RELATION_IsValid ( int  value)

+ 这是这个函数的调用关系图:

const ::std::string& neb::Mydis_DbOperate_ConditionGroup_E_RELATION_Name ( Mydis_DbOperate_ConditionGroup_E_RELATION  value)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

bool neb::Mydis_DbOperate_ConditionGroup_E_RELATION_Parse ( const ::std::string &  name,
Mydis_DbOperate_ConditionGroup_E_RELATION *  value 
)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

const ::google::protobuf::EnumDescriptor * neb::Mydis_DbOperate_E_QUERY_TYPE_descriptor ( )

+ 这是这个函数的调用关系图:

bool neb::Mydis_DbOperate_E_QUERY_TYPE_IsValid ( int  value)

+ 这是这个函数的调用关系图:

const ::std::string& neb::Mydis_DbOperate_E_QUERY_TYPE_Name ( Mydis_DbOperate_E_QUERY_TYPE  value)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

bool neb::Mydis_DbOperate_E_QUERY_TYPE_Parse ( const ::std::string &  name,
Mydis_DbOperate_E_QUERY_TYPE *  value 
)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

const ::google::protobuf::EnumDescriptor * neb::Mydis_DbOperate_OrderBy_E_RELATION_descriptor ( )

+ 这是这个函数的调用关系图:

bool neb::Mydis_DbOperate_OrderBy_E_RELATION_IsValid ( int  value)

+ 这是这个函数的调用关系图:

const ::std::string& neb::Mydis_DbOperate_OrderBy_E_RELATION_Name ( Mydis_DbOperate_OrderBy_E_RELATION  value)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

bool neb::Mydis_DbOperate_OrderBy_E_RELATION_Parse ( const ::std::string &  name,
Mydis_DbOperate_OrderBy_E_RELATION *  value 
)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

const ::google::protobuf::EnumDescriptor * neb::Mydis_RedisOperate_OPERATE_TYPE_descriptor ( )

+ 这是这个函数的调用关系图:

bool neb::Mydis_RedisOperate_OPERATE_TYPE_IsValid ( int  value)

+ 这是这个函数的调用关系图:

const ::std::string& neb::Mydis_RedisOperate_OPERATE_TYPE_Name ( Mydis_RedisOperate_OPERATE_TYPE  value)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

bool neb::Mydis_RedisOperate_OPERATE_TYPE_Parse ( const ::std::string &  name,
Mydis_RedisOperate_OPERATE_TYPE *  value 
)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

unsigned long long neb::ntohll ( unsigned long long  val)
void neb::protobuf_AddDesc_mydis_2eproto ( )

+ 函数调用图:

+ 这是这个函数的调用关系图:

void neb::protobuf_AddDesc_neb_5fsys_2eproto ( )

+ 函数调用图:

+ 这是这个函数的调用关系图:

void neb::protobuf_AssignDesc_mydis_2eproto ( )

+ 函数调用图:

void neb::protobuf_AssignDesc_neb_5fsys_2eproto ( )

+ 函数调用图:

void neb::protobuf_ShutdownFile_mydis_2eproto ( )

+ 这是这个函数的调用关系图:

void neb::protobuf_ShutdownFile_neb_5fsys_2eproto ( )

+ 这是这个函数的调用关系图:

const ::google::protobuf::EnumDescriptor * neb::Result_E_RESULT_FROM_descriptor ( )

+ 这是这个函数的调用关系图:

bool neb::Result_E_RESULT_FROM_IsValid ( int  value)

+ 这是这个函数的调用关系图:

const ::std::string& neb::Result_E_RESULT_FROM_Name ( Result_E_RESULT_FROM  value)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

bool neb::Result_E_RESULT_FROM_Parse ( const ::std::string &  name,
Result_E_RESULT_FROM *  value 
)
inline

+ 函数调用图:

+ 这是这个函数的调用关系图:

unsigned char neb::ToHex ( unsigned char  x)

+ 这是这个函数的调用关系图:

std::string neb::UrlDecode ( const std::string &  str)

+ 函数调用图:

std::string neb::UrlEncode ( const std::string &  str)

+ 函数调用图:

变量说明

const int neb::E_COL_TYPE_ARRAYSIZE = E_COL_TYPE_MAX + 1
const E_COL_TYPE neb::E_COL_TYPE_MAX = DOUBLE
const E_COL_TYPE neb::E_COL_TYPE_MIN = STRING
const unsigned long neb::FNV_64_INIT = 0x100000001b3
const unsigned long neb::FNV_64_PRIME = 0xcbf29ce484222325
const ev_tstamp neb::gc_dDefaultTimeout = 0
const ev_tstamp neb::gc_dNoTimeout = -1
const int neb::gc_iAddrLen = 64

IP地址长度

const int neb::gc_iBeatInterval = NODE_BEAT

心跳间隔时间(单位:秒)

const int neb::gc_iErrBuffLen = 256

错误信息缓冲区大小

const int neb::gc_iMaxBuffLen = 65535

最大缓冲区大小

const int neb::gc_iMaxEpollEvents = 100

每次epoll_wait能处理的最大事件数

const unsigned int neb::gc_uiAesBit = 0x02000000

采用128位aes加密

const uint32 neb::gc_uiClientMsgHeadSize = 14
const unsigned int neb::gc_uiCmdBit = 0x0000FFFF

命令为无符号短整型

const unsigned int neb::gc_uiCmdReq = 0x00000001

请求(奇数为请求,偶数为应答,通过 gc_iCmdReq & iCmd 来判断,比运算快)

const unsigned int neb::gc_uiGzipBit = 0x10000000

采用zip压缩

const unsigned int neb::gc_uiMaxLogFileSize = 2048000
const unsigned int neb::gc_uiMaxLogLineLen = 1024
const unsigned int neb::gc_uiMaxRollLogFileIndex = 9
const uint32 neb::gc_uiMsgHeadSize = 15
const unsigned int neb::gc_uiRc5Bit = 0x01000000

采用12轮Rc5加密

const unsigned int neb::gc_uiZipBit = 0x20000000

采用gzip压缩

const std::string neb::LogLevMsg[Logger::LEV_MAX]
初始值:
=
{
"FATAL",
"CRITICAL",
"ERROR",
"NOTICE",
"WARNING",
"INFO",
"DEBUG",
"TRACE"
}
const int neb::Mydis_DbOperate_Condition_E_RELATION_E_RELATION_ARRAYSIZE = Mydis_DbOperate_Condition_E_RELATION_E_RELATION_MAX + 1
const Mydis_DbOperate_Condition_E_RELATION neb::Mydis_DbOperate_Condition_E_RELATION_E_RELATION_MAX = Mydis_DbOperate_Condition_E_RELATION_IN
const Mydis_DbOperate_Condition_E_RELATION neb::Mydis_DbOperate_Condition_E_RELATION_E_RELATION_MIN = Mydis_DbOperate_Condition_E_RELATION_EQ
const int neb::Mydis_DbOperate_ConditionGroup_E_RELATION_E_RELATION_ARRAYSIZE = Mydis_DbOperate_ConditionGroup_E_RELATION_E_RELATION_MAX + 1
const Mydis_DbOperate_ConditionGroup_E_RELATION neb::Mydis_DbOperate_ConditionGroup_E_RELATION_E_RELATION_MAX = Mydis_DbOperate_ConditionGroup_E_RELATION_OR
const Mydis_DbOperate_ConditionGroup_E_RELATION neb::Mydis_DbOperate_ConditionGroup_E_RELATION_E_RELATION_MIN = Mydis_DbOperate_ConditionGroup_E_RELATION_AND
const int neb::Mydis_DbOperate_E_QUERY_TYPE_E_QUERY_TYPE_ARRAYSIZE = Mydis_DbOperate_E_QUERY_TYPE_E_QUERY_TYPE_MAX + 1
const Mydis_DbOperate_E_QUERY_TYPE neb::Mydis_DbOperate_E_QUERY_TYPE_E_QUERY_TYPE_MAX = Mydis_DbOperate_E_QUERY_TYPE_DELETE
const Mydis_DbOperate_E_QUERY_TYPE neb::Mydis_DbOperate_E_QUERY_TYPE_E_QUERY_TYPE_MIN = Mydis_DbOperate_E_QUERY_TYPE_SELECT
const int neb::Mydis_DbOperate_OrderBy_E_RELATION_E_RELATION_ARRAYSIZE = Mydis_DbOperate_OrderBy_E_RELATION_E_RELATION_MAX + 1
const Mydis_DbOperate_OrderBy_E_RELATION neb::Mydis_DbOperate_OrderBy_E_RELATION_E_RELATION_MAX = Mydis_DbOperate_OrderBy_E_RELATION_DESC
const Mydis_DbOperate_OrderBy_E_RELATION neb::Mydis_DbOperate_OrderBy_E_RELATION_E_RELATION_MIN = Mydis_DbOperate_OrderBy_E_RELATION_ASC
const int neb::Mydis_RedisOperate_OPERATE_TYPE_OPERATE_TYPE_ARRAYSIZE = Mydis_RedisOperate_OPERATE_TYPE_OPERATE_TYPE_MAX + 1
const Mydis_RedisOperate_OPERATE_TYPE neb::Mydis_RedisOperate_OPERATE_TYPE_OPERATE_TYPE_MAX = Mydis_RedisOperate_OPERATE_TYPE_T_WRITE
const Mydis_RedisOperate_OPERATE_TYPE neb::Mydis_RedisOperate_OPERATE_TYPE_OPERATE_TYPE_MIN = Mydis_RedisOperate_OPERATE_TYPE_T_READ
const int neb::Result_E_RESULT_FROM_E_RESULT_FROM_ARRAYSIZE = Result_E_RESULT_FROM_E_RESULT_FROM_MAX + 1
const Result_E_RESULT_FROM neb::Result_E_RESULT_FROM_E_RESULT_FROM_MAX = Result_E_RESULT_FROM_FROM_REDIS
const Result_E_RESULT_FROM neb::Result_E_RESULT_FROM_E_RESULT_FROM_MIN = Result_E_RESULT_FROM_FROM_DB
struct neb::StaticDescriptorInitializer_mydis_2eproto neb::static_descriptor_initializer_mydis_2eproto_
struct neb::StaticDescriptorInitializer_neb_5fsys_2eproto neb::static_descriptor_initializer_neb_5fsys_2eproto_
const uint8 neb::WEBSOCKET_FIN = 0x80
const uint8 neb::WEBSOCKET_FRAME_BINARY = 2
const uint8 neb::WEBSOCKET_FRAME_CLOSE = 8
const uint8 neb::WEBSOCKET_FRAME_CONTINUE = 0
const uint8 neb::WEBSOCKET_FRAME_PING = 9
const uint8 neb::WEBSOCKET_FRAME_PONG = 10
const uint8 neb::WEBSOCKET_FRAME_TEXT = 1
const uint8 neb::WEBSOCKET_MASK = 0x80
const uint8 neb::WEBSOCKET_OPCODE = 0x0F
const uint8 neb::WEBSOCKET_PAYLOAD_LEN = 0x7F
const uint8 neb::WEBSOCKET_PAYLOAD_LEN_UINT16 = 126
const uint8 neb::WEBSOCKET_PAYLOAD_LEN_UINT64 = 127
const uint8 neb::WEBSOCKET_RSV1 = 0x40
const uint8 neb::WEBSOCKET_RSV2 = 0x20
const uint8 neb::WEBSOCKET_RSV3 = 0x10