static PythonExceptionMap createPythonExceptionMap()

in src/exceptions.cc [91:141]
51 lines of code
1 McCabe index (conditional complexity)

static PythonExceptionMap createPythonExceptionMap(py::module_& m, py::exception<PulsarException>& base) {
    PythonExceptionMap exceptions;
    exceptions[ResultUnknownError] = {m, "UnknownError", base};
    exceptions[ResultInvalidConfiguration] = {m, "InvalidConfiguration", base};
    exceptions[ResultTimeout] = {m, "Timeout", base};
    exceptions[ResultLookupError] = {m, "LookupError", base};
    exceptions[ResultConnectError] = {m, "ConnectError", base};
    exceptions[ResultReadError] = {m, "ReadError", base};
    exceptions[ResultAuthenticationError] = {m, "AuthenticationError", base};
    exceptions[ResultAuthorizationError] = {m, "AuthorizationError", base};
    exceptions[ResultErrorGettingAuthenticationData] = {m, "ErrorGettingAuthenticationData", base};
    exceptions[ResultBrokerMetadataError] = {m, "BrokerMetadataError", base};
    exceptions[ResultBrokerPersistenceError] = {m, "BrokerPersistenceError", base};
    exceptions[ResultChecksumError] = {m, "ChecksumError", base};
    exceptions[ResultConsumerBusy] = {m, "ConsumerBusy", base};
    exceptions[ResultNotConnected] = {m, "NotConnected", base};
    exceptions[ResultAlreadyClosed] = {m, "AlreadyClosed", base};
    exceptions[ResultInvalidMessage] = {m, "InvalidMessage", base};
    exceptions[ResultConsumerNotInitialized] = {m, "ConsumerNotInitialized", base};
    exceptions[ResultProducerNotInitialized] = {m, "ProducerNotInitialized", base};
    exceptions[ResultProducerBusy] = {m, "ProducerBusy", base};
    exceptions[ResultTooManyLookupRequestException] = {m, "TooManyLookupRequestException", base};
    exceptions[ResultInvalidTopicName] = {m, "InvalidTopicName", base};
    exceptions[ResultInvalidUrl] = {m, "InvalidUrl", base};
    exceptions[ResultServiceUnitNotReady] = {m, "ServiceUnitNotReady", base};
    exceptions[ResultOperationNotSupported] = {m, "OperationNotSupported", base};
    exceptions[ResultProducerBlockedQuotaExceededError] = {m, "ProducerBlockedQuotaExceededError", base};
    exceptions[ResultProducerBlockedQuotaExceededException] = {m, "ProducerBlockedQuotaExceededException",
                                                               base};
    exceptions[ResultProducerQueueIsFull] = {m, "ProducerQueueIsFull", base};
    exceptions[ResultMessageTooBig] = {m, "MessageTooBig", base};
    exceptions[ResultTopicNotFound] = {m, "TopicNotFound", base};
    exceptions[ResultSubscriptionNotFound] = {m, "SubscriptionNotFound", base};
    exceptions[ResultConsumerNotFound] = {m, "ConsumerNotFound", base};
    exceptions[ResultUnsupportedVersionError] = {m, "UnsupportedVersionError", base};
    exceptions[ResultTopicTerminated] = {m, "TopicTerminated", base};
    exceptions[ResultCryptoError] = {m, "CryptoError", base};
    exceptions[ResultIncompatibleSchema] = {m, "IncompatibleSchema", base};
    exceptions[ResultConsumerAssignError] = {m, "ConsumerAssignError", base};
    exceptions[ResultCumulativeAcknowledgementNotAllowedError] = {
        m, "CumulativeAcknowledgementNotAllowedError", base};
    exceptions[ResultTransactionCoordinatorNotFoundError] = {m, "TransactionCoordinatorNotFoundError", base};
    exceptions[ResultInvalidTxnStatusError] = {m, "InvalidTxnStatusError", base};
    exceptions[ResultNotAllowedError] = {m, "NotAllowedError", base};
    exceptions[ResultTransactionConflict] = {m, "TransactionConflict", base};
    exceptions[ResultTransactionNotFound] = {m, "TransactionNotFound", base};
    exceptions[ResultProducerFenced] = {m, "ProducerFenced", base};
    exceptions[ResultMemoryBufferIsFull] = {m, "MemoryBufferIsFull", base};
    exceptions[ResultInterrupted] = {m, "Interrupted", base};
    return exceptions;
}