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

use crate::commands::{ConnectCommand, ConnectedCommand};

use super::Respond;

pub struct ConnectRespond {}
impl Respond for ConnectRespond {
    type Request = ConnectCommand;
    type Response = ConnectedCommand;
    type Error = ConnectRespondError;
}

make_x_respond_error!(
    Connect;
    AuthenticationError "https://github.com/apache/pulsar/blob/v2.7.0/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java#L773"
);