bobocep.cep.engine.producer.pubsub.BoboProducerSubscriber

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

Bases: abc.ABC

A producer subscriber interface.

__init__()
abstract on_producer_update(event: bobocep.cep.event.complex.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.