HCE project C++ developers source code library  1.1.1
HCE project developer library
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
Public Member Functions | List of all members
HCE::reduce::ReducerFunctionalObjectSphinx Class Reference

#include <ReducerFunctionalObjectSphinx.hpp>

Public Member Functions

 ReducerFunctionalObjectSphinx ()
void accumulate (std::string &jsonReducingInputMessage, unsigned long long itemId)
bool isCompleteTask (unsigned long long itemId, int nodesCount, unsigned int ttl=USE_TASK_TTL_VALUE)
Poco::SharedPtr
< HCE::reduce_types::ReducingOutputMessage > 		reduce (unsigned long long itemId)
unsigned int getTasksNumber ()
int getErrCode ()
std::string getErrMsg ()
int cleanupExpiredTasksByTTL (unsigned int maxRemoveTasks=1, unsigned int ttl=USE_TASK_TTL_VALUE)
unsigned int cleanupExpiredTasksByTTLQueue (unsigned int maxRemoveItems, unsigned int minTerminateTime)
void getExceededTTLTasks (unsigned int maxTaskNumber, std::vector< unsigned long long > &exceededTTLTasks, unsigned int ttl=USE_TASK_TTL_VALUE)
int getRejectedMessages () const

Detailed Description

Definition at line 32 of file ReducerFunctionalObjectSphinx.hpp.

Constructor & Destructor Documentation

HCE::reduce::ReducerFunctionalObjectSphinx::ReducerFunctionalObjectSphinx ( )
inline

Definition at line 34 of file ReducerFunctionalObjectSphinx.hpp.

Here is the call graph for this function:

Member Function Documentation

void HCE::reduce::ReducerFunctionalObjectSphinx::accumulate ( std::string &  jsonReducingInputMessage,
unsigned long long  itemId 
)
inline

Definition at line 41 of file ReducerFunctionalObjectSphinx.hpp.

Here is the call graph for this function:

int HCE::reduce::ReducerFunctionalObjectSphinx::cleanupExpiredTasksByTTL ( unsigned int  maxRemoveTasks = 1,
unsigned int  ttl = USE_TASK_TTL_VALUE 
)
inline

Definition at line 95 of file ReducerFunctionalObjectSphinx.hpp.

unsigned int HCE::reduce::ReducerFunctionalObjectSphinx::cleanupExpiredTasksByTTLQueue ( unsigned int  maxRemoveItems,
unsigned int  minTerminateTime 
)
inline

Definition at line 99 of file ReducerFunctionalObjectSphinx.hpp.

int HCE::reduce::ReducerFunctionalObjectSphinx::getErrCode ( )
inline

Definition at line 87 of file ReducerFunctionalObjectSphinx.hpp.

std::string HCE::reduce::ReducerFunctionalObjectSphinx::getErrMsg ( )
inline

Definition at line 91 of file ReducerFunctionalObjectSphinx.hpp.

void HCE::reduce::ReducerFunctionalObjectSphinx::getExceededTTLTasks ( unsigned int  maxTaskNumber,
std::vector< unsigned long long > &  exceededTTLTasks,
unsigned int  ttl = USE_TASK_TTL_VALUE 
)
inline

Definition at line 103 of file ReducerFunctionalObjectSphinx.hpp.

int HCE::reduce::ReducerFunctionalObjectSphinx::getRejectedMessages ( ) const
inline

Definition at line 108 of file ReducerFunctionalObjectSphinx.hpp.

unsigned int HCE::reduce::ReducerFunctionalObjectSphinx::getTasksNumber ( )
inline

Definition at line 83 of file ReducerFunctionalObjectSphinx.hpp.

bool HCE::reduce::ReducerFunctionalObjectSphinx::isCompleteTask ( unsigned long long  itemId,
int  nodesCount,
unsigned int  ttl = USE_TASK_TTL_VALUE 
)
inline

Definition at line 62 of file ReducerFunctionalObjectSphinx.hpp.

Poco::SharedPtr<HCE::reduce_types::ReducingOutputMessage> HCE::reduce::ReducerFunctionalObjectSphinx::reduce ( unsigned long long  itemId)
inline

Definition at line 75 of file ReducerFunctionalObjectSphinx.hpp.

The documentation for this class was generated from the following file: