1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

use crate::protos::protobuf::pulsar_api::CommandAck_AckType as Protobuf_AckType;

#[derive(PartialEq, Eq, Debug, Clone)]
pub enum AckType {
    Individual,
    Cumulative,
}

impl From<AckType> for Protobuf_AckType {
    fn from(at: AckType) -> Self {
        match at {
            AckType::Individual => Protobuf_AckType::Individual,
            AckType::Cumulative => Protobuf_AckType::Cumulative,
        }
    }
}