1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
use crate::protos::protobuf::pulsar_api::CommandSubscribe_SubType as Protobuf_SubType; #[derive(PartialEq, Eq, Debug, Clone)] pub enum SubscribeType { Exclusive, Shared, Failover, KeyShared, } impl From<SubscribeType> for Protobuf_SubType { fn from(st: SubscribeType) -> Self { match st { SubscribeType::Exclusive => Protobuf_SubType::Exclusive, SubscribeType::Shared => Protobuf_SubType::Shared, SubscribeType::Failover => Protobuf_SubType::Failover, SubscribeType::KeyShared => Protobuf_SubType::Key_Shared, } } }