HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
dtm.TasksManager.TasksManager Member List

This is the complete list of members for dtm.TasksManager.TasksManager, including all inherited members.

__init__(self, configParser, connectBuilderLight, pollerManager=None)dtm.TasksManager.TasksManager
app::BaseServerManager::BaseServerManager.__init__(self, poller_manager=None, admin_connection=None, conectionLightBuilder=None, exceptionForward=False, dumpStatVars=True)app.BaseServerManager.BaseServerManager
addConnection(self, name, connection)app.BaseServerManager.BaseServerManager
addNewTaskData(self, event)dtm.TasksManager.TasksManager
ADMIN_CONNECT_CLIENTapp.BaseServerManager.BaseServerManagerstatic
ADMIN_CONNECT_ENDPOINTapp.BaseServerManager.BaseServerManagerstatic
AUTO_CLEANUP_TIME_SLOT_PERIODdtm.TasksManager.TasksManagerstatic
build_poller_list(self)app.BaseServerManager.BaseServerManager
cfg_sectiondtm.TasksManager.TasksManager
checkCleanUp(self, taskId=None)dtm.TasksManager.TasksManager
checkTaskPresence(self, taskId)dtm.TasksManager.TasksManager
cleanAfterDBIErr(self, event)dtm.TasksManager.TasksManager
CLEANUP_TABLES_LISTdtm.TasksManager.TasksManagerstatic
cleanUpOnStart(self, isClearOnStart)dtm.TasksManager.TasksManager
cleanupTables(self)dtm.TasksManager.TasksManager
cleanUpTask(self, taskBackLogScheme)dtm.TasksManager.TasksManager
cleanUpTaskNetworkOperation(self, taskId, delFromTDMData)dtm.TasksManager.TasksManager
cleanUpTimeoutdtm.TasksManager.TasksManager
clear_poller(self)app.BaseServerManager.BaseServerManager
clearEmptyFields(self, fields, taskId)dtm.TasksManager.TasksManager
CONFIG_TIME_SLOT_PERIODdtm.TasksManager.TasksManagerstatic
configVarsapp.BaseServerManager.BaseServerManager
connectionsapp.BaseServerManager.BaseServerManager
createDBIDict(self, configParser)app.BaseServerManager.BaseServerManager
createLogMsg(self, event)app.BaseServerManager.BaseServerManager
createOperationSteps(self, event, dataManagerEventType, onlyLastTwo=False)dtm.TasksManager.TasksManager
createTaskLog(self, taskObj)dtm.TasksManager.TasksManager
createTaskLogFromDic(self, fields)dtm.TasksManager.TasksManager
createTaskManagerFields(self, taskLog)dtm.TasksManager.TasksManager
dbidtm.TasksManager.TasksManager
deleteOnCleanUp(self, taskData, autoCleanupFields)dtm.TasksManager.TasksManager
dumpStatVarsapp.BaseServerManager.BaseServerManager
event_handlersapp.BaseServerManager.BaseServerManager
eventBuilderapp.BaseServerManager.BaseServerManager
exceptionForwardapp.BaseServerManager.BaseServerManager
exit_flagapp.BaseServerManager.BaseServerManager
fetchEventsdtm.TasksManager.TasksManager
finishNewTaskData(self, event)dtm.TasksManager.TasksManager
getConfigVarsFields(self, fields)app.BaseServerManager.BaseServerManager
getDeletedTask(self, taskLog)dtm.TasksManager.TasksManager
getLogLevel(self)app.BaseServerManager.BaseServerManager
getStatDataFields(self, fields)app.BaseServerManager.BaseServerManager
getStatVarsDumpFileName(self)app.BaseServerManager.BaseServerManager
getSystemStat(self)app.BaseServerManager.BaseServerManager
groupDeleteResponseEventdtm.TasksManager.TasksManager
initStatFields(self, connect_name)app.BaseServerManager.BaseServerManager
is_connection_registered(self, name)app.BaseServerManager.BaseServerManager
loadStatVarsDump(self)app.BaseServerManager.BaseServerManager
LOG_LEVEL_CONFIG_VAR_NAMEapp.BaseServerManager.BaseServerManagerstatic
LOGGERS_NAMESapp.BaseServerManager.BaseServerManagerstatic
newTaskRollback(self, event)dtm.TasksManager.TasksManager
on_poll_timeout(self)dtm.TasksManager.TasksManager
on_unhandled_event(self, event)app.BaseServerManager.BaseServerManager
onAdminFetchStatData(self, event)app.BaseServerManager.BaseServerManager
onAdminGetConfigVars(self, event)app.BaseServerManager.BaseServerManager
onAdminSetConfigVars(self, event)app.BaseServerManager.BaseServerManager
onAdminState(self, event)app.BaseServerManager.BaseServerManager
onAdminSuspend(self, event)app.BaseServerManager.BaseServerManager
onDeleteTask(self, event)dtm.TasksManager.TasksManager
onDeleteTaskResponse(self, event)dtm.TasksManager.TasksManager
onFetchAvailableTasks(self, event)dtm.TasksManager.TasksManager
onFetchResultResponse(self, event)dtm.TasksManager.TasksManager
onFetchResultsCache(self, event)dtm.TasksManager.TasksManager
onFetchTaskDataResponse(self, event)dtm.TasksManager.TasksManager
onGetTaskFields(self, event)dtm.TasksManager.TasksManager
onGetTaskStatus(self, event)dtm.TasksManager.TasksManager
onNewTask(self, event)dtm.TasksManager.TasksManager
onTasksManagerGeneralResponse(self, event)dtm.TasksManager.TasksManager
onUpdateTask(self, event)dtm.TasksManager.TasksManager
onUpdateTaskField(self, event)dtm.TasksManager.TasksManager
pendingTasksdtm.TasksManager.TasksManager
poll(self)app.BaseServerManager.BaseServerManager
POLL_TIMEOUT_CONFIG_VAR_NAMEapp.BaseServerManager.BaseServerManagerstatic
POLL_TIMEOUT_DEFAULTapp.BaseServerManager.BaseServerManagerstatic
poller_managerapp.BaseServerManager.BaseServerManager
pollTimeoutapp.BaseServerManager.BaseServerManager
prevCleanUpTimedtm.TasksManager.TasksManager
process(self, event)app.BaseServerManager.BaseServerManager
processOperationStep(self, event)dtm.TasksManager.TasksManager
processSchedulerFailure(self, event)dtm.TasksManager.TasksManager
processSpecialConfigVars(self, name, value)app.BaseServerManager.BaseServerManager
processTasksDataManagerFailure(self, event)dtm.TasksManager.TasksManager
reply(self, event, reply_event)app.BaseServerManager.BaseServerManager
replyGeneralResponse(self, event)dtm.TasksManager.TasksManager
restoreTaskSteps(self, taskId)dtm.TasksManager.TasksManager
run(self)app.BaseServerManager.BaseServerManager
saveStatVarsDump(self)app.BaseServerManager.BaseServerManager
SCHEDULER_CLIENTdtm.TasksManager.TasksManagerstatic
send(self, connect_name, event)app.BaseServerManager.BaseServerManager
sendAdminReadyEvent(self)app.BaseServerManager.BaseServerManager
sendGroupDeleteResponse(self)dtm.TasksManager.TasksManager
SERVERdtm.TasksManager.TasksManagerstatic
setConfigVars(self, setConfigVars)app.BaseServerManager.BaseServerManager
setEventHandler(self, eventType, handler)app.BaseServerManager.BaseServerManager
setLogLevel(self, level)app.BaseServerManager.BaseServerManager
simpleDeleteTask(self, event, responseEventType)dtm.TasksManager.TasksManager
STAT_DUMPS_DEFAULT_DIRapp.BaseServerManager.BaseServerManagerstatic
STAT_DUMPS_DEFAULT_NAMEapp.BaseServerManager.BaseServerManagerstatic
STAT_FIELDS_OPERATION_ADDapp.BaseServerManager.BaseServerManagerstatic
STAT_FIELDS_OPERATION_INITapp.BaseServerManager.BaseServerManagerstatic
STAT_FIELDS_OPERATION_SETapp.BaseServerManager.BaseServerManagerstatic
STAT_FIELDS_OPERATION_SUBapp.BaseServerManager.BaseServerManagerstatic
statFieldsapp.BaseServerManager.BaseServerManager
statFieldsRecalculate(self, taskLogScheme)dtm.TasksManager.TasksManager
TASKS_DATA_MANAGER_CLIENTdtm.TasksManager.TasksManagerstatic
tasksQueuedtm.TasksManager.TasksManager
updateStatField(self, field_name, value, operation=STAT_FIELDS_OPERATION_ADD)app.BaseServerManager.BaseServerManager
updateTaskBackLogToSchedulerStep(self, localId, incr, newState)dtm.TasksManager.TasksManager
VAR_TASKS_DELETE_TRIESdtm.TasksManager.TasksManagerstatic
VAR_TASKS_ERRORSdtm.TasksManager.TasksManagerstatic
VAR_TASKS_RETRIESdtm.TasksManager.TasksManagerstatic
VAR_TASKS_RETRIES_DELdtm.TasksManager.TasksManagerstatic
VAR_TASKS_TIME_AVGdtm.TasksManager.TasksManagerstatic
VAR_TASKS_TIME_COUNTdtm.TasksManager.TasksManagerstatic
VAR_TASKS_TIME_MAXdtm.TasksManager.TasksManagerstatic
VAR_TASKS_TIME_MINdtm.TasksManager.TasksManagerstatic
VAR_TASKS_TIME_SUMdtm.TasksManager.TasksManagerstatic
VAR_TASKS_TOTALdtm.TasksManager.TasksManagerstatic
VAR_TASKS_TOTAL_DELdtm.TasksManager.TasksManagerstatic