| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205 |
- """Kazoo Exceptions"""
- from collections import defaultdict
- class KazooException(Exception):
- """Base Kazoo exception that all other kazoo library exceptions
- inherit from"""
- class ZookeeperError(KazooException):
- """Base Zookeeper exception for errors originating from the
- Zookeeper server"""
- class CancelledError(KazooException):
- """Raised when a process is cancelled by another thread"""
- class ConfigurationError(KazooException):
- """Raised if the configuration arguments to an object are
- invalid"""
- class ZookeeperStoppedError(KazooException):
- """Raised when the kazoo client stopped (and thus not connected)"""
- class ConnectionDropped(KazooException):
- """Internal error for jumping out of loops"""
- class LockTimeout(KazooException):
- """Raised if failed to acquire a lock.
- .. versionadded:: 1.1
- """
- class WriterNotClosedException(KazooException):
- """Raised if the writer is unable to stop closing when requested.
- .. versionadded:: 1.2
- """
- class SaslException(KazooException):
- """Raised if SASL encountered an error.
- .. versionadded:: 2.1
- """
- def _invalid_error_code():
- raise RuntimeError('Invalid error code')
- EXCEPTIONS = defaultdict(_invalid_error_code)
- def _zookeeper_exception(code):
- def decorator(klass):
- def create(*args, **kwargs):
- return klass(args, kwargs)
- EXCEPTIONS[code] = create
- klass.code = code
- return klass
- return decorator
- @_zookeeper_exception(0)
- class RolledBackError(ZookeeperError):
- pass
- @_zookeeper_exception(-1)
- class SystemZookeeperError(ZookeeperError):
- pass
- @_zookeeper_exception(-2)
- class RuntimeInconsistency(ZookeeperError):
- pass
- @_zookeeper_exception(-3)
- class DataInconsistency(ZookeeperError):
- pass
- @_zookeeper_exception(-4)
- class ConnectionLoss(ZookeeperError):
- pass
- @_zookeeper_exception(-5)
- class MarshallingError(ZookeeperError):
- pass
- @_zookeeper_exception(-6)
- class UnimplementedError(ZookeeperError):
- pass
- @_zookeeper_exception(-7)
- class OperationTimeoutError(ZookeeperError):
- pass
- @_zookeeper_exception(-8)
- class BadArgumentsError(ZookeeperError):
- pass
- @_zookeeper_exception(-100)
- class APIError(ZookeeperError):
- pass
- @_zookeeper_exception(-101)
- class NoNodeError(ZookeeperError):
- pass
- @_zookeeper_exception(-102)
- class NoAuthError(ZookeeperError):
- pass
- @_zookeeper_exception(-103)
- class BadVersionError(ZookeeperError):
- pass
- @_zookeeper_exception(-108)
- class NoChildrenForEphemeralsError(ZookeeperError):
- pass
- @_zookeeper_exception(-110)
- class NodeExistsError(ZookeeperError):
- pass
- @_zookeeper_exception(-111)
- class NotEmptyError(ZookeeperError):
- pass
- @_zookeeper_exception(-112)
- class SessionExpiredError(ZookeeperError):
- pass
- @_zookeeper_exception(-113)
- class InvalidCallbackError(ZookeeperError):
- pass
- @_zookeeper_exception(-114)
- class InvalidACLError(ZookeeperError):
- pass
- @_zookeeper_exception(-115)
- class AuthFailedError(ZookeeperError):
- pass
- @_zookeeper_exception(-118)
- class SessionMovedError(ZookeeperError):
- pass
- @_zookeeper_exception(-119)
- class NotReadOnlyCallError(ZookeeperError):
- """An API call that is not read-only was used while connected to
- a read-only server"""
- class ConnectionClosedError(SessionExpiredError):
- """Connection is closed"""
- # BW Compat aliases for C lib style exceptions
- ConnectionLossException = ConnectionLoss
- MarshallingErrorException = MarshallingError
- SystemErrorException = SystemZookeeperError
- RuntimeInconsistencyException = RuntimeInconsistency
- DataInconsistencyException = DataInconsistency
- UnimplementedException = UnimplementedError
- OperationTimeoutException = OperationTimeoutError
- BadArgumentsException = BadArgumentsError
- ApiErrorException = APIError
- NoNodeException = NoNodeError
- NoAuthException = NoAuthError
- BadVersionException = BadVersionError
- NoChildrenForEphemeralsException = NoChildrenForEphemeralsError
- NodeExistsException = NodeExistsError
- InvalidACLException = InvalidACLError
- AuthFailedException = AuthFailedError
- NotEmptyException = NotEmptyError
- SessionExpiredException = SessionExpiredError
- InvalidCallbackException = InvalidCallbackError
|