[−][src]Struct pulsar::message::proto::BaseCommand
Fields
type_: i32
connect: Option<CommandConnect>
connected: Option<CommandConnected>
subscribe: Option<CommandSubscribe>
producer: Option<CommandProducer>
send: Option<CommandSend>
send_receipt: Option<CommandSendReceipt>
send_error: Option<CommandSendError>
message: Option<CommandMessage>
ack: Option<CommandAck>
flow: Option<CommandFlow>
unsubscribe: Option<CommandUnsubscribe>
success: Option<CommandSuccess>
error: Option<CommandError>
close_producer: Option<CommandCloseProducer>
close_consumer: Option<CommandCloseConsumer>
producer_success: Option<CommandProducerSuccess>
ping: Option<CommandPing>
pong: Option<CommandPong>
redeliver_unacknowledged_messages: Option<CommandRedeliverUnacknowledgedMessages>
partition_metadata: Option<CommandPartitionedTopicMetadata>
partition_metadata_response: Option<CommandPartitionedTopicMetadataResponse>
lookup_topic: Option<CommandLookupTopic>
lookup_topic_response: Option<CommandLookupTopicResponse>
consumer_stats: Option<CommandConsumerStats>
consumer_stats_response: Option<CommandConsumerStatsResponse>
reached_end_of_topic: Option<CommandReachedEndOfTopic>
seek: Option<CommandSeek>
get_last_message_id: Option<CommandGetLastMessageId>
get_last_message_id_response: Option<CommandGetLastMessageIdResponse>
active_consumer_change: Option<CommandActiveConsumerChange>
get_topics_of_namespace: Option<CommandGetTopicsOfNamespace>
get_topics_of_namespace_response: Option<CommandGetTopicsOfNamespaceResponse>
get_schema: Option<CommandGetSchema>
get_schema_response: Option<CommandGetSchemaResponse>
Implementations
impl BaseCommand
[src]
pub fn type_(&self) -> Type
[src]
Returns the enum value of type_
, or the default if the field is set to an invalid enum value.
pub fn set_type_(&mut self, value: Type)
[src]
Sets type_
to the provided enum value.
Trait Implementations
impl Clone for BaseCommand
[src]
fn clone(&self) -> BaseCommand
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for BaseCommand
[src]
impl Default for BaseCommand
[src]
fn default() -> BaseCommand
[src]
impl Message for BaseCommand
[src]
fn encode_raw<B>(&self, buf: &mut B) where
B: BufMut,
[src]
B: BufMut,
fn merge_field<B>(
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
[src]
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
fn encoded_len(&self) -> usize
[src]
fn clear(&mut self)
[src]
fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
[src]
B: BufMut,
fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
[src]
B: BufMut,
fn decode<B>(buf: B) -> Result<Self, DecodeError> where
B: Buf,
Self: Default,
[src]
B: Buf,
Self: Default,
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
B: Buf,
Self: Default,
[src]
B: Buf,
Self: Default,
fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
[src]
B: Buf,
fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
[src]
B: Buf,
impl PartialEq<BaseCommand> for BaseCommand
[src]
fn eq(&self, other: &BaseCommand) -> bool
[src]
fn ne(&self, other: &BaseCommand) -> bool
[src]
impl StructuralPartialEq for BaseCommand
[src]
Auto Trait Implementations
impl RefUnwindSafe for BaseCommand
impl Send for BaseCommand
impl Sync for BaseCommand
impl Unpin for BaseCommand
impl UnwindSafe for BaseCommand
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,