pub struct BaseCommand {Show 53 fields
pub connect: SingularPtrField<CommandConnect>,
pub connected: SingularPtrField<CommandConnected>,
pub subscribe: SingularPtrField<CommandSubscribe>,
pub producer: SingularPtrField<CommandProducer>,
pub send: SingularPtrField<CommandSend>,
pub send_receipt: SingularPtrField<CommandSendReceipt>,
pub send_error: SingularPtrField<CommandSendError>,
pub message: SingularPtrField<CommandMessage>,
pub ack: SingularPtrField<CommandAck>,
pub flow: SingularPtrField<CommandFlow>,
pub unsubscribe: SingularPtrField<CommandUnsubscribe>,
pub success: SingularPtrField<CommandSuccess>,
pub error: SingularPtrField<CommandError>,
pub close_producer: SingularPtrField<CommandCloseProducer>,
pub close_consumer: SingularPtrField<CommandCloseConsumer>,
pub producer_success: SingularPtrField<CommandProducerSuccess>,
pub ping: SingularPtrField<CommandPing>,
pub pong: SingularPtrField<CommandPong>,
pub redeliverUnacknowledgedMessages: SingularPtrField<CommandRedeliverUnacknowledgedMessages>,
pub partitionMetadata: SingularPtrField<CommandPartitionedTopicMetadata>,
pub partitionMetadataResponse: SingularPtrField<CommandPartitionedTopicMetadataResponse>,
pub lookupTopic: SingularPtrField<CommandLookupTopic>,
pub lookupTopicResponse: SingularPtrField<CommandLookupTopicResponse>,
pub consumerStats: SingularPtrField<CommandConsumerStats>,
pub consumerStatsResponse: SingularPtrField<CommandConsumerStatsResponse>,
pub reachedEndOfTopic: SingularPtrField<CommandReachedEndOfTopic>,
pub seek: SingularPtrField<CommandSeek>,
pub getLastMessageId: SingularPtrField<CommandGetLastMessageId>,
pub getLastMessageIdResponse: SingularPtrField<CommandGetLastMessageIdResponse>,
pub active_consumer_change: SingularPtrField<CommandActiveConsumerChange>,
pub getTopicsOfNamespace: SingularPtrField<CommandGetTopicsOfNamespace>,
pub getTopicsOfNamespaceResponse: SingularPtrField<CommandGetTopicsOfNamespaceResponse>,
pub getSchema: SingularPtrField<CommandGetSchema>,
pub getSchemaResponse: SingularPtrField<CommandGetSchemaResponse>,
pub authChallenge: SingularPtrField<CommandAuthChallenge>,
pub authResponse: SingularPtrField<CommandAuthResponse>,
pub ackResponse: SingularPtrField<CommandAckResponse>,
pub getOrCreateSchema: SingularPtrField<CommandGetOrCreateSchema>,
pub getOrCreateSchemaResponse: SingularPtrField<CommandGetOrCreateSchemaResponse>,
pub newTxn: SingularPtrField<CommandNewTxn>,
pub newTxnResponse: SingularPtrField<CommandNewTxnResponse>,
pub addPartitionToTxn: SingularPtrField<CommandAddPartitionToTxn>,
pub addPartitionToTxnResponse: SingularPtrField<CommandAddPartitionToTxnResponse>,
pub addSubscriptionToTxn: SingularPtrField<CommandAddSubscriptionToTxn>,
pub addSubscriptionToTxnResponse: SingularPtrField<CommandAddSubscriptionToTxnResponse>,
pub endTxn: SingularPtrField<CommandEndTxn>,
pub endTxnResponse: SingularPtrField<CommandEndTxnResponse>,
pub endTxnOnPartition: SingularPtrField<CommandEndTxnOnPartition>,
pub endTxnOnPartitionResponse: SingularPtrField<CommandEndTxnOnPartitionResponse>,
pub endTxnOnSubscription: SingularPtrField<CommandEndTxnOnSubscription>,
pub endTxnOnSubscriptionResponse: SingularPtrField<CommandEndTxnOnSubscriptionResponse>,
pub unknown_fields: UnknownFields,
pub cached_size: CachedSize,
/* private fields */
}Fields§
§connect: SingularPtrField<CommandConnect>§connected: SingularPtrField<CommandConnected>§subscribe: SingularPtrField<CommandSubscribe>§producer: SingularPtrField<CommandProducer>§send: SingularPtrField<CommandSend>§send_receipt: SingularPtrField<CommandSendReceipt>§send_error: SingularPtrField<CommandSendError>§message: SingularPtrField<CommandMessage>§ack: SingularPtrField<CommandAck>§flow: SingularPtrField<CommandFlow>§unsubscribe: SingularPtrField<CommandUnsubscribe>§success: SingularPtrField<CommandSuccess>§error: SingularPtrField<CommandError>§close_producer: SingularPtrField<CommandCloseProducer>§close_consumer: SingularPtrField<CommandCloseConsumer>§producer_success: SingularPtrField<CommandProducerSuccess>§ping: SingularPtrField<CommandPing>§pong: SingularPtrField<CommandPong>§redeliverUnacknowledgedMessages: SingularPtrField<CommandRedeliverUnacknowledgedMessages>§partitionMetadata: SingularPtrField<CommandPartitionedTopicMetadata>§partitionMetadataResponse: SingularPtrField<CommandPartitionedTopicMetadataResponse>§lookupTopic: SingularPtrField<CommandLookupTopic>§lookupTopicResponse: SingularPtrField<CommandLookupTopicResponse>§consumerStats: SingularPtrField<CommandConsumerStats>§consumerStatsResponse: SingularPtrField<CommandConsumerStatsResponse>§reachedEndOfTopic: SingularPtrField<CommandReachedEndOfTopic>§seek: SingularPtrField<CommandSeek>§getLastMessageId: SingularPtrField<CommandGetLastMessageId>§getLastMessageIdResponse: SingularPtrField<CommandGetLastMessageIdResponse>§active_consumer_change: SingularPtrField<CommandActiveConsumerChange>§getTopicsOfNamespace: SingularPtrField<CommandGetTopicsOfNamespace>§getTopicsOfNamespaceResponse: SingularPtrField<CommandGetTopicsOfNamespaceResponse>§getSchema: SingularPtrField<CommandGetSchema>§getSchemaResponse: SingularPtrField<CommandGetSchemaResponse>§authChallenge: SingularPtrField<CommandAuthChallenge>§authResponse: SingularPtrField<CommandAuthResponse>§ackResponse: SingularPtrField<CommandAckResponse>§getOrCreateSchema: SingularPtrField<CommandGetOrCreateSchema>§getOrCreateSchemaResponse: SingularPtrField<CommandGetOrCreateSchemaResponse>§newTxn: SingularPtrField<CommandNewTxn>§newTxnResponse: SingularPtrField<CommandNewTxnResponse>§addPartitionToTxn: SingularPtrField<CommandAddPartitionToTxn>§addPartitionToTxnResponse: SingularPtrField<CommandAddPartitionToTxnResponse>§addSubscriptionToTxn: SingularPtrField<CommandAddSubscriptionToTxn>§addSubscriptionToTxnResponse: SingularPtrField<CommandAddSubscriptionToTxnResponse>§endTxn: SingularPtrField<CommandEndTxn>§endTxnResponse: SingularPtrField<CommandEndTxnResponse>§endTxnOnPartition: SingularPtrField<CommandEndTxnOnPartition>§endTxnOnPartitionResponse: SingularPtrField<CommandEndTxnOnPartitionResponse>§endTxnOnSubscription: SingularPtrField<CommandEndTxnOnSubscription>§endTxnOnSubscriptionResponse: SingularPtrField<CommandEndTxnOnSubscriptionResponse>§unknown_fields: UnknownFields§cached_size: CachedSizeImplementations§
Source§impl BaseCommand
impl BaseCommand
pub fn new() -> BaseCommand
pub fn get_field_type(&self) -> BaseCommand_Type
pub fn clear_field_type(&mut self)
pub fn has_field_type(&self) -> bool
pub fn set_field_type(&mut self, v: BaseCommand_Type)
pub fn get_connect(&self) -> &CommandConnect
pub fn clear_connect(&mut self)
pub fn has_connect(&self) -> bool
pub fn set_connect(&mut self, v: CommandConnect)
pub fn mut_connect(&mut self) -> &mut CommandConnect
pub fn take_connect(&mut self) -> CommandConnect
pub fn get_connected(&self) -> &CommandConnected
pub fn clear_connected(&mut self)
pub fn has_connected(&self) -> bool
pub fn set_connected(&mut self, v: CommandConnected)
pub fn mut_connected(&mut self) -> &mut CommandConnected
pub fn take_connected(&mut self) -> CommandConnected
pub fn get_subscribe(&self) -> &CommandSubscribe
pub fn clear_subscribe(&mut self)
pub fn has_subscribe(&self) -> bool
pub fn set_subscribe(&mut self, v: CommandSubscribe)
pub fn mut_subscribe(&mut self) -> &mut CommandSubscribe
pub fn take_subscribe(&mut self) -> CommandSubscribe
pub fn get_producer(&self) -> &CommandProducer
pub fn clear_producer(&mut self)
pub fn has_producer(&self) -> bool
pub fn set_producer(&mut self, v: CommandProducer)
pub fn mut_producer(&mut self) -> &mut CommandProducer
pub fn take_producer(&mut self) -> CommandProducer
pub fn get_send(&self) -> &CommandSend
pub fn clear_send(&mut self)
pub fn has_send(&self) -> bool
pub fn set_send(&mut self, v: CommandSend)
pub fn mut_send(&mut self) -> &mut CommandSend
pub fn take_send(&mut self) -> CommandSend
pub fn get_send_receipt(&self) -> &CommandSendReceipt
pub fn clear_send_receipt(&mut self)
pub fn has_send_receipt(&self) -> bool
pub fn set_send_receipt(&mut self, v: CommandSendReceipt)
pub fn mut_send_receipt(&mut self) -> &mut CommandSendReceipt
pub fn take_send_receipt(&mut self) -> CommandSendReceipt
pub fn get_send_error(&self) -> &CommandSendError
pub fn clear_send_error(&mut self)
pub fn has_send_error(&self) -> bool
pub fn set_send_error(&mut self, v: CommandSendError)
pub fn mut_send_error(&mut self) -> &mut CommandSendError
pub fn take_send_error(&mut self) -> CommandSendError
pub fn get_message(&self) -> &CommandMessage
pub fn clear_message(&mut self)
pub fn has_message(&self) -> bool
pub fn set_message(&mut self, v: CommandMessage)
pub fn mut_message(&mut self) -> &mut CommandMessage
pub fn take_message(&mut self) -> CommandMessage
pub fn get_ack(&self) -> &CommandAck
pub fn clear_ack(&mut self)
pub fn has_ack(&self) -> bool
pub fn set_ack(&mut self, v: CommandAck)
pub fn mut_ack(&mut self) -> &mut CommandAck
pub fn take_ack(&mut self) -> CommandAck
pub fn get_flow(&self) -> &CommandFlow
pub fn clear_flow(&mut self)
pub fn has_flow(&self) -> bool
pub fn set_flow(&mut self, v: CommandFlow)
pub fn mut_flow(&mut self) -> &mut CommandFlow
pub fn take_flow(&mut self) -> CommandFlow
pub fn get_unsubscribe(&self) -> &CommandUnsubscribe
pub fn clear_unsubscribe(&mut self)
pub fn has_unsubscribe(&self) -> bool
pub fn set_unsubscribe(&mut self, v: CommandUnsubscribe)
pub fn mut_unsubscribe(&mut self) -> &mut CommandUnsubscribe
pub fn take_unsubscribe(&mut self) -> CommandUnsubscribe
pub fn get_success(&self) -> &CommandSuccess
pub fn clear_success(&mut self)
pub fn has_success(&self) -> bool
pub fn set_success(&mut self, v: CommandSuccess)
pub fn mut_success(&mut self) -> &mut CommandSuccess
pub fn take_success(&mut self) -> CommandSuccess
pub fn get_error(&self) -> &CommandError
pub fn clear_error(&mut self)
pub fn has_error(&self) -> bool
pub fn set_error(&mut self, v: CommandError)
pub fn mut_error(&mut self) -> &mut CommandError
pub fn take_error(&mut self) -> CommandError
pub fn get_close_producer(&self) -> &CommandCloseProducer
pub fn clear_close_producer(&mut self)
pub fn has_close_producer(&self) -> bool
pub fn set_close_producer(&mut self, v: CommandCloseProducer)
pub fn mut_close_producer(&mut self) -> &mut CommandCloseProducer
pub fn take_close_producer(&mut self) -> CommandCloseProducer
pub fn get_close_consumer(&self) -> &CommandCloseConsumer
pub fn clear_close_consumer(&mut self)
pub fn has_close_consumer(&self) -> bool
pub fn set_close_consumer(&mut self, v: CommandCloseConsumer)
pub fn mut_close_consumer(&mut self) -> &mut CommandCloseConsumer
pub fn take_close_consumer(&mut self) -> CommandCloseConsumer
pub fn get_producer_success(&self) -> &CommandProducerSuccess
pub fn clear_producer_success(&mut self)
pub fn has_producer_success(&self) -> bool
pub fn set_producer_success(&mut self, v: CommandProducerSuccess)
pub fn mut_producer_success(&mut self) -> &mut CommandProducerSuccess
pub fn take_producer_success(&mut self) -> CommandProducerSuccess
pub fn get_ping(&self) -> &CommandPing
pub fn clear_ping(&mut self)
pub fn has_ping(&self) -> bool
pub fn set_ping(&mut self, v: CommandPing)
pub fn mut_ping(&mut self) -> &mut CommandPing
pub fn take_ping(&mut self) -> CommandPing
pub fn get_pong(&self) -> &CommandPong
pub fn clear_pong(&mut self)
pub fn has_pong(&self) -> bool
pub fn set_pong(&mut self, v: CommandPong)
pub fn mut_pong(&mut self) -> &mut CommandPong
pub fn take_pong(&mut self) -> CommandPong
pub fn get_redeliverUnacknowledgedMessages( &self, ) -> &CommandRedeliverUnacknowledgedMessages
pub fn clear_redeliverUnacknowledgedMessages(&mut self)
pub fn has_redeliverUnacknowledgedMessages(&self) -> bool
pub fn set_redeliverUnacknowledgedMessages( &mut self, v: CommandRedeliverUnacknowledgedMessages, )
pub fn mut_redeliverUnacknowledgedMessages( &mut self, ) -> &mut CommandRedeliverUnacknowledgedMessages
pub fn take_redeliverUnacknowledgedMessages( &mut self, ) -> CommandRedeliverUnacknowledgedMessages
pub fn get_partitionMetadata(&self) -> &CommandPartitionedTopicMetadata
pub fn clear_partitionMetadata(&mut self)
pub fn has_partitionMetadata(&self) -> bool
pub fn set_partitionMetadata(&mut self, v: CommandPartitionedTopicMetadata)
pub fn mut_partitionMetadata(&mut self) -> &mut CommandPartitionedTopicMetadata
pub fn take_partitionMetadata(&mut self) -> CommandPartitionedTopicMetadata
pub fn get_partitionMetadataResponse( &self, ) -> &CommandPartitionedTopicMetadataResponse
pub fn clear_partitionMetadataResponse(&mut self)
pub fn has_partitionMetadataResponse(&self) -> bool
pub fn set_partitionMetadataResponse( &mut self, v: CommandPartitionedTopicMetadataResponse, )
pub fn mut_partitionMetadataResponse( &mut self, ) -> &mut CommandPartitionedTopicMetadataResponse
pub fn take_partitionMetadataResponse( &mut self, ) -> CommandPartitionedTopicMetadataResponse
pub fn get_lookupTopic(&self) -> &CommandLookupTopic
pub fn clear_lookupTopic(&mut self)
pub fn has_lookupTopic(&self) -> bool
pub fn set_lookupTopic(&mut self, v: CommandLookupTopic)
pub fn mut_lookupTopic(&mut self) -> &mut CommandLookupTopic
pub fn take_lookupTopic(&mut self) -> CommandLookupTopic
pub fn get_lookupTopicResponse(&self) -> &CommandLookupTopicResponse
pub fn clear_lookupTopicResponse(&mut self)
pub fn has_lookupTopicResponse(&self) -> bool
pub fn set_lookupTopicResponse(&mut self, v: CommandLookupTopicResponse)
pub fn mut_lookupTopicResponse(&mut self) -> &mut CommandLookupTopicResponse
pub fn take_lookupTopicResponse(&mut self) -> CommandLookupTopicResponse
pub fn get_consumerStats(&self) -> &CommandConsumerStats
pub fn clear_consumerStats(&mut self)
pub fn has_consumerStats(&self) -> bool
pub fn set_consumerStats(&mut self, v: CommandConsumerStats)
pub fn mut_consumerStats(&mut self) -> &mut CommandConsumerStats
pub fn take_consumerStats(&mut self) -> CommandConsumerStats
pub fn get_consumerStatsResponse(&self) -> &CommandConsumerStatsResponse
pub fn clear_consumerStatsResponse(&mut self)
pub fn has_consumerStatsResponse(&self) -> bool
pub fn set_consumerStatsResponse(&mut self, v: CommandConsumerStatsResponse)
pub fn mut_consumerStatsResponse(&mut self) -> &mut CommandConsumerStatsResponse
pub fn take_consumerStatsResponse(&mut self) -> CommandConsumerStatsResponse
pub fn get_reachedEndOfTopic(&self) -> &CommandReachedEndOfTopic
pub fn clear_reachedEndOfTopic(&mut self)
pub fn has_reachedEndOfTopic(&self) -> bool
pub fn set_reachedEndOfTopic(&mut self, v: CommandReachedEndOfTopic)
pub fn mut_reachedEndOfTopic(&mut self) -> &mut CommandReachedEndOfTopic
pub fn take_reachedEndOfTopic(&mut self) -> CommandReachedEndOfTopic
pub fn get_seek(&self) -> &CommandSeek
pub fn clear_seek(&mut self)
pub fn has_seek(&self) -> bool
pub fn set_seek(&mut self, v: CommandSeek)
pub fn mut_seek(&mut self) -> &mut CommandSeek
pub fn take_seek(&mut self) -> CommandSeek
pub fn get_getLastMessageId(&self) -> &CommandGetLastMessageId
pub fn clear_getLastMessageId(&mut self)
pub fn has_getLastMessageId(&self) -> bool
pub fn set_getLastMessageId(&mut self, v: CommandGetLastMessageId)
pub fn mut_getLastMessageId(&mut self) -> &mut CommandGetLastMessageId
pub fn take_getLastMessageId(&mut self) -> CommandGetLastMessageId
pub fn get_getLastMessageIdResponse(&self) -> &CommandGetLastMessageIdResponse
pub fn clear_getLastMessageIdResponse(&mut self)
pub fn has_getLastMessageIdResponse(&self) -> bool
pub fn set_getLastMessageIdResponse( &mut self, v: CommandGetLastMessageIdResponse, )
pub fn mut_getLastMessageIdResponse( &mut self, ) -> &mut CommandGetLastMessageIdResponse
pub fn take_getLastMessageIdResponse( &mut self, ) -> CommandGetLastMessageIdResponse
pub fn get_active_consumer_change(&self) -> &CommandActiveConsumerChange
pub fn clear_active_consumer_change(&mut self)
pub fn has_active_consumer_change(&self) -> bool
pub fn set_active_consumer_change(&mut self, v: CommandActiveConsumerChange)
pub fn mut_active_consumer_change(&mut self) -> &mut CommandActiveConsumerChange
pub fn take_active_consumer_change(&mut self) -> CommandActiveConsumerChange
pub fn get_getTopicsOfNamespace(&self) -> &CommandGetTopicsOfNamespace
pub fn clear_getTopicsOfNamespace(&mut self)
pub fn has_getTopicsOfNamespace(&self) -> bool
pub fn set_getTopicsOfNamespace(&mut self, v: CommandGetTopicsOfNamespace)
pub fn mut_getTopicsOfNamespace(&mut self) -> &mut CommandGetTopicsOfNamespace
pub fn take_getTopicsOfNamespace(&mut self) -> CommandGetTopicsOfNamespace
pub fn get_getTopicsOfNamespaceResponse( &self, ) -> &CommandGetTopicsOfNamespaceResponse
pub fn clear_getTopicsOfNamespaceResponse(&mut self)
pub fn has_getTopicsOfNamespaceResponse(&self) -> bool
pub fn set_getTopicsOfNamespaceResponse( &mut self, v: CommandGetTopicsOfNamespaceResponse, )
pub fn mut_getTopicsOfNamespaceResponse( &mut self, ) -> &mut CommandGetTopicsOfNamespaceResponse
pub fn take_getTopicsOfNamespaceResponse( &mut self, ) -> CommandGetTopicsOfNamespaceResponse
pub fn get_getSchema(&self) -> &CommandGetSchema
pub fn clear_getSchema(&mut self)
pub fn has_getSchema(&self) -> bool
pub fn set_getSchema(&mut self, v: CommandGetSchema)
pub fn mut_getSchema(&mut self) -> &mut CommandGetSchema
pub fn take_getSchema(&mut self) -> CommandGetSchema
pub fn get_getSchemaResponse(&self) -> &CommandGetSchemaResponse
pub fn clear_getSchemaResponse(&mut self)
pub fn has_getSchemaResponse(&self) -> bool
pub fn set_getSchemaResponse(&mut self, v: CommandGetSchemaResponse)
pub fn mut_getSchemaResponse(&mut self) -> &mut CommandGetSchemaResponse
pub fn take_getSchemaResponse(&mut self) -> CommandGetSchemaResponse
pub fn get_authChallenge(&self) -> &CommandAuthChallenge
pub fn clear_authChallenge(&mut self)
pub fn has_authChallenge(&self) -> bool
pub fn set_authChallenge(&mut self, v: CommandAuthChallenge)
pub fn mut_authChallenge(&mut self) -> &mut CommandAuthChallenge
pub fn take_authChallenge(&mut self) -> CommandAuthChallenge
pub fn get_authResponse(&self) -> &CommandAuthResponse
pub fn clear_authResponse(&mut self)
pub fn has_authResponse(&self) -> bool
pub fn set_authResponse(&mut self, v: CommandAuthResponse)
pub fn mut_authResponse(&mut self) -> &mut CommandAuthResponse
pub fn take_authResponse(&mut self) -> CommandAuthResponse
pub fn get_ackResponse(&self) -> &CommandAckResponse
pub fn clear_ackResponse(&mut self)
pub fn has_ackResponse(&self) -> bool
pub fn set_ackResponse(&mut self, v: CommandAckResponse)
pub fn mut_ackResponse(&mut self) -> &mut CommandAckResponse
pub fn take_ackResponse(&mut self) -> CommandAckResponse
pub fn get_getOrCreateSchema(&self) -> &CommandGetOrCreateSchema
pub fn clear_getOrCreateSchema(&mut self)
pub fn has_getOrCreateSchema(&self) -> bool
pub fn set_getOrCreateSchema(&mut self, v: CommandGetOrCreateSchema)
pub fn mut_getOrCreateSchema(&mut self) -> &mut CommandGetOrCreateSchema
pub fn take_getOrCreateSchema(&mut self) -> CommandGetOrCreateSchema
pub fn get_getOrCreateSchemaResponse(&self) -> &CommandGetOrCreateSchemaResponse
pub fn clear_getOrCreateSchemaResponse(&mut self)
pub fn has_getOrCreateSchemaResponse(&self) -> bool
pub fn set_getOrCreateSchemaResponse( &mut self, v: CommandGetOrCreateSchemaResponse, )
pub fn mut_getOrCreateSchemaResponse( &mut self, ) -> &mut CommandGetOrCreateSchemaResponse
pub fn take_getOrCreateSchemaResponse( &mut self, ) -> CommandGetOrCreateSchemaResponse
pub fn get_newTxn(&self) -> &CommandNewTxn
pub fn clear_newTxn(&mut self)
pub fn has_newTxn(&self) -> bool
pub fn set_newTxn(&mut self, v: CommandNewTxn)
pub fn mut_newTxn(&mut self) -> &mut CommandNewTxn
pub fn take_newTxn(&mut self) -> CommandNewTxn
pub fn get_newTxnResponse(&self) -> &CommandNewTxnResponse
pub fn clear_newTxnResponse(&mut self)
pub fn has_newTxnResponse(&self) -> bool
pub fn set_newTxnResponse(&mut self, v: CommandNewTxnResponse)
pub fn mut_newTxnResponse(&mut self) -> &mut CommandNewTxnResponse
pub fn take_newTxnResponse(&mut self) -> CommandNewTxnResponse
pub fn get_addPartitionToTxn(&self) -> &CommandAddPartitionToTxn
pub fn clear_addPartitionToTxn(&mut self)
pub fn has_addPartitionToTxn(&self) -> bool
pub fn set_addPartitionToTxn(&mut self, v: CommandAddPartitionToTxn)
pub fn mut_addPartitionToTxn(&mut self) -> &mut CommandAddPartitionToTxn
pub fn take_addPartitionToTxn(&mut self) -> CommandAddPartitionToTxn
pub fn get_addPartitionToTxnResponse(&self) -> &CommandAddPartitionToTxnResponse
pub fn clear_addPartitionToTxnResponse(&mut self)
pub fn has_addPartitionToTxnResponse(&self) -> bool
pub fn set_addPartitionToTxnResponse( &mut self, v: CommandAddPartitionToTxnResponse, )
pub fn mut_addPartitionToTxnResponse( &mut self, ) -> &mut CommandAddPartitionToTxnResponse
pub fn take_addPartitionToTxnResponse( &mut self, ) -> CommandAddPartitionToTxnResponse
pub fn get_addSubscriptionToTxn(&self) -> &CommandAddSubscriptionToTxn
pub fn clear_addSubscriptionToTxn(&mut self)
pub fn has_addSubscriptionToTxn(&self) -> bool
pub fn set_addSubscriptionToTxn(&mut self, v: CommandAddSubscriptionToTxn)
pub fn mut_addSubscriptionToTxn(&mut self) -> &mut CommandAddSubscriptionToTxn
pub fn take_addSubscriptionToTxn(&mut self) -> CommandAddSubscriptionToTxn
pub fn get_addSubscriptionToTxnResponse( &self, ) -> &CommandAddSubscriptionToTxnResponse
pub fn clear_addSubscriptionToTxnResponse(&mut self)
pub fn has_addSubscriptionToTxnResponse(&self) -> bool
pub fn set_addSubscriptionToTxnResponse( &mut self, v: CommandAddSubscriptionToTxnResponse, )
pub fn mut_addSubscriptionToTxnResponse( &mut self, ) -> &mut CommandAddSubscriptionToTxnResponse
pub fn take_addSubscriptionToTxnResponse( &mut self, ) -> CommandAddSubscriptionToTxnResponse
pub fn get_endTxn(&self) -> &CommandEndTxn
pub fn clear_endTxn(&mut self)
pub fn has_endTxn(&self) -> bool
pub fn set_endTxn(&mut self, v: CommandEndTxn)
pub fn mut_endTxn(&mut self) -> &mut CommandEndTxn
pub fn take_endTxn(&mut self) -> CommandEndTxn
pub fn get_endTxnResponse(&self) -> &CommandEndTxnResponse
pub fn clear_endTxnResponse(&mut self)
pub fn has_endTxnResponse(&self) -> bool
pub fn set_endTxnResponse(&mut self, v: CommandEndTxnResponse)
pub fn mut_endTxnResponse(&mut self) -> &mut CommandEndTxnResponse
pub fn take_endTxnResponse(&mut self) -> CommandEndTxnResponse
pub fn get_endTxnOnPartition(&self) -> &CommandEndTxnOnPartition
pub fn clear_endTxnOnPartition(&mut self)
pub fn has_endTxnOnPartition(&self) -> bool
pub fn set_endTxnOnPartition(&mut self, v: CommandEndTxnOnPartition)
pub fn mut_endTxnOnPartition(&mut self) -> &mut CommandEndTxnOnPartition
pub fn take_endTxnOnPartition(&mut self) -> CommandEndTxnOnPartition
pub fn get_endTxnOnPartitionResponse(&self) -> &CommandEndTxnOnPartitionResponse
pub fn clear_endTxnOnPartitionResponse(&mut self)
pub fn has_endTxnOnPartitionResponse(&self) -> bool
pub fn set_endTxnOnPartitionResponse( &mut self, v: CommandEndTxnOnPartitionResponse, )
pub fn mut_endTxnOnPartitionResponse( &mut self, ) -> &mut CommandEndTxnOnPartitionResponse
pub fn take_endTxnOnPartitionResponse( &mut self, ) -> CommandEndTxnOnPartitionResponse
pub fn get_endTxnOnSubscription(&self) -> &CommandEndTxnOnSubscription
pub fn clear_endTxnOnSubscription(&mut self)
pub fn has_endTxnOnSubscription(&self) -> bool
pub fn set_endTxnOnSubscription(&mut self, v: CommandEndTxnOnSubscription)
pub fn mut_endTxnOnSubscription(&mut self) -> &mut CommandEndTxnOnSubscription
pub fn take_endTxnOnSubscription(&mut self) -> CommandEndTxnOnSubscription
pub fn get_endTxnOnSubscriptionResponse( &self, ) -> &CommandEndTxnOnSubscriptionResponse
pub fn clear_endTxnOnSubscriptionResponse(&mut self)
pub fn has_endTxnOnSubscriptionResponse(&self) -> bool
pub fn set_endTxnOnSubscriptionResponse( &mut self, v: CommandEndTxnOnSubscriptionResponse, )
pub fn mut_endTxnOnSubscriptionResponse( &mut self, ) -> &mut CommandEndTxnOnSubscriptionResponse
pub fn take_endTxnOnSubscriptionResponse( &mut self, ) -> CommandEndTxnOnSubscriptionResponse
Trait Implementations§
Source§impl Clear for BaseCommand
impl Clear for BaseCommand
Source§impl Clone for BaseCommand
impl Clone for BaseCommand
Source§fn clone(&self) -> BaseCommand
fn clone(&self) -> BaseCommand
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for BaseCommand
impl Debug for BaseCommand
Source§impl<'a> Default for &'a BaseCommand
impl<'a> Default for &'a BaseCommand
Source§fn default() -> &'a BaseCommand
fn default() -> &'a BaseCommand
Returns the “default value” for a type. Read more
Source§impl Default for BaseCommand
impl Default for BaseCommand
Source§fn default() -> BaseCommand
fn default() -> BaseCommand
Returns the “default value” for a type. Read more
Source§impl Message for BaseCommand
impl Message for BaseCommand
Source§fn is_initialized(&self) -> bool
fn is_initialized(&self) -> bool
True iff all required fields are initialized.
Always returns
true for protobuf 3.Source§fn merge_from(&mut self, is: &mut CodedInputStream<'_>) -> ProtobufResult<()>
fn merge_from(&mut self, is: &mut CodedInputStream<'_>) -> ProtobufResult<()>
Update this message object with fields read from given stream.
Source§fn compute_size(&self) -> u32
fn compute_size(&self) -> u32
Compute and cache size of this message and all nested messages
Source§fn write_to_with_cached_sizes(
&self,
os: &mut CodedOutputStream<'_>,
) -> ProtobufResult<()>
fn write_to_with_cached_sizes( &self, os: &mut CodedOutputStream<'_>, ) -> ProtobufResult<()>
Write message to the stream. Read more
Source§fn get_cached_size(&self) -> u32
fn get_cached_size(&self) -> u32
Get size previously computed by
compute_size.Source§fn get_unknown_fields(&self) -> &UnknownFields
fn get_unknown_fields(&self) -> &UnknownFields
Get a reference to unknown fields.
Source§fn mut_unknown_fields(&mut self) -> &mut UnknownFields
fn mut_unknown_fields(&mut self) -> &mut UnknownFields
Get a mutable reference to unknown fields.
Source§fn as_any_mut(&mut self) -> &mut dyn Any
fn as_any_mut(&mut self) -> &mut dyn Any
View self as mutable
Any.Source§fn descriptor(&self) -> &'static MessageDescriptor
fn descriptor(&self) -> &'static MessageDescriptor
Message descriptor for this message, used for reflection.
Source§fn new() -> BaseCommand
fn new() -> BaseCommand
Create an empty message object. Read more
Source§fn default_instance() -> &'static BaseCommand
fn default_instance() -> &'static BaseCommand
Return a pointer to default immutable message with static lifetime. Read more
Source§fn parse_from(is: &mut CodedInputStream<'_>) -> Result<Self, ProtobufError>where
Self: Sized,
fn parse_from(is: &mut CodedInputStream<'_>) -> Result<Self, ProtobufError>where
Self: Sized,
Parse message from stream.
Source§fn write_to(&self, os: &mut CodedOutputStream<'_>) -> Result<(), ProtobufError>
fn write_to(&self, os: &mut CodedOutputStream<'_>) -> Result<(), ProtobufError>
Write the message to the stream. Read more
Source§fn write_length_delimited_to(
&self,
os: &mut CodedOutputStream<'_>,
) -> Result<(), ProtobufError>
fn write_length_delimited_to( &self, os: &mut CodedOutputStream<'_>, ) -> Result<(), ProtobufError>
Write the message to the stream prepending the message with message length
encoded as varint.
Source§fn write_length_delimited_to_vec(
&self,
vec: &mut Vec<u8>,
) -> Result<(), ProtobufError>
fn write_length_delimited_to_vec( &self, vec: &mut Vec<u8>, ) -> Result<(), ProtobufError>
Write the message to the vec, prepend the message with message length
encoded as varint.
Source§fn merge_from_bytes(&mut self, bytes: &[u8]) -> Result<(), ProtobufError>
fn merge_from_bytes(&mut self, bytes: &[u8]) -> Result<(), ProtobufError>
Update this message object with fields read from given stream.
Source§fn parse_from_reader(reader: &mut dyn Read) -> Result<Self, ProtobufError>where
Self: Sized,
fn parse_from_reader(reader: &mut dyn Read) -> Result<Self, ProtobufError>where
Self: Sized,
Parse message from reader.
Parse stops on EOF or when error encountered.
Source§fn parse_from_bytes(bytes: &[u8]) -> Result<Self, ProtobufError>where
Self: Sized,
fn parse_from_bytes(bytes: &[u8]) -> Result<Self, ProtobufError>where
Self: Sized,
Parse message from byte array.
Source§fn check_initialized(&self) -> Result<(), ProtobufError>
fn check_initialized(&self) -> Result<(), ProtobufError>
Check if all required fields of this object are initialized.
Source§fn write_to_writer(&self, w: &mut dyn Write) -> Result<(), ProtobufError>
fn write_to_writer(&self, w: &mut dyn Write) -> Result<(), ProtobufError>
Write the message to the writer.
Source§fn write_to_vec(&self, v: &mut Vec<u8>) -> Result<(), ProtobufError>
fn write_to_vec(&self, v: &mut Vec<u8>) -> Result<(), ProtobufError>
Write the message to bytes vec.
Source§fn write_to_bytes(&self) -> Result<Vec<u8>, ProtobufError>
fn write_to_bytes(&self) -> Result<Vec<u8>, ProtobufError>
Write the message to bytes vec.
Source§fn write_length_delimited_to_writer(
&self,
w: &mut dyn Write,
) -> Result<(), ProtobufError>
fn write_length_delimited_to_writer( &self, w: &mut dyn Write, ) -> Result<(), ProtobufError>
Write the message to the writer, prepend the message with message length
encoded as varint.
Source§fn write_length_delimited_to_bytes(&self) -> Result<Vec<u8>, ProtobufError>
fn write_length_delimited_to_bytes(&self) -> Result<Vec<u8>, ProtobufError>
Write the message to the bytes vec, prepend the message with message length
encoded as varint.
Source§fn descriptor_static() -> &'static MessageDescriptorwhere
Self: Sized,
fn descriptor_static() -> &'static MessageDescriptorwhere
Self: Sized,
Get message descriptor for message type. Read more
Source§impl PartialEq for BaseCommand
impl PartialEq for BaseCommand
Source§impl ProtobufValue for BaseCommand
impl ProtobufValue for BaseCommand
Source§fn as_ref(&self) -> ReflectValueRef<'_>
fn as_ref(&self) -> ReflectValueRef<'_>
As ref
Source§fn is_non_zero(&self) -> bool
fn is_non_zero(&self) -> bool
Is value non-zero?
Source§fn as_ref_copy(&self) -> ReflectValueRef<'static>
fn as_ref_copy(&self) -> ReflectValueRef<'static>
impl StructuralPartialEq for BaseCommand
Auto Trait Implementations§
impl !Freeze for BaseCommand
impl RefUnwindSafe for BaseCommand
impl Send for BaseCommand
impl Sync for BaseCommand
impl Unpin for BaseCommand
impl UnwindSafe for BaseCommand
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit)