#![allow(unused_imports)]
#![allow(unused_extern_crates)]
#![cfg_attr(feature = "cargo-clippy", allow(too_many_arguments, type_complexity))]
#![cfg_attr(rustfmt, rustfmt_skip)]
extern crate ordered_float;
extern crate thrift;
extern crate try_from;
use ordered_float::OrderedFloat;
use std::cell::RefCell;
use std::collections::{BTreeMap, BTreeSet};
use std::convert::From;
use std::default::Default;
use std::error::Error;
use std::fmt;
use std::fmt::{Display, Formatter};
use std::rc::Rc;
use try_from::TryFrom;
use thrift::{ApplicationError, ApplicationErrorKind, ProtocolError, ProtocolErrorKind, TThriftClient};
use thrift::protocol::{TFieldIdentifier, TListIdentifier, TMapIdentifier, TMessageIdentifier, TMessageType, TInputProtocol, TOutputProtocol, TSetIdentifier, TStructIdentifier, TType};
use thrift::protocol::field_id;
use thrift::protocol::verify_expected_message_type;
use thrift::protocol::verify_expected_sequence_number;
use thrift::protocol::verify_expected_service_call;
use thrift::protocol::verify_required_field_exists;
use thrift::server::TProcessor;
#[derive(Clone, Debug, Eq, Hash, Ord, PartialEq, PartialOrd)]
pub struct SubscribeRequest {
pub topic: Option<String>,
pub appid: Option<String>,
pub msgname: Option<String>,
}
impl SubscribeRequest {
pub fn new<F1, F2, F3>(topic: F1, appid: F2, msgname: F3) -> SubscribeRequest where F1: Into<Option<String>>, F2: Into<Option<String>>, F3: Into<Option<String>> {
SubscribeRequest {
topic: topic.into(),
appid: appid.into(),
msgname: msgname.into(),
}
}
pub fn read_from_in_protocol(i_prot: &mut TInputProtocol) -> thrift::Result<SubscribeRequest> {
i_prot.read_struct_begin()?;
let mut f_1: Option<String> = Some("".to_owned());
let mut f_2: Option<String> = Some("".to_owned());
let mut f_3: Option<String> = Some("".to_owned());
loop {
let field_ident = i_prot.read_field_begin()?;
if field_ident.field_type == TType::Stop {
break;
}
let field_id = field_id(&field_ident)?;
match field_id {
1 => {
let val = i_prot.read_string()?;
f_1 = Some(val);
},
2 => {
let val = i_prot.read_string()?;
f_2 = Some(val);
},
3 => {
let val = i_prot.read_string()?;
f_3 = Some(val);
},
_ => {
i_prot.skip(field_ident.field_type)?;
},
};
i_prot.read_field_end()?;
}
i_prot.read_struct_end()?;
let ret = SubscribeRequest {
topic: f_1,
appid: f_2,
msgname: f_3,
};
Ok(ret)
}
pub fn write_to_out_protocol(&self, o_prot: &mut TOutputProtocol) -> thrift::Result<()> {
let struct_ident = TStructIdentifier::new("SubscribeRequest");
o_prot.write_struct_begin(&struct_ident)?;
if let Some(ref fld_var) = self.topic {
o_prot.write_field_begin(&TFieldIdentifier::new("topic", TType::String, 1))?;
o_prot.write_string(fld_var)?;
o_prot.write_field_end()?;
()
} else {
()
}
if let Some(ref fld_var) = self.appid {
o_prot.write_field_begin(&TFieldIdentifier::new("appid", TType::String, 2))?;
o_prot.write_string(fld_var)?;
o_prot.write_field_end()?;
()
} else {
()
}
if let Some(ref fld_var) = self.msgname {
o_prot.write_field_begin(&TFieldIdentifier::new("msgname", TType::String, 3))?;
o_prot.write_string(fld_var)?;
o_prot.write_field_end()?;
()
} else {
()
}
o_prot.write_field_stop()?;
o_prot.write_struct_end()
}
}
impl Default for SubscribeRequest {
fn default() -> Self {
SubscribeRequest{
topic: Some("".to_owned()),
appid: Some("".to_owned()),
msgname: Some("".to_owned()),
}
}
}
#[derive(Clone, Debug, Eq, Hash, Ord, PartialEq, PartialOrd)]
pub struct SubscribeReply {
pub success: Option<bool>,
pub topic: Option<String>,
pub appid: Option<String>,
pub msgname: Option<String>,
}
impl SubscribeReply {
pub fn new<F1, F2, F3, F4>(success: F1, topic: F2, appid: F3, msgname: F4) -> SubscribeReply where F1: Into<Option<bool>>, F2: Into<Option<String>>, F3: Into<Option<String>>, F4: Into<Option<String>> {
SubscribeReply {
success: success.into(),
topic: topic.into(),
appid: appid.into(),
msgname: msgname.into(),
}
}
pub fn read_from_in_protocol(i_prot: &mut TInputProtocol) -> thrift::Result<SubscribeReply> {
i_prot.read_struct_begin()?;
let mut f_1: Option<bool> = Some(false);
let mut f_2: Option<String> = Some("".to_owned());
let mut f_3: Option<String> = Some("".to_owned());
let mut f_4: Option<String> = Some("".to_owned());
loop {
let field_ident = i_prot.read_field_begin()?;
if field_ident.field_type == TType::Stop {
break;
}
let field_id = field_id(&field_ident)?;
match field_id {
1 => {
let val = i_prot.read_bool()?;
f_1 = Some(val);
},
2 => {
let val = i_prot.read_string()?;
f_2 = Some(val);
},
3 => {
let val = i_prot.read_string()?;
f_3 = Some(val);
},
4 => {
let val = i_prot.read_string()?;
f_4 = Some(val);
},
_ => {
i_prot.skip(field_ident.field_type)?;
},
};
i_prot.read_field_end()?;
}
i_prot.read_struct_end()?;
let ret = SubscribeReply {
success: f_1,
topic: f_2,
appid: f_3,
msgname: f_4,
};
Ok(ret)
}
pub fn write_to_out_protocol(&self, o_prot: &mut TOutputProtocol) -> thrift::Result<()> {
let struct_ident = TStructIdentifier::new("SubscribeReply");
o_prot.write_struct_begin(&struct_ident)?;
if let Some(fld_var) = self.success {
o_prot.write_field_begin(&TFieldIdentifier::new("success", TType::Bool, 1))?;
o_prot.write_bool(fld_var)?;
o_prot.write_field_end()?;
()
} else {
()
}
if let Some(ref fld_var) = self.topic {
o_prot.write_field_begin(&TFieldIdentifier::new("topic", TType::String, 2))?;
o_prot.write_string(fld_var)?;
o_prot.write_field_end()?;
()
} else {
()
}
if let Some(ref fld_var) = self.appid {
o_prot.write_field_begin(&TFieldIdentifier::new("appid", TType::String, 3))?;
o_prot.write_string(fld_var)?;
o_prot.write_field_end()?;
()
} else {
()
}
if let Some(ref fld_var) = self.msgname {
o_prot.write_field_begin(&TFieldIdentifier::new("msgname", TType::String, 4))?;
o_prot.write_string(fld_var)?;
o_prot.write_field_end()?;
()
} else {
()
}
o_prot.write_field_stop()?;
o_prot.write_struct_end()
}
}
impl Default for SubscribeReply {
fn default() -> Self {
SubscribeReply{
success: Some(false),
topic: Some("".to_owned()),
appid: Some("".to_owned()),
msgname: Some("".to_owned()),
}
}
}