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

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

Bases: ABC

A decider publisher interface.

__init__()

abstract snapshot() → Tuple[List[BoboRunSerial], List[BoboRunSerial], List[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: BoboDeciderSubscriber)[source]

Parameters:: subscriber – Subscriber to add to list.