# Copyright (c) 2019-2024 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.
"""