lib/Result.cc

/**
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
#include <pulsar/Result.h>
#include <pulsar/defines.h>

#include <iostream>

namespace pulsar {

const char* strResult(Result result) {
    switch (result) {
        case ResultRetryable:
            return "Retryable";

        case ResultOk:
            return "Ok";

        case ResultUnknownError:
            return "UnknownError";

        case ResultInvalidConfiguration:
            return "InvalidConfiguration";

        case ResultTimeout:
            return "TimeOut";

        case ResultLookupError:
            return "LookupError";

        case ResultConnectError:
            return "ConnectError";

        case ResultAuthenticationError:
            return "AuthenticationError";

        case ResultAuthorizationError:
            return "AuthorizationError";

        case ResultErrorGettingAuthenticationData:
            return "ErrorGettingAuthenticationData";

        case ResultBrokerMetadataError:
            return "BrokerMetadataError";

        case ResultBrokerPersistenceError:
            return "BrokerPersistenceError";

        case ResultConsumerBusy:
            return "ConsumerBusy";

        case ResultNotConnected:
            return "NotConnected";

        case ResultReadError:
            return "ReadError";

        case ResultAlreadyClosed:
            return "AlreadyClosed";

        case ResultInvalidMessage:
            return "InvalidMessage";

        case ResultConsumerNotInitialized:
            return "ConsumerNotInitialized";

        case ResultProducerNotInitialized:
            return "ProducerNotInitialized";

        case ResultInvalidTopicName:
            return "InvalidTopicName";

        case ResultServiceUnitNotReady:
            return "ServiceUnitNotReady";

        case ResultInvalidUrl:
            return "InvalidUrl";

        case ResultChecksumError:
            return "ChecksumError";

        case ResultTooManyLookupRequestException:
            return "TooManyLookupRequestException";

        case ResultOperationNotSupported:
            return "OperationNotSupported";

        case ResultProducerBlockedQuotaExceededError:
            return "ProducerBlockedQuotaExceededError";

        case ResultProducerBlockedQuotaExceededException:
            return "ProducerBlockedQuotaExceededException";

        case ResultProducerQueueIsFull:
            return "ProducerQueueIsFull";

        case ResultMessageTooBig:
            return "MessageTooBig";

        case ResultTopicNotFound:
            return "TopicNotFound";

        case ResultSubscriptionNotFound:
            return "SubscriptionNotFound";

        case ResultConsumerNotFound:
            return "ConsumerNotFound";

        case ResultUnsupportedVersionError:
            return "UnsupportedVersionError";

        case ResultTopicTerminated:
            return "TopicTerminated";

        case ResultCryptoError:
            return "CryptoError";

        case ResultProducerBusy:
            return "ProducerBusy";

        case ResultIncompatibleSchema:
            return "IncompatibleSchema";

        case ResultConsumerAssignError:
            return "ResultConsumerAssignError";

        case ResultCumulativeAcknowledgementNotAllowedError:
            return "ResultCumulativeAcknowledgementNotAllowedError";

        case ResultTransactionCoordinatorNotFoundError:
            return "ResultTransactionCoordinatorNotFoundError";

        case ResultInvalidTxnStatusError:
            return "ResultInvalidTxnStatusError";

        case ResultNotAllowedError:
            return "ResultNotAllowedError";

        case ResultTransactionConflict:
            return "ResultTransactionConflict";

        case ResultTransactionNotFound:
            return "ResultTransactionNotFound";

        case ResultProducerFenced:
            return "ResultProducerFenced";

        case ResultMemoryBufferIsFull:
            return "ResultMemoryBufferIsFull";

        case ResultInterrupted:
            return "ResultInterrupted";

        case ResultDisconnected:
            return "ResultDisconnected";
    };
    // NOTE : Do not add default case in the switch above. In future if we get new cases for
    // ServerError and miss them in the switch above we would like to get notified. Adding
    // return here to make the compiler happy.
    return "UnknownErrorCode";
}

PULSAR_PUBLIC std::ostream& operator<<(std::ostream& s, Result result) { return s << strResult(result); }

}  // namespace pulsar