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
ResourcesTable.py
Go to the documentation of this file.
1 '''
2 Created on Mar 13, 2014
3 
4 @package: dtm
5 @author: scorp
6 @link: http://hierarchical-cluster-engine.com/
7 @copyright: Copyright © 2013-2014 IOIX Ukraine
8 @license: http://hierarchical-cluster-engine.com/license/
9 @since: 0.1
10 '''
11 import sqlalchemy
12 from sqlalchemy.ext.declarative import declarative_base
13 
14 
16 Base = declarative_base()
17 class ResourcesTable(Base): # pylint: disable-all
18  __tablename__ = "resources_table"
19  __table_args__ = {'mysql_engine': 'MyISAM'}
20  nodeId = sqlalchemy.Column(sqlalchemy.String(256), primary_key=True, autoincrement=False)
21  nodeName = sqlalchemy.Column(sqlalchemy.String(256), primary_key=False)
22  host = sqlalchemy.Column(sqlalchemy.String(256), primary_key=False)
23  port = sqlalchemy.Column(sqlalchemy.Integer, primary_key=False)
24  cpu = sqlalchemy.Column(sqlalchemy.Integer, primary_key=False)
25  io = sqlalchemy.Column(sqlalchemy.Integer, primary_key=False)
26  ramRU = sqlalchemy.Column(sqlalchemy.BigInteger, primary_key=False)
27  ramVU = sqlalchemy.Column(sqlalchemy.BigInteger, primary_key=False)
28  ramR = sqlalchemy.Column(sqlalchemy.BigInteger, primary_key=False)
29  ramV = sqlalchemy.Column(sqlalchemy.BigInteger, primary_key=False)
30  swap = sqlalchemy.Column(sqlalchemy.BigInteger, primary_key=False)
31  swapU = sqlalchemy.Column(sqlalchemy.BigInteger, primary_key=False)
32  disk = sqlalchemy.Column(sqlalchemy.BigInteger, primary_key=False)
33  diskU = sqlalchemy.Column(sqlalchemy.BigInteger, primary_key=False)
34  state = sqlalchemy.Column(sqlalchemy.Integer, primary_key=False)
35  uDate = sqlalchemy.Column(sqlalchemy.DateTime, primary_key=False)
36  cpuCores = sqlalchemy.Column(sqlalchemy.Integer, primary_key=False)
37  threads = sqlalchemy.Column(sqlalchemy.Integer, primary_key=False)
38  processes = sqlalchemy.Column(sqlalchemy.Integer, primary_key=False)
39 
40 
41  # #constructor
42  def __init__(self, eventObject=None):
43  if eventObject == None:
44  self.nodeId = None
45  self.nodeName = None
46  self.host = None
47  self.port = None
48  self.cpu = None
49  self.io = None
50  self.ramRU = None
51  self.ramVU = None
52  self.ramR = None
53  self.ramV = None
54  self.swap = None
55  self.swapU = None
56  self.disk = None
57  self.diskU = None
58  self.state = None
59  self.uDate = None
60  self.cpuCores = None
61  self.threads = None
62  self.processes = None
63  else:
64  self.initFieldsFromEventObject(eventObject)
65 
66 
67  def initFieldsFromEventObject(self, eventObject):
68  self.nodeId = eventObject.nodeId
69  self.nodeName = eventObject.nodeName
70  self.host = eventObject.host
71  self.port = eventObject.port
72  self.cpu = eventObject.cpu
73  self.io = eventObject.io
74  self.ramRU = eventObject.ramRU
75  self.ramVU = eventObject.ramVU
76  self.ramR = eventObject.ramR
77  self.ramV = eventObject.ramV
78  self.swap = eventObject.swap
79  self.swapU = eventObject.swapU
80  self.disk = eventObject.disk
81  self.diskU = eventObject.diskU
82  self.state = eventObject.state
83  self.uDate = eventObject.uDate
84  self.cpuCores = eventObject.cpuCores
85  self.threads = eventObject.threads
86  self.processes = eventObject.processes
dtm.ResourcesTable.Base
Base
Class describes structures of task item used in ResourcesManager module.
Definition: ResourcesTable.py:16
dtm.ResourcesTable.initFieldsFromEventObject
def initFieldsFromEventObject(self, eventObject)
Definition: ResourcesTable.py:67
dtm.ResourcesTable.__init__
def __init__(self, eventObject=None)
Definition: ResourcesTable.py:42