bobocep.cep.engine.producer.pubsub.BoboProducerSubscriber

class bobocep.cep.engine.producer.pubsub.BoboProducerSubscriber[source]

Bases: ABC

A producer subscriber interface.

__init__()
abstract on_producer_update(event: BoboEventComplex, local: bool) → None[source]
Parameters:

  • event – Complex event generated by Producer.

  • local – True if the complex event was generated using a locally-completed run; False otherwise.