# Copyright (c) 2019-2023 r3w0p
# The following code can be redistributed and/or
# modified under the terms of the MIT License.
"""
Distributed complex event processing.
"""
from abc import ABC, abstractmethod
from bobocep import BoboError
[docs]class BoboDistributedError(BoboError):
"""
A distributed error.
"""
[docs]class BoboDistributedSystemError(BoboDistributedError):
"""
A distributed system error.
"""
[docs]class BoboDistributedTimeoutError(BoboDistributedError):
"""
A distributed timeout error.
"""
[docs]class BoboDistributedJSONError(BoboDistributedError):
"""
A distributed JSON error.
"""
[docs]class BoboDistributedJSONEncodeError(BoboDistributedJSONError):
"""
A distributed JSON encode error.
"""
[docs]class BoboDistributedJSONDecodeError(BoboDistributedJSONError):
"""
A distributed JSON decode error.
"""
[docs]class BoboDistributed(ABC):
"""
Distributed `BoboCEP`.
"""
[docs] @abstractmethod
def run(self) -> None:
"""
Runs distributed.
"""