Home       Trees       Indices       Help   
Package Ganga :: Package Lib :: Package MonitoringServices :: Package MSGMS :: Module MSGMS :: Class MSGMS
[hide private]
[frames] | no frames]

Class MSGMS

source code

GPIDev.Adapters.IMonitoringService.IMonitoringService --+
                                                        |
                                                       MSGMS

GangaMon Monitoring Service based on MSG.

Publishes job meta-data to an MSG destination on submit, start and stop events for consumption by a GangaMon subscriber.

See IMonitoringService for implementation details.

Instance Methods [hide private]
 
__init__(self, job_info, config_info)
Construct the GangaMon monitoring service.		 source code
 
getSandboxModules(self)
Return list of MSGMS module dependencies.		 source code
 
getJobInfo(self)
Create job_info from Job object.		 source code
 
getMessage(self, event)
Create message from job_info adding hostname and event.		 source code
 
send(self, message)
Send the message to the configured destination.		 source code
 
submit(self, **opts)
Log submit event on client.		 source code
 
start(self, **opts)
Log start event on worker node.		 source code
 
progress(self, **opts)
Log progress event on worker node.		 source code
 
stop(self, exitcode, **opts)
Log stop event on worker node.		 source code

Inherited from GPIDev.Adapters.IMonitoringService.IMonitoringService: complete, event, fail, getWrapperScriptConstructorText, kill, prepare, rollback, submitting

Static Methods [hide private]
 
getConfig()
Return MSGMS Config object.		 source code
Method Details [hide private]

__init__(self, job_info, config_info)
(Constructor)

source code 

Construct the GangaMon monitoring service.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.__init__

getConfig()
Static Method

source code 

Return MSGMS Config object.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.getConfig

getSandboxModules(self)

source code 

Return list of MSGMS module dependencies.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.getSandboxModules

getJobInfo(self)

source code 

Create job_info from Job object.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.getJobInfo

submit(self, **opts)

source code 

Log submit event on client.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.submit

start(self, **opts)

source code 

Log start event on worker node.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.start

progress(self, **opts)

source code 

Log progress event on worker node. NOP.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.progress

stop(self, exitcode, **opts)

source code 

Log stop event on worker node.

Overrides: GPIDev.Adapters.IMonitoringService.IMonitoringService.stop

   Home       Trees       Indices       Help   
Generated by Epydoc 3.0.1 on Mon Jun 25 10:35:22 2012 http://epydoc.sourceforge.net