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
Constants.py
Go to the documentation of this file.
1 '''
2 HCE project, Python bindings, Distributed Tasks Manager application.
3 Application level constants and enumerations.
4 
5 @package: dtm
6 @author bgv bgv.hce@gmail.com
7 @link: http://hierarchical-cluster-engine.com/
8 @copyright: Copyright © 2013-2014 IOIX Ukraine
9 @license: http://hierarchical-cluster-engine.com/license/
10 @since: 0.1
11 '''
12 
13 import app.Consts as APP_CONSTS
14 
15 
18 class EVENT_TYPES(object):
19  #Request events
20  NEW_TASK = 1
21  UPDATE_TASK = 2
22  DELETE_TASK_RESULTS = 3
23  GET_TASK_STATUS = 4
24  FETCH_TASK_RESULTS = 5
25  FETCH_RESULTS_CACHE = 6
26  DELETE_TASK = 7
27  #TaskDataManager
28  FETCH_TASK_DATA = 8
29  INSERT_EE_DATA = 9
30  DELETE_TASK_DATA = 10
31  FETCH_EE_DATA = 11
32  DELETE_EE_DATA = 12
33  #ExecutionEnvironmentManager
34  EXECUTE_TASK = 13
35  DELETE_TASKS = 14
36  CHECK_TASK_STATE = 15
37  UPDATE_TASK_FIELDS = 17
38  GET_TASK_FIELDS = 18
39  #TasksExecutor
40  GET_SCHEDULED_TASKS = 19
41  #ResourcesStateMonitor
42  UPDATE_RESOURCES_DATA = 20
43  #ResourcesManager
44  GET_AVG_RESOURCES = 21
45  #TasksManager
46  SCHEDULE_TASK = 22
47  UPDATE_SCHEDULED_TASKS = 23
48  #AdminInterfaceServer
49  ADMIN_FETCH_STAT_DATA = 1024
50  ADMIN_GET_CONFIG_VARS = 1025
51  ADMIN_SET_CONFIG_VARS = 1026
52  ADMIN_STATE = 1027
53  ADMIN_SYSTEM = 1028
54  ADMIN_SQL_CUSTOM = 1029
55  SERVER_TCP_RAW = 28
56  #TaskStateUpdateService
57  FETCH_AVAILABLE_TASK_IDS = 30
58  ADMIN_SUSPEND = 31
59 
60  #Response events
61  GENERAL_RESPONSE = 100
62  NEW_TASK_RESPONSE = 101
63  UPDATE_TASK_RESPONSE = 102
64  CHECK_TASK_STATE_RESPONSE = 103
65  GET_TASK_STATUS_RESPONSE = 104
66  FETCH_TASK_RESULTS_RESPONSE = 105
67  DELETE_TASK_RESPONSE = 106
68  #TaskDataManager
69  FETCH_TASK_DATA_RESPONSE = 107
70  INSERT_EE_DATA_RESPONSE = 108
71  DELETE_TASK_DATA_RESPONSE = 109
72  FETCH_EE_DATA_RESPONSE = 110
73  DELETE_EE_DATA_RESPONSE = 111
74  #ExecutionEnvironmentManager
75  GET_TASK_FIELDS_RESPONSE = 112
76  UPDATE_TASK_FIELDS_RESPONSE = 113
77  #TaskExecutor
78  GET_SCHEDULED_TASKS_RESPONSE = 114
79  #ResourcesStateMonitor
80  UPDATE_RESOURCES_DATA_RESPONSE = 115
81  #ResourcesManager
82  GET_AVG_RESOURCES_RESPONSE = 116
83  #TasksManager
84  SCHEDULE_TASK_RESPONSE = 117
85  UPDATE_SCHEDULED_TASKS_RESPONSE = 118
86  #ClientInterfaceService
87  DELETE_TASK_RESULTS_RESPONSE = 119
88  #AdminInterfaceServer
89  ADMIN_FETCH_STAT_DATA_RESPONSE = 120
90  ADMIN_GET_CONFIG_VARS_RESPONSE = 121
91  ADMIN_SET_CONFIG_VARS_RESPONSE = 122
92  ADMIN_STATE_RESPONSE = 123
93  ADMIN_SQL_CUSTOM_RESPONSE = 124
94  #TasksManager
95  AVAILABLE_TASK_IDS_RESPONSE = 124
96  ADMIN_SUSPEND_RESPONSE = 125
97 
98  ADMIN_SYSTEM_RESPONSE = 126
99 
100 
101 
104  def __init__(self):
105  pass
106 
107 
108 
109 
112 class DRCE_FIELDS(object):
113  #Request events
114  ALG = "alg"
115  DELAY = "delay"
116  REPEAT = "repeat"
117  SIGNAL = "signal"
118  HOST = "host"
119  PORT = "port"
120  STATE = "state"
121  URRAM = "TASK_RRAM"
122  UVRAM = "TASK_VRAM"
123  UCPU = "TASK_CPU"
124  UTHREADS = "TASK_THREADS"
125 
126 
127 
130  def __init__(self):
131  pass
132 
133 #Logger name
134 #LOGGER_NAME = "dtm"
135 LOGGER_NAME = APP_CONSTS.LOGGER_NAME
136 
137 CLEAR_ON_START = "ClearOnStart"
138 
139 DB_CONFIG_SECTION = "DBData"
140 
dtm.Constants.DRCE_FIELDS.__init__
def __init__(self)
constructor initialize task's fields
Definition: Constants.py:130
dtm.Constants.EVENT_TYPES.__init__
def __init__(self)
constructor initialize task's fields
Definition: Constants.py:104
dtm.Constants.EVENT_TYPES
Event types definition, used to unique identification events by inproc messaging transport.
Definition: Constants.py:18