spreadflow_core.proc module

class spreadflow_core.proc.DebugLog(message=u'Item received: {item}', level=u'debug')

Bases: object

A minimal processor which simply logs every item received.

log

A L{Logger} emits log messages to an observer. You should instantiate it as a class or module attribute, as documented in L{this module’s documentation <twisted.logger>}.

class spreadflow_core.proc.Duplicator

Bases: object

A processor capable of sending messages to another flow.

class spreadflow_core.proc.Sleep(delay)

Bases: object

A processor which delays every incomming message by the specified amount.

When sleeping, no other incoming message is accepted. Use a throttle before this component in order to avoid queue overflow.

attach(scheduler, reactor)

detach()

sleep = None

class spreadflow_core.proc.SyntheticSource(items)

Bases: object

attach(scheduler, reactor)

detach()

class spreadflow_core.proc.Throttle(delay, initial=0)

Bases: object

A processor which forwards only one incomming message per time period.

attach(scheduler, reactor)

detach()

last = None

now = None