spreadflow_core.service module

class spreadflow_core.service.Options

Bases: twisted.python.usage.Options

optFlags = [[u'oneshot', u'o', u'Exit after initial execution of the network'], [u'multiprocess', u'p', u'Launch a separate process for each chain']]

optParameters = [[u'confpath', u'c', None, u'Path to configuration file'], [u'queuestatus', None, None, u'Path where status should be written to'], [u'partition', None, None, u'Run the given partition of the graph (internal)'], [u'protocol', None, None, u'The IPC protocol to use when running a partition (internal)']]

class spreadflow_core.service.SpreadFlowQueuestatusLogger(path)

Bases: object

logstatus(event)

watch(interval, scheduler)

class spreadflow_core.service.SpreadFlowService(options)

Bases: twisted.application.service.Service

startService()

stopService()

spreadflow_core.service.makeService(options)