1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use crate::protos::protobuf::pulsar_api::CommandAck_ValidationError as Protobuf_ValidationError;

#[derive(PartialEq, Eq, Debug, Clone)]
pub enum AckValidationError {
    UncompressedSizeCorruption,
    DecompressionError,
    ChecksumMismatch,
    BatchDeSerializeError,
    DecryptionError,
}

impl From<AckValidationError> for Protobuf_ValidationError {
    fn from(ave: AckValidationError) -> Self {
        match ave {
            AckValidationError::UncompressedSizeCorruption => {
                Protobuf_ValidationError::UncompressedSizeCorruption
            }
            AckValidationError::DecompressionError => Protobuf_ValidationError::DecompressionError,
            AckValidationError::ChecksumMismatch => Protobuf_ValidationError::ChecksumMismatch,
            AckValidationError::BatchDeSerializeError => {
                Protobuf_ValidationError::BatchDeSerializeError
            }
            AckValidationError::DecryptionError => Protobuf_ValidationError::DecryptionError,
        }
    }
}