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.Scheduler.Scheduler Member List

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

__init__(self, configParser, connectBuilderLight, pollerManager=None)dtm.Scheduler.Scheduler
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
addPendingEvent(self, event)dtm.Scheduler.Scheduler
ADMIN_CONNECT_CLIENTapp.BaseServerManager.BaseServerManagerstatic
ADMIN_CONNECT_ENDPOINTapp.BaseServerManager.BaseServerManagerstatic
build_poller_list(self)app.BaseServerManager.BaseServerManager
cfg_sectiondtm.Scheduler.Scheduler
checkCorrectTaskType(self, task)dtm.Scheduler.Scheduler
clear_poller(self)app.BaseServerManager.BaseServerManager
CLIENT_INTERFACE_SERVICE_CLIENTdtm.Scheduler.Schedulerstatic
configVarsapp.BaseServerManager.BaseServerManager
connectionsapp.BaseServerManager.BaseServerManager
createDBIDict(self, configParser)dtm.Scheduler.Scheduler
createLogMsg(self, event)app.BaseServerManager.BaseServerManager
dbidtm.Scheduler.Scheduler
deletePendingEvent(self, event)dtm.Scheduler.Scheduler
deleteTaskFromSchedule(self, deleteTask, schedulerTask=None)dtm.Scheduler.Scheduler
dumpStatVarsapp.BaseServerManager.BaseServerManager
event_handlersapp.BaseServerManager.BaseServerManager
eventBuilderapp.BaseServerManager.BaseServerManager
exceptionForwardapp.BaseServerManager.BaseServerManager
exit_flagapp.BaseServerManager.BaseServerManager
getConfigVarsFields(self, fields)app.BaseServerManager.BaseServerManager
getLogLevel(self)app.BaseServerManager.BaseServerManager
getPlannedRunTime(self, date_string)dtm.Scheduler.Scheduler
getStatDataFields(self, fields)app.BaseServerManager.BaseServerManager
getStatVarsDumpFileName(self)app.BaseServerManager.BaseServerManager
getSystemStat(self)app.BaseServerManager.BaseServerManager
getTimeSinceEpoch(self, date=None)dtm.Scheduler.Scheduler
initStatFields(self, connect_name)app.BaseServerManager.BaseServerManager
is_connection_registered(self, name)app.BaseServerManager.BaseServerManager
isPossibleToRun(self, resourcesAVG, task_strategy)dtm.Scheduler.Scheduler
loadStatVarsDump(self)app.BaseServerManager.BaseServerManager
LOG_LEVEL_CONFIG_VAR_NAMEapp.BaseServerManager.BaseServerManagerstatic
LOGGERS_NAMESapp.BaseServerManager.BaseServerManagerstatic
MAX_TASKSdtm.Scheduler.Schedulerstatic
maxTasksdtm.Scheduler.Scheduler
modifyTaskInSchedule(self, task)dtm.Scheduler.Scheduler
on_poll_timeout(self)app.BaseServerManager.BaseServerManager
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
onAVGResourcesResponse(self, event)dtm.Scheduler.Scheduler
onDeleteTask(self, event)dtm.Scheduler.Scheduler
onGetSheduledTasks(self, event)dtm.Scheduler.Scheduler
onNewTask(self, event)dtm.Scheduler.Scheduler
onUpdateTask(self, event)dtm.Scheduler.Scheduler
onUpdateTaskFieldsResponse(self, event)dtm.Scheduler.Scheduler
OPERATION_ERRdtm.Scheduler.Schedulerstatic
OPERATION_ERR_MSGdtm.Scheduler.Schedulerstatic
planTaskTimeToRun(self, task)dtm.Scheduler.Scheduler
poll(self)app.BaseServerManager.BaseServerManager
POLL_TIMEOUT_CONFIG_VAR_NAMEapp.BaseServerManager.BaseServerManagerstatic
POLL_TIMEOUT_DEFAULTapp.BaseServerManager.BaseServerManagerstatic
poller_managerapp.BaseServerManager.BaseServerManager
pollTimeoutapp.BaseServerManager.BaseServerManager
process(self, event)app.BaseServerManager.BaseServerManager
processSpecialConfigVars(self, name, value)app.BaseServerManager.BaseServerManager
reply(self, event, reply_event)app.BaseServerManager.BaseServerManager
reschedulingTasks(self)dtm.Scheduler.Scheduler
RESOURCES_EXCEED_ERRdtm.Scheduler.Schedulerstatic
RESOURCES_EXCEED_ERR_MSGdtm.Scheduler.Schedulerstatic
RESOURCES_MANAGER_CLIENTdtm.Scheduler.Schedulerstatic
rTimeCalc(self, schedulerTask, task_strategy, replanned)dtm.Scheduler.Scheduler
run(self)app.BaseServerManager.BaseServerManager
saveStatVarsDump(self)app.BaseServerManager.BaseServerManager
send(self, connect_name, event)app.BaseServerManager.BaseServerManager
sendAdminReadyEvent(self)app.BaseServerManager.BaseServerManager
sendOperationProcessingError(self, event)dtm.Scheduler.Scheduler
SERVERdtm.Scheduler.Schedulerstatic
setConfigVars(self, setConfigVars)app.BaseServerManager.BaseServerManager
setEventHandler(self, eventType, handler)app.BaseServerManager.BaseServerManager
setLogLevel(self, level)app.BaseServerManager.BaseServerManager
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
stateRecalculate(self, task_strategy, schedulerTask)dtm.Scheduler.Scheduler
statFieldsapp.BaseServerManager.BaseServerManager
tasksToUpdatedtm.Scheduler.Scheduler
taskUpdateProcess(self)dtm.Scheduler.Scheduler
TIME_SLOT_PERIODdtm.Scheduler.Schedulerstatic
timeSlotdtm.Scheduler.Scheduler
updateStatField(self, field_name, value, operation=STAT_FIELDS_OPERATION_ADD)app.BaseServerManager.BaseServerManager
waitResourcesEventsdtm.Scheduler.Scheduler
waitResourcesTasksdtm.Scheduler.Scheduler