bobocep.dist.pubsub.BoboDistributedSubscriber

class bobocep.dist.pubsub.BoboDistributedSubscriber[source]

Bases: abc.ABC

A distributed subscriber interface.

__init__()
abstract on_distributed_update(completed: List[bobocep.cep.engine.decider.runserial.BoboRunSerial], halted: List[bobocep.cep.engine.decider.runserial.BoboRunSerial], updated: List[bobocep.cep.engine.decider.runserial.BoboRunSerial]) → None[source]
Parameters

  • completed – Completed runs.

  • halted – Halted runs.

  • updated – Updated runs.