bobocep.cep.engine.decider.pubsub.BoboDeciderPublisher

class bobocep.cep.engine.decider.pubsub.BoboDeciderPublisher[source]

Bases: abc.ABC

A decider publisher interface.

__init__()

abstract snapshot() → Tuple[List[bobocep.cep.engine.decider.runserial.BoboRunSerial], List[bobocep.cep.engine.decider.runserial.BoboRunSerial], List[bobocep.cep.engine.decider.runserial.BoboRunSerial]][source]

A snapshot of the current state of the Decider.

Returns: Tuple of cached completed, cached halted, and currently partially-completed runs. If caching is disabled, the first two lists will be empty.

abstract subscribe(subscriber: bobocep.cep.engine.decider.pubsub.BoboDeciderSubscriber)[source]

Parameters: subscriber – Subscriber to add to list.