浏览代码

documentation & architecture refactor

steve 8 年之前
父节点
当前提交
da0986e243
共有 3 个文件被更改,包括 250 次插入2 次删除
  1. 243 0
      src/api/static/img/uml-design
  2. 2 1
      src/utils/agents/actor.py
  3. 5 1
      src/utils/agents/data-collector.py

文件差异内容过多而无法显示
+ 243 - 0
src/api/static/img/uml-design


+ 2 - 1
src/utils/agents/actor.py

@@ -46,7 +46,7 @@ class Actor:
                 message = {"from":self.getIdentifier(),"to":to,"content":content}
                 host	= self.config['api']
                 uid	= self.config['key']
-                qid	= to#self.config['id']
+                qid	= to#self.conorfig['id']
                 
                 qwriter = QueueWriter(host=host,uid=uid,qid=qid)
                 qwriter.init(qid)
@@ -55,6 +55,7 @@ class Actor:
                 pass
 
 class Kill(Actor):
+    
         def isValid(self,item):
                 print self.config
                 return (item is not None) and (item in self.config)

+ 5 - 1
src/utils/agents/data-collector.py

@@ -27,6 +27,8 @@ class ICollector(Thread) :
 		self.factory	= DataSourceFactory()
 		self.init()
 		self.name = 'data-collector@'+self.id
+		
+		
 	def init(self):
 		
 		
@@ -51,7 +53,9 @@ class ICollector(Thread) :
 		self.quit = False
 		#self.DELAY = PARAMS['delay']*60
 		self.DELAY = self.config['delay']
-		
+		#
+		# we need to instanciate the actor orchestrator
+		#
 	"""
 		This function returns an instance of a data collector class :
 		ProcessDetails, FileWatch, ... provided the class name