hce-node application  1.4.3
HCE Hierarchical Cluster Engine node application
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
Namespaces | Classes | Typedefs | Enumerations | Functions | Variables
HCE Namespace Reference

< HCE::ServerApplication provides global variable 'HCE::database::Session' which initializes in function 'HCE::ServerApplication::initializeDataBaseSession()' More...

Namespaces

namespace  algorithms
namespace  component
namespace  database
namespace  drce
namespace  exception
namespace  handlers
namespace  jsonMessageCoverConst
namespace  logger
namespace  reduce
namespace  reduce_convertors
namespace  reduce_types
namespace  sphinx
namespace  starter_const
namespace  tests
namespace  types
namespace  utils
namespace  Utils

Classes

class  AlreadyInitializedException
class  ChannelNotExistException
class  NotSetDatabaseParametersException
class  NotSetDatabaseTypeException
class  ThreadAlreadyJoinedException
class  ThreadAlreadyRunningException
class  Logger
class  ServerApplication
class  Command
class  CommandExecutor
class  CommandResultData
class  Process
class  ProcessHandle
class  ProcExec
class  StarterExecutor
class  ComponentsManagerFactory
class  DataBase
class  TaskWaitObject
class  TaskWaitObjectWrapper
class  AerospikeDB
class  BaseDB
 Your Driver's class must be inherited from that base class class BaseDB. More...
class  DataBaseDriverConfig
class  FakeDB
 class FakeDB More...
class  HCETimer
class  LevelDB
class  ORMFunctionalObject
class  Request
struct  DataSet
struct  Documents
struct  Response
class  VoldemortDB
 class VoldemortDB More...
class  CustomMessage
class  LoggerStream
class  MessagesCollection
class  BitsetBase
class  CWords
class  InDataRefine
class  MorphChangeGradBitset
class  OutDataRefine
class  POSMaskBitset
class  RWords
class  JsonMessageCover
class  IJsonSerializable
class  TrimFormatter

Typedefs

typedef int STATUS
typedef std::function
< std::string(const
std::string &)> 		Loggable
typedef unsigned short POSMask

Enumerations

enum  ExitStatus { SUCCESS = 0, ERROR_FDOPEN_WRITE = 1, ERROR_FDOPEN_READ = 2, ERROR_WAITPID = 3 }
enum  AdaptorType {
  ADT_NCP06_EFUP_A, ADT_NCP06_EF_A, ADT_EF_PBL_A, ADT_PBL_RB_A,
  ADT_NCP06_RB_A, ADT_TC_C, ADT_DM_T_C, ADT_DPMT_DMT_A,
  ADT_DPMR_C, ADT_DPMR_DMR_A, ADT_DMT_DMCB_A, ADT_DMT_ETPBSB_A,
  ADT_DMR_DMCB_A, ADT_DMR_ETPBSB_A, ADT_DMC_PDM_A, ADT_PM_RW_A,
  ADT_ETPBT_C, ADT_NDSP09_C
}
enum  ComponentType {
  CT_DEFAULT, CT_NetCP06, CT_EXTFMSG, CT_EXTFMSG_UPD,
  CT_POSTBLOCK, CT_REFINE, CT_RB, CT_T,
  CT_PMT, CT_MT, CT_PMR, CT_MR,
  CT_MCB, CT_MC, CT_ETPBSB, CT_ETPBS,
  CT_PMB, CT_PM, CT_RWB, CT_RW,
  CT_ETPBTB, CT_ETPBT, CT_NetDSP09, CT_CTEST,
  CT_HIGHLIGHT
}
enum  TaskWaitObjectExeptionsType {
  HCECTE_DEFAULT, HCECTE_EXP1, HCECTE_EXP2, HCECTE_COMPONENT_EXP,
  HCECTE_EXP_BASE
}
enum  ServiceType {
  SRV_DEFAULT, SRV_CRAWLER, SRV_CRAWLER_NET_CPOLL, SRV_EXT_FILTER,
  SRV_TSA, SRV_TSB
}
enum  {
  ACTION_SUCCESS = 0, DOCUMENT_PRESENT = ACTION_SUCCESS, DOCUMENT_NOT_PRESENT, ACTION_PARSE_ERROR,
  ACTION_NOT_SUPPORT, ACTION_GENERAL_FAILURE, INVALID_MESSAGE_TYPE, INVALID_MESSAGE_BODY,
  INVALID_ADMIN_COMMAND, PUT_FAIL_KEY_EXISTS
}
enum  CommandId
enum  {
  PUT = 0, GET, DEL, CHECK,
  MANAGE, LIST
}
enum  WORD_TYPE
enum  GRANULARITY_LEVEL
enum  MCG_Consistency {
  MCG_TOPIC_BIT_NUMBER = 15, MCG_START_UPPERCASE = 14, MCG_OTHER_UPPERCASE = 13, MCG_SYNONYM_BIT_SIZE = 5,
  MCG_SYNONYM_LOWEST_BIT_NUMBER = 8, MCG_GRAMMAR_BIT_SIZE = 8, MCG_GRAMMAR_LOWEST_BIT_NUMBER = 0, MCG_OBSCENE_WORD_VALUE = 1 << MCG_TOPIC_BIT_NUMBER
}
enum  POS_enum {
  POS_NOUN = 0, POS_ADJ_FULL = 1, POS_VERB = 2, POS_VBE = 3,
  POS_MOD = 4, POS_NUMERAL = 5, POS_CONJ = 6, POS_INTERJ = 7,
  POS_PREP = 8, POS_PARTICLE = 9, POS_ART = 10, POS_ADV = 11,
  POS_PN = 12, POS_ORDNUM = 13, POS_PRON = 14, POS_POSS = 15
}

Functions

std::string encodeBase64 (const std::string &data)
std::string decodeBase64 (const std::string &data)
std::ostream & operator<< (std::ostream &os, const ProcExec &procExec)
std::string & operator<< (std::string &str, const ProcExec &procExec)
std::ostream & endl (std::ostream &os)
std::ostream & flush (std::ostream &os)
LoggerStream & operator<< (LoggerStream &os, const std::string &rhs)
LoggerStream & operator<< (LoggerStream &os, const char *rhs)
std::istream & operator>> (std::istream &is, JsonMessageCover &jsonHandler)
std::ostream & operator<< (std::ostream &os, const JsonMessageCover &jsonHandler)

Variables

const std::string DRCE_FAKE_RESPONSE = "}]"
Poco::AutoPtr
< Poco::Util::AbstractConfiguration > 		_config = NULL
 < AbstractConfiguration - all public methods are synchronized, so the class is safe for multithreaded use.
std::string componentManagerNames [] = {"CM_COMMON"}
std::string componentNames []
std::vector< ComponentType > componentTypeVec
const std::string COMMON_CHARSET = "utf-8"
const std::string INCOMING_CHARSET = "ucs-2"
class HCE::DataBaseDriverConfig __attribute__
const std::string error_messages []

Detailed Description

< HCE::ServerApplication provides global variable 'HCE::database::Session' which initializes in function 'HCE::ServerApplication::initializeDataBaseSession()'

< poco headers

< std headers

Windows specific headers.

std headers

project node API

Since
0.1

.hpp

HCE project node handler's parent. Implements basic functionality common for any kind of node handler.

Author
bgv bgv.h.nosp@m.ce@g.nosp@m.mail..nosp@m.com Copyright © 2013 IOIX Ukraine http://hierarchical-cluster-engine.com/license/ project node API 0.1 project node 0.1 .hpp HCE project node model application. Implements complete functional model of cluster node application. Supports four basic runtime modes: router, proxy shard, data shard and data node. Uses zmq PPP-based protocol and connection schema, heartbit algorithm, admin management handler and so on. This is an atomic brick for HCE project architecture structure schema construction. bgv bgv.h.nosp@m.ce@g.nosp@m.mail..nosp@m.com http://hierarchical-cluster-engine.com/ Copyright © 2013-2015 HCE project, IOIX Ukraine http://hierarchical-cluster-engine.com/license/ project node API 0.1 < HCE::ServerApplication provides global variable 'HCE::_config' which initializes in function 'HCE::ServerApplication::initializeConfigurationFile ()' we need to use variable 'HCE::_config' after calling function initialize () < HCE::ServerApplication provides global static class 'HCE::Logger' which initializes by calling function 'HCE::Logger::initializeLoggers()' from 'HCE::ServerApplication::initializeLoggers ()' < Poco headers< std headers< app headers < which ONE!!! Storage Engine driver does compile with < app headers< Poco headers< std headers < app headers< std headers< lib headers < app headers< Poco headers < app headers < std headers< Poco headers < app headers< std headers< Poco headers< libheaders Reducing Task 0.1 header file BitsetBase.hpp Base class for classes representing bit set structures source file BoostPlugin.cpp boost headers app headers header file BoostPlugin.hpp app headers header file CldPlugin.hpp headers app headers Source file FakeHCRCPlugin.cpp header file FakeHCRCPlugin.hpp app headers source file IcuPlugin.cpp std headers header file IcuPlugin icu headers app headers app headers Linux specific headers platform independent headers std headers Source file MecabPlugin.cpp header file MecabPlugin.hpp headers header file MorphChangeGradBitset.hpp class representing morphology bit set structures header file POSMaskBitset.hpp class representing Part-Of-Speech bit set structures < std headers < app headers std headers app headers source file SnowballPlugin.cpp header file SnowballPlugin.hpp snowball headers std headers app headers source file TagReducePlugin.cpp header file TagReducePlugin.hpp icu headers std headers app headers source file TurglemPlugin.cpp header file TurglemPlugin.hpp std headers turglem headers app headers

Typedef Documentation

typedef std::function<std::string(const std::string&)> HCE::Loggable

Definition at line 25 of file LoggerStream.hpp.

typedef unsigned short HCE::POSMask

Definition at line 46 of file Defs.hpp.

typedef int HCE::STATUS

Definition at line 41 of file BaseDB.hpp.

Enumeration Type Documentation

anonymous enum
Enumerator:
ACTION_SUCCESS 
DOCUMENT_PRESENT 
DOCUMENT_NOT_PRESENT 
ACTION_PARSE_ERROR 
ACTION_NOT_SUPPORT 
ACTION_GENERAL_FAILURE 
INVALID_MESSAGE_TYPE 
INVALID_MESSAGE_BODY 
INVALID_ADMIN_COMMAND 
PUT_FAIL_KEY_EXISTS 

Definition at line 22 of file Errors.hpp.

anonymous enum
Enumerator:
PUT 

put documents to DB storage

GET 

get documents from DB storage

DEL 

delete documents from DB storage

CHECK 

check documents in DB storage

MANAGE 

admin command

LIST 

Definition at line 53 of file Response.hpp.

enum HCE::AdaptorType
Enumerator:
ADT_NCP06_EFUP_A 
ADT_NCP06_EF_A 
ADT_EF_PBL_A 
ADT_PBL_RB_A 
ADT_NCP06_RB_A 
ADT_TC_C 
ADT_DM_T_C 
ADT_DPMT_DMT_A 
ADT_DPMR_C 
ADT_DPMR_DMR_A 
ADT_DMT_DMCB_A 
ADT_DMT_ETPBSB_A 
ADT_DMR_DMCB_A 
ADT_DMR_ETPBSB_A 
ADT_DMC_PDM_A 
ADT_PM_RW_A 
ADT_ETPBT_C 
ADT_NDSP09_C 

Definition at line 9 of file HCEConstants.hpp.

enum HCE::CommandId

< Supported admin commands enumeration

Definition at line 45 of file Response.hpp.

enum HCE::ComponentType
Enumerator:
CT_DEFAULT 
CT_NetCP06 
CT_EXTFMSG 
CT_EXTFMSG_UPD 
CT_POSTBLOCK 
CT_REFINE 
CT_RB 
CT_T 
CT_PMT 
CT_MT 
CT_PMR 
CT_MR 
CT_MCB 
CT_MC 
CT_ETPBSB 
CT_ETPBS 
CT_PMB 
CT_PM 
CT_RWB 
CT_RW 
CT_ETPBTB 
CT_ETPBT 
CT_NetDSP09 
CT_CTEST 
CT_HIGHLIGHT 

Definition at line 30 of file HCEConstants.hpp.

enum HCE::ExitStatus
Enumerator:
SUCCESS 
ERROR_FDOPEN_WRITE 
ERROR_FDOPEN_READ 
ERROR_WAITPID 

Definition at line 29 of file Process.hpp.

enum HCE::GRANULARITY_LEVEL

Definition at line 64 of file Defs.hpp.

enum HCE::MCG_Consistency
Enumerator:
MCG_TOPIC_BIT_NUMBER 
MCG_START_UPPERCASE 
MCG_OTHER_UPPERCASE 
MCG_SYNONYM_BIT_SIZE 
MCG_SYNONYM_LOWEST_BIT_NUMBER 
MCG_GRAMMAR_BIT_SIZE 
MCG_GRAMMAR_LOWEST_BIT_NUMBER 
MCG_OBSCENE_WORD_VALUE 

Definition at line 19 of file MorphChangeGradBitset.hpp.

enum HCE::POS_enum

Part-Of-Speech constants

Enumerator:
POS_NOUN 
POS_ADJ_FULL 
POS_VERB 
POS_VBE 
POS_MOD 
POS_NUMERAL 
POS_CONJ 
POS_INTERJ 
POS_PREP 
POS_PARTICLE 
POS_ART 
POS_ADV 
POS_PN 
POS_ORDNUM 
POS_PRON 
POS_POSS 

Definition at line 22 of file POSMaskBitset.hpp.

enum HCE::ServiceType
Enumerator:
SRV_DEFAULT 
SRV_CRAWLER 
SRV_CRAWLER_NET_CPOLL 
SRV_EXT_FILTER 
SRV_TSA 
SRV_TSB 

Definition at line 62 of file HCEConstants.hpp.

enum HCE::TaskWaitObjectExeptionsType
Enumerator:
HCECTE_DEFAULT 
HCECTE_EXP1 
HCECTE_EXP2 
HCECTE_COMPONENT_EXP 
HCECTE_EXP_BASE 

Definition at line 57 of file HCEConstants.hpp.

enum HCE::WORD_TYPE

Definition at line 62 of file Defs.hpp.

Function Documentation

std::string HCE::decodeBase64 ( const std::string &  data)

Definition at line 25 of file EncodeDecodeBase64.cpp.

Here is the caller graph for this function:

std::string HCE::encodeBase64 ( const std::string &  data)

Definition at line 11 of file EncodeDecodeBase64.cpp.

Here is the caller graph for this function:

std::ostream & HCE::endl ( std::ostream &  os)

Definition at line 113 of file LoggerStream.cpp.

Here is the call graph for this function:

std::ostream & HCE::flush ( std::ostream &  os)

Definition at line 126 of file LoggerStream.cpp.

Here is the call graph for this function:

std::ostream& HCE::operator<< ( std::ostream &  os,
const ProcExec &  procExec 
)

Definition at line 73 of file ProcExec.cpp.

std::string& HCE::operator<< ( std::string &  str,
const ProcExec &  procExec 
)

Definition at line 79 of file ProcExec.cpp.

std::ostream& HCE::operator<< ( std::ostream &  os,
const JsonMessageCover &  jsonHandler 
)

Definition at line 119 of file JsonMessageCover.cpp.

LoggerStream & HCE::operator<< ( LoggerStream &  os,
const std::string &  rhs 
)

Definition at line 139 of file LoggerStream.cpp.

Here is the call graph for this function:

LoggerStream & HCE::operator<< ( LoggerStream &  os,
const char *  rhs 
)

Definition at line 145 of file LoggerStream.cpp.

Here is the call graph for this function:

std::istream& HCE::operator>> ( std::istream &  is,
HCE::JsonMessageCover &  jsonHandler 
)

Definition at line 108 of file JsonMessageCover.cpp.

Here is the call graph for this function:

Variable Documentation

class HCE::DataBaseDriverConfig HCE::__attribute__
Poco::AutoPtr< Poco::Util::AbstractConfiguration > HCE::_config = NULL

< AbstractConfiguration - all public methods are synchronized, so the class is safe for multithreaded use.

Definition at line 4 of file Logger.cpp.

const std::string HCE::COMMON_CHARSET = "utf-8"

Definition at line 15 of file HCEConstants.cpp.

std::string HCE::componentManagerNames[] = {"CM_COMMON"}

Definition at line 7 of file HCEConstants.cpp.

std::string HCE::componentNames
Initial value:
{"CT_DEFAULT", "CT_NetCP06", "CT_EXTFMSG", "CT_EXTFMSG_UPD", "CT_POSTBLOCK", "CT_REFINE", "CT_RB",
"CT_T", "CT_PMT", "CT_MT", "CT_PMR", "CT_MR", "CT_MCB", "CT_MC", "CT_ETPBSB", "CT_ETPBS", "CT_PMB", "CT_PM","CT_RWB",
"CT_RW", "CT_ETPBTB", "CT_ETPBT", "CT_NetDSP09", "CT_CTEST", "CT_HIGHLIGHT"}

Definition at line 8 of file HCEConstants.cpp.

std::vector< ComponentType > HCE::componentTypeVec
Initial value:
{CT_DEFAULT, CT_NetCP06, CT_EXTFMSG, CT_EXTFMSG_UPD, CT_POSTBLOCK, CT_REFINE, CT_RB,
CT_T, CT_PMT, CT_MT, CT_PMR, CT_MR, CT_MCB, CT_MC, CT_ETPBSB, CT_ETPBS, CT_PMB, CT_PM, CT_RWB,
CT_RW, CT_ETPBTB, CT_ETPBT, CT_NetDSP09, CT_CTEST, CT_HIGHLIGHT}

Definition at line 11 of file HCEConstants.cpp.

const std::string HCE::DRCE_FAKE_RESPONSE = "}]"

Definition at line 372 of file HandlerTypes.hpp.

const std::string HCE::error_messages[]
Initial value:
{
"status ok"
, "documents not present"
, "Parse error – wrong Json format"
, "Action type error : not supported"
, "General internal error of functional object"
, "Invalid message type"
, "Invalid message body"
, "Invalid admin command"
, "Put fail: key exist. The aerospike server is configured for only unique keys."
}

Definition at line 36 of file Errors.hpp.

const std::string HCE::INCOMING_CHARSET = "ucs-2"

Definition at line 16 of file HCEConstants.cpp.