in pulsar/error.go [156:245]
func getResultStr(r Result) string {
switch r {
case Ok:
return "OK"
case UnknownError:
return "UnknownError"
case InvalidConfiguration:
return "InvalidConfiguration"
case TimeoutError:
return "TimeoutError"
case LookupError:
return "LookupError"
case ConnectError:
return "ConnectError"
case ReadError:
return "ReadError"
case AuthenticationError:
return "AuthenticationError"
case AuthorizationError:
return "AuthorizationError"
case ErrorGettingAuthenticationData:
return "ErrorGettingAuthenticationData"
case BrokerMetadataError:
return "BrokerMetadataError"
case BrokerPersistenceError:
return "BrokerPersistenceError"
case ChecksumError:
return "ChecksumError"
case ConsumerBusy:
return "ConsumerBusy"
case NotConnectedError:
return "NotConnectedError"
case AlreadyClosedError:
return "AlreadyClosedError"
case InvalidMessage:
return "InvalidMessage"
case ConsumerNotInitialized:
return "ConsumerNotInitialized"
case ProducerNotInitialized:
return "ProducerNotInitialized"
case TooManyLookupRequestException:
return "TooManyLookupRequestException"
case InvalidTopicName:
return "InvalidTopicName"
case InvalidURL:
return "InvalidURL"
case ServiceUnitNotReady:
return "ServiceUnitNotReady"
case OperationNotSupported:
return "OperationNotSupported"
case ProducerBlockedQuotaExceededError:
return "ProducerBlockedQuotaExceededError"
case ProducerBlockedQuotaExceededException:
return "ProducerBlockedQuotaExceededException"
case ProducerQueueIsFull:
return "ProducerQueueIsFull"
case MessageTooBig:
return "MessageTooBig"
case TopicNotFound:
return "TopicNotFound"
case SubscriptionNotFound:
return "SubscriptionNotFound"
case ConsumerNotFound:
return "ConsumerNotFound"
case UnsupportedVersionError:
return "UnsupportedVersionError"
case TopicTerminated:
return "TopicTerminated"
case CryptoError:
return "CryptoError"
case ConsumerClosed:
return "ConsumerClosed"
case InvalidBatchBuilderType:
return "InvalidBatchBuilderType"
case AddToBatchFailed:
return "AddToBatchFailed"
case SeekFailed:
return "SeekFailed"
case ProducerClosed:
return "ProducerClosed"
case SchemaFailure:
return "SchemaFailure"
case ClientMemoryBufferIsFull:
return "ClientMemoryBufferIsFull"
case TransactionNoFoundError:
return "TransactionNoFoundError"
default:
return fmt.Sprintf("Result(%d)", r)
}
}