pulsar-binary-protocol-spec 0.0.1

Pulsar binary protocol specification
Documentation 
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,
        }
    }
}