Struct pulsar_binary_protocol_spec::protos::protobuf::PulsarApi::BaseCommand [−][src]
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: CachedSize
Implementations
impl BaseCommand
[src]
pub fn new() -> BaseCommand
[src]
pub fn get_field_type(&self) -> BaseCommand_Type
[src]
pub fn clear_field_type(&mut self)
[src]
pub fn has_field_type(&self) -> bool
[src]
pub fn set_field_type(&mut self, v: BaseCommand_Type)
[src]
pub fn get_connect(&self) -> &CommandConnect
[src]
pub fn clear_connect(&mut self)
[src]
pub fn has_connect(&self) -> bool
[src]
pub fn set_connect(&mut self, v: CommandConnect)
[src]
pub fn mut_connect(&mut self) -> &mut CommandConnect
[src]
pub fn take_connect(&mut self) -> CommandConnect
[src]
pub fn get_connected(&self) -> &CommandConnected
[src]
pub fn clear_connected(&mut self)
[src]
pub fn has_connected(&self) -> bool
[src]
pub fn set_connected(&mut self, v: CommandConnected)
[src]
pub fn mut_connected(&mut self) -> &mut CommandConnected
[src]
pub fn take_connected(&mut self) -> CommandConnected
[src]
pub fn get_subscribe(&self) -> &CommandSubscribe
[src]
pub fn clear_subscribe(&mut self)
[src]
pub fn has_subscribe(&self) -> bool
[src]
pub fn set_subscribe(&mut self, v: CommandSubscribe)
[src]
pub fn mut_subscribe(&mut self) -> &mut CommandSubscribe
[src]
pub fn take_subscribe(&mut self) -> CommandSubscribe
[src]
pub fn get_producer(&self) -> &CommandProducer
[src]
pub fn clear_producer(&mut self)
[src]
pub fn has_producer(&self) -> bool
[src]
pub fn set_producer(&mut self, v: CommandProducer)
[src]
pub fn mut_producer(&mut self) -> &mut CommandProducer
[src]
pub fn take_producer(&mut self) -> CommandProducer
[src]
pub fn get_send(&self) -> &CommandSend
[src]
pub fn clear_send(&mut self)
[src]
pub fn has_send(&self) -> bool
[src]
pub fn set_send(&mut self, v: CommandSend)
[src]
pub fn mut_send(&mut self) -> &mut CommandSend
[src]
pub fn take_send(&mut self) -> CommandSend
[src]
pub fn get_send_receipt(&self) -> &CommandSendReceipt
[src]
pub fn clear_send_receipt(&mut self)
[src]
pub fn has_send_receipt(&self) -> bool
[src]
pub fn set_send_receipt(&mut self, v: CommandSendReceipt)
[src]
pub fn mut_send_receipt(&mut self) -> &mut CommandSendReceipt
[src]
pub fn take_send_receipt(&mut self) -> CommandSendReceipt
[src]
pub fn get_send_error(&self) -> &CommandSendError
[src]
pub fn clear_send_error(&mut self)
[src]
pub fn has_send_error(&self) -> bool
[src]
pub fn set_send_error(&mut self, v: CommandSendError)
[src]
pub fn mut_send_error(&mut self) -> &mut CommandSendError
[src]
pub fn take_send_error(&mut self) -> CommandSendError
[src]
pub fn get_message(&self) -> &CommandMessage
[src]
pub fn clear_message(&mut self)
[src]
pub fn has_message(&self) -> bool
[src]
pub fn set_message(&mut self, v: CommandMessage)
[src]
pub fn mut_message(&mut self) -> &mut CommandMessage
[src]
pub fn take_message(&mut self) -> CommandMessage
[src]
pub fn get_ack(&self) -> &CommandAck
[src]
pub fn clear_ack(&mut self)
[src]
pub fn has_ack(&self) -> bool
[src]
pub fn set_ack(&mut self, v: CommandAck)
[src]
pub fn mut_ack(&mut self) -> &mut CommandAck
[src]
pub fn take_ack(&mut self) -> CommandAck
[src]
pub fn get_flow(&self) -> &CommandFlow
[src]
pub fn clear_flow(&mut self)
[src]
pub fn has_flow(&self) -> bool
[src]
pub fn set_flow(&mut self, v: CommandFlow)
[src]
pub fn mut_flow(&mut self) -> &mut CommandFlow
[src]
pub fn take_flow(&mut self) -> CommandFlow
[src]
pub fn get_unsubscribe(&self) -> &CommandUnsubscribe
[src]
pub fn clear_unsubscribe(&mut self)
[src]
pub fn has_unsubscribe(&self) -> bool
[src]
pub fn set_unsubscribe(&mut self, v: CommandUnsubscribe)
[src]
pub fn mut_unsubscribe(&mut self) -> &mut CommandUnsubscribe
[src]
pub fn take_unsubscribe(&mut self) -> CommandUnsubscribe
[src]
pub fn get_success(&self) -> &CommandSuccess
[src]
pub fn clear_success(&mut self)
[src]
pub fn has_success(&self) -> bool
[src]
pub fn set_success(&mut self, v: CommandSuccess)
[src]
pub fn mut_success(&mut self) -> &mut CommandSuccess
[src]
pub fn take_success(&mut self) -> CommandSuccess
[src]
pub fn get_error(&self) -> &CommandError
[src]
pub fn clear_error(&mut self)
[src]
pub fn has_error(&self) -> bool
[src]
pub fn set_error(&mut self, v: CommandError)
[src]
pub fn mut_error(&mut self) -> &mut CommandError
[src]
pub fn take_error(&mut self) -> CommandError
[src]
pub fn get_close_producer(&self) -> &CommandCloseProducer
[src]
pub fn clear_close_producer(&mut self)
[src]
pub fn has_close_producer(&self) -> bool
[src]
pub fn set_close_producer(&mut self, v: CommandCloseProducer)
[src]
pub fn mut_close_producer(&mut self) -> &mut CommandCloseProducer
[src]
pub fn take_close_producer(&mut self) -> CommandCloseProducer
[src]
pub fn get_close_consumer(&self) -> &CommandCloseConsumer
[src]
pub fn clear_close_consumer(&mut self)
[src]
pub fn has_close_consumer(&self) -> bool
[src]
pub fn set_close_consumer(&mut self, v: CommandCloseConsumer)
[src]
pub fn mut_close_consumer(&mut self) -> &mut CommandCloseConsumer
[src]
pub fn take_close_consumer(&mut self) -> CommandCloseConsumer
[src]
pub fn get_producer_success(&self) -> &CommandProducerSuccess
[src]
pub fn clear_producer_success(&mut self)
[src]
pub fn has_producer_success(&self) -> bool
[src]
pub fn set_producer_success(&mut self, v: CommandProducerSuccess)
[src]
pub fn mut_producer_success(&mut self) -> &mut CommandProducerSuccess
[src]
pub fn take_producer_success(&mut self) -> CommandProducerSuccess
[src]
pub fn get_ping(&self) -> &CommandPing
[src]
pub fn clear_ping(&mut self)
[src]
pub fn has_ping(&self) -> bool
[src]
pub fn set_ping(&mut self, v: CommandPing)
[src]
pub fn mut_ping(&mut self) -> &mut CommandPing
[src]
pub fn take_ping(&mut self) -> CommandPing
[src]
pub fn get_pong(&self) -> &CommandPong
[src]
pub fn clear_pong(&mut self)
[src]
pub fn has_pong(&self) -> bool
[src]
pub fn set_pong(&mut self, v: CommandPong)
[src]
pub fn mut_pong(&mut self) -> &mut CommandPong
[src]
pub fn take_pong(&mut self) -> CommandPong
[src]
pub fn get_redeliverUnacknowledgedMessages(
&self
) -> &CommandRedeliverUnacknowledgedMessages
[src]
&self
) -> &CommandRedeliverUnacknowledgedMessages
pub fn clear_redeliverUnacknowledgedMessages(&mut self)
[src]
pub fn has_redeliverUnacknowledgedMessages(&self) -> bool
[src]
pub fn set_redeliverUnacknowledgedMessages(
&mut self,
v: CommandRedeliverUnacknowledgedMessages
)
[src]
&mut self,
v: CommandRedeliverUnacknowledgedMessages
)
pub fn mut_redeliverUnacknowledgedMessages(
&mut self
) -> &mut CommandRedeliverUnacknowledgedMessages
[src]
&mut self
) -> &mut CommandRedeliverUnacknowledgedMessages
pub fn take_redeliverUnacknowledgedMessages(
&mut self
) -> CommandRedeliverUnacknowledgedMessages
[src]
&mut self
) -> CommandRedeliverUnacknowledgedMessages
pub fn get_partitionMetadata(&self) -> &CommandPartitionedTopicMetadata
[src]
pub fn clear_partitionMetadata(&mut self)
[src]
pub fn has_partitionMetadata(&self) -> bool
[src]
pub fn set_partitionMetadata(&mut self, v: CommandPartitionedTopicMetadata)
[src]
pub fn mut_partitionMetadata(&mut self) -> &mut CommandPartitionedTopicMetadata
[src]
pub fn take_partitionMetadata(&mut self) -> CommandPartitionedTopicMetadata
[src]
pub fn get_partitionMetadataResponse(
&self
) -> &CommandPartitionedTopicMetadataResponse
[src]
&self
) -> &CommandPartitionedTopicMetadataResponse
pub fn clear_partitionMetadataResponse(&mut self)
[src]
pub fn has_partitionMetadataResponse(&self) -> bool
[src]
pub fn set_partitionMetadataResponse(
&mut self,
v: CommandPartitionedTopicMetadataResponse
)
[src]
&mut self,
v: CommandPartitionedTopicMetadataResponse
)
pub fn mut_partitionMetadataResponse(
&mut self
) -> &mut CommandPartitionedTopicMetadataResponse
[src]
&mut self
) -> &mut CommandPartitionedTopicMetadataResponse
pub fn take_partitionMetadataResponse(
&mut self
) -> CommandPartitionedTopicMetadataResponse
[src]
&mut self
) -> CommandPartitionedTopicMetadataResponse
pub fn get_lookupTopic(&self) -> &CommandLookupTopic
[src]
pub fn clear_lookupTopic(&mut self)
[src]
pub fn has_lookupTopic(&self) -> bool
[src]
pub fn set_lookupTopic(&mut self, v: CommandLookupTopic)
[src]
pub fn mut_lookupTopic(&mut self) -> &mut CommandLookupTopic
[src]
pub fn take_lookupTopic(&mut self) -> CommandLookupTopic
[src]
pub fn get_lookupTopicResponse(&self) -> &CommandLookupTopicResponse
[src]
pub fn clear_lookupTopicResponse(&mut self)
[src]
pub fn has_lookupTopicResponse(&self) -> bool
[src]
pub fn set_lookupTopicResponse(&mut self, v: CommandLookupTopicResponse)
[src]
pub fn mut_lookupTopicResponse(&mut self) -> &mut CommandLookupTopicResponse
[src]
pub fn take_lookupTopicResponse(&mut self) -> CommandLookupTopicResponse
[src]
pub fn get_consumerStats(&self) -> &CommandConsumerStats
[src]
pub fn clear_consumerStats(&mut self)
[src]
pub fn has_consumerStats(&self) -> bool
[src]
pub fn set_consumerStats(&mut self, v: CommandConsumerStats)
[src]
pub fn mut_consumerStats(&mut self) -> &mut CommandConsumerStats
[src]
pub fn take_consumerStats(&mut self) -> CommandConsumerStats
[src]
pub fn get_consumerStatsResponse(&self) -> &CommandConsumerStatsResponse
[src]
pub fn clear_consumerStatsResponse(&mut self)
[src]
pub fn has_consumerStatsResponse(&self) -> bool
[src]
pub fn set_consumerStatsResponse(&mut self, v: CommandConsumerStatsResponse)
[src]
pub fn mut_consumerStatsResponse(&mut self) -> &mut CommandConsumerStatsResponse
[src]
pub fn take_consumerStatsResponse(&mut self) -> CommandConsumerStatsResponse
[src]
pub fn get_reachedEndOfTopic(&self) -> &CommandReachedEndOfTopic
[src]
pub fn clear_reachedEndOfTopic(&mut self)
[src]
pub fn has_reachedEndOfTopic(&self) -> bool
[src]
pub fn set_reachedEndOfTopic(&mut self, v: CommandReachedEndOfTopic)
[src]
pub fn mut_reachedEndOfTopic(&mut self) -> &mut CommandReachedEndOfTopic
[src]
pub fn take_reachedEndOfTopic(&mut self) -> CommandReachedEndOfTopic
[src]
pub fn get_seek(&self) -> &CommandSeek
[src]
pub fn clear_seek(&mut self)
[src]
pub fn has_seek(&self) -> bool
[src]
pub fn set_seek(&mut self, v: CommandSeek)
[src]
pub fn mut_seek(&mut self) -> &mut CommandSeek
[src]
pub fn take_seek(&mut self) -> CommandSeek
[src]
pub fn get_getLastMessageId(&self) -> &CommandGetLastMessageId
[src]
pub fn clear_getLastMessageId(&mut self)
[src]
pub fn has_getLastMessageId(&self) -> bool
[src]
pub fn set_getLastMessageId(&mut self, v: CommandGetLastMessageId)
[src]
pub fn mut_getLastMessageId(&mut self) -> &mut CommandGetLastMessageId
[src]
pub fn take_getLastMessageId(&mut self) -> CommandGetLastMessageId
[src]
pub fn get_getLastMessageIdResponse(&self) -> &CommandGetLastMessageIdResponse
[src]
pub fn clear_getLastMessageIdResponse(&mut self)
[src]
pub fn has_getLastMessageIdResponse(&self) -> bool
[src]
pub fn set_getLastMessageIdResponse(
&mut self,
v: CommandGetLastMessageIdResponse
)
[src]
&mut self,
v: CommandGetLastMessageIdResponse
)
pub fn mut_getLastMessageIdResponse(
&mut self
) -> &mut CommandGetLastMessageIdResponse
[src]
&mut self
) -> &mut CommandGetLastMessageIdResponse
pub fn take_getLastMessageIdResponse(
&mut self
) -> CommandGetLastMessageIdResponse
[src]
&mut self
) -> CommandGetLastMessageIdResponse
pub fn get_active_consumer_change(&self) -> &CommandActiveConsumerChange
[src]
pub fn clear_active_consumer_change(&mut self)
[src]
pub fn has_active_consumer_change(&self) -> bool
[src]
pub fn set_active_consumer_change(&mut self, v: CommandActiveConsumerChange)
[src]
pub fn mut_active_consumer_change(&mut self) -> &mut CommandActiveConsumerChange
[src]
pub fn take_active_consumer_change(&mut self) -> CommandActiveConsumerChange
[src]
pub fn get_getTopicsOfNamespace(&self) -> &CommandGetTopicsOfNamespace
[src]
pub fn clear_getTopicsOfNamespace(&mut self)
[src]
pub fn has_getTopicsOfNamespace(&self) -> bool
[src]
pub fn set_getTopicsOfNamespace(&mut self, v: CommandGetTopicsOfNamespace)
[src]
pub fn mut_getTopicsOfNamespace(&mut self) -> &mut CommandGetTopicsOfNamespace
[src]
pub fn take_getTopicsOfNamespace(&mut self) -> CommandGetTopicsOfNamespace
[src]
pub fn get_getTopicsOfNamespaceResponse(
&self
) -> &CommandGetTopicsOfNamespaceResponse
[src]
&self
) -> &CommandGetTopicsOfNamespaceResponse
pub fn clear_getTopicsOfNamespaceResponse(&mut self)
[src]
pub fn has_getTopicsOfNamespaceResponse(&self) -> bool
[src]
pub fn set_getTopicsOfNamespaceResponse(
&mut self,
v: CommandGetTopicsOfNamespaceResponse
)
[src]
&mut self,
v: CommandGetTopicsOfNamespaceResponse
)
pub fn mut_getTopicsOfNamespaceResponse(
&mut self
) -> &mut CommandGetTopicsOfNamespaceResponse
[src]
&mut self
) -> &mut CommandGetTopicsOfNamespaceResponse
pub fn take_getTopicsOfNamespaceResponse(
&mut self
) -> CommandGetTopicsOfNamespaceResponse
[src]
&mut self
) -> CommandGetTopicsOfNamespaceResponse
pub fn get_getSchema(&self) -> &CommandGetSchema
[src]
pub fn clear_getSchema(&mut self)
[src]
pub fn has_getSchema(&self) -> bool
[src]
pub fn set_getSchema(&mut self, v: CommandGetSchema)
[src]
pub fn mut_getSchema(&mut self) -> &mut CommandGetSchema
[src]
pub fn take_getSchema(&mut self) -> CommandGetSchema
[src]
pub fn get_getSchemaResponse(&self) -> &CommandGetSchemaResponse
[src]
pub fn clear_getSchemaResponse(&mut self)
[src]
pub fn has_getSchemaResponse(&self) -> bool
[src]
pub fn set_getSchemaResponse(&mut self, v: CommandGetSchemaResponse)
[src]
pub fn mut_getSchemaResponse(&mut self) -> &mut CommandGetSchemaResponse
[src]
pub fn take_getSchemaResponse(&mut self) -> CommandGetSchemaResponse
[src]
pub fn get_authChallenge(&self) -> &CommandAuthChallenge
[src]
pub fn clear_authChallenge(&mut self)
[src]
pub fn has_authChallenge(&self) -> bool
[src]
pub fn set_authChallenge(&mut self, v: CommandAuthChallenge)
[src]
pub fn mut_authChallenge(&mut self) -> &mut CommandAuthChallenge
[src]
pub fn take_authChallenge(&mut self) -> CommandAuthChallenge
[src]
pub fn get_authResponse(&self) -> &CommandAuthResponse
[src]
pub fn clear_authResponse(&mut self)
[src]
pub fn has_authResponse(&self) -> bool
[src]
pub fn set_authResponse(&mut self, v: CommandAuthResponse)
[src]
pub fn mut_authResponse(&mut self) -> &mut CommandAuthResponse
[src]
pub fn take_authResponse(&mut self) -> CommandAuthResponse
[src]
pub fn get_ackResponse(&self) -> &CommandAckResponse
[src]
pub fn clear_ackResponse(&mut self)
[src]
pub fn has_ackResponse(&self) -> bool
[src]
pub fn set_ackResponse(&mut self, v: CommandAckResponse)
[src]
pub fn mut_ackResponse(&mut self) -> &mut CommandAckResponse
[src]
pub fn take_ackResponse(&mut self) -> CommandAckResponse
[src]
pub fn get_getOrCreateSchema(&self) -> &CommandGetOrCreateSchema
[src]
pub fn clear_getOrCreateSchema(&mut self)
[src]
pub fn has_getOrCreateSchema(&self) -> bool
[src]
pub fn set_getOrCreateSchema(&mut self, v: CommandGetOrCreateSchema)
[src]
pub fn mut_getOrCreateSchema(&mut self) -> &mut CommandGetOrCreateSchema
[src]
pub fn take_getOrCreateSchema(&mut self) -> CommandGetOrCreateSchema
[src]
pub fn get_getOrCreateSchemaResponse(&self) -> &CommandGetOrCreateSchemaResponse
[src]
pub fn clear_getOrCreateSchemaResponse(&mut self)
[src]
pub fn has_getOrCreateSchemaResponse(&self) -> bool
[src]
pub fn set_getOrCreateSchemaResponse(
&mut self,
v: CommandGetOrCreateSchemaResponse
)
[src]
&mut self,
v: CommandGetOrCreateSchemaResponse
)
pub fn mut_getOrCreateSchemaResponse(
&mut self
) -> &mut CommandGetOrCreateSchemaResponse
[src]
&mut self
) -> &mut CommandGetOrCreateSchemaResponse
pub fn take_getOrCreateSchemaResponse(
&mut self
) -> CommandGetOrCreateSchemaResponse
[src]
&mut self
) -> CommandGetOrCreateSchemaResponse
pub fn get_newTxn(&self) -> &CommandNewTxn
[src]
pub fn clear_newTxn(&mut self)
[src]
pub fn has_newTxn(&self) -> bool
[src]
pub fn set_newTxn(&mut self, v: CommandNewTxn)
[src]
pub fn mut_newTxn(&mut self) -> &mut CommandNewTxn
[src]
pub fn take_newTxn(&mut self) -> CommandNewTxn
[src]
pub fn get_newTxnResponse(&self) -> &CommandNewTxnResponse
[src]
pub fn clear_newTxnResponse(&mut self)
[src]
pub fn has_newTxnResponse(&self) -> bool
[src]
pub fn set_newTxnResponse(&mut self, v: CommandNewTxnResponse)
[src]
pub fn mut_newTxnResponse(&mut self) -> &mut CommandNewTxnResponse
[src]
pub fn take_newTxnResponse(&mut self) -> CommandNewTxnResponse
[src]
pub fn get_addPartitionToTxn(&self) -> &CommandAddPartitionToTxn
[src]
pub fn clear_addPartitionToTxn(&mut self)
[src]
pub fn has_addPartitionToTxn(&self) -> bool
[src]
pub fn set_addPartitionToTxn(&mut self, v: CommandAddPartitionToTxn)
[src]
pub fn mut_addPartitionToTxn(&mut self) -> &mut CommandAddPartitionToTxn
[src]
pub fn take_addPartitionToTxn(&mut self) -> CommandAddPartitionToTxn
[src]
pub fn get_addPartitionToTxnResponse(&self) -> &CommandAddPartitionToTxnResponse
[src]
pub fn clear_addPartitionToTxnResponse(&mut self)
[src]
pub fn has_addPartitionToTxnResponse(&self) -> bool
[src]
pub fn set_addPartitionToTxnResponse(
&mut self,
v: CommandAddPartitionToTxnResponse
)
[src]
&mut self,
v: CommandAddPartitionToTxnResponse
)
pub fn mut_addPartitionToTxnResponse(
&mut self
) -> &mut CommandAddPartitionToTxnResponse
[src]
&mut self
) -> &mut CommandAddPartitionToTxnResponse
pub fn take_addPartitionToTxnResponse(
&mut self
) -> CommandAddPartitionToTxnResponse
[src]
&mut self
) -> CommandAddPartitionToTxnResponse
pub fn get_addSubscriptionToTxn(&self) -> &CommandAddSubscriptionToTxn
[src]
pub fn clear_addSubscriptionToTxn(&mut self)
[src]
pub fn has_addSubscriptionToTxn(&self) -> bool
[src]
pub fn set_addSubscriptionToTxn(&mut self, v: CommandAddSubscriptionToTxn)
[src]
pub fn mut_addSubscriptionToTxn(&mut self) -> &mut CommandAddSubscriptionToTxn
[src]
pub fn take_addSubscriptionToTxn(&mut self) -> CommandAddSubscriptionToTxn
[src]
pub fn get_addSubscriptionToTxnResponse(
&self
) -> &CommandAddSubscriptionToTxnResponse
[src]
&self
) -> &CommandAddSubscriptionToTxnResponse
pub fn clear_addSubscriptionToTxnResponse(&mut self)
[src]
pub fn has_addSubscriptionToTxnResponse(&self) -> bool
[src]
pub fn set_addSubscriptionToTxnResponse(
&mut self,
v: CommandAddSubscriptionToTxnResponse
)
[src]
&mut self,
v: CommandAddSubscriptionToTxnResponse
)
pub fn mut_addSubscriptionToTxnResponse(
&mut self
) -> &mut CommandAddSubscriptionToTxnResponse
[src]
&mut self
) -> &mut CommandAddSubscriptionToTxnResponse
pub fn take_addSubscriptionToTxnResponse(
&mut self
) -> CommandAddSubscriptionToTxnResponse
[src]
&mut self
) -> CommandAddSubscriptionToTxnResponse
pub fn get_endTxn(&self) -> &CommandEndTxn
[src]
pub fn clear_endTxn(&mut self)
[src]
pub fn has_endTxn(&self) -> bool
[src]
pub fn set_endTxn(&mut self, v: CommandEndTxn)
[src]
pub fn mut_endTxn(&mut self) -> &mut CommandEndTxn
[src]
pub fn take_endTxn(&mut self) -> CommandEndTxn
[src]
pub fn get_endTxnResponse(&self) -> &CommandEndTxnResponse
[src]
pub fn clear_endTxnResponse(&mut self)
[src]
pub fn has_endTxnResponse(&self) -> bool
[src]
pub fn set_endTxnResponse(&mut self, v: CommandEndTxnResponse)
[src]
pub fn mut_endTxnResponse(&mut self) -> &mut CommandEndTxnResponse
[src]
pub fn take_endTxnResponse(&mut self) -> CommandEndTxnResponse
[src]
pub fn get_endTxnOnPartition(&self) -> &CommandEndTxnOnPartition
[src]
pub fn clear_endTxnOnPartition(&mut self)
[src]
pub fn has_endTxnOnPartition(&self) -> bool
[src]
pub fn set_endTxnOnPartition(&mut self, v: CommandEndTxnOnPartition)
[src]
pub fn mut_endTxnOnPartition(&mut self) -> &mut CommandEndTxnOnPartition
[src]
pub fn take_endTxnOnPartition(&mut self) -> CommandEndTxnOnPartition
[src]
pub fn get_endTxnOnPartitionResponse(&self) -> &CommandEndTxnOnPartitionResponse
[src]
pub fn clear_endTxnOnPartitionResponse(&mut self)
[src]
pub fn has_endTxnOnPartitionResponse(&self) -> bool
[src]
pub fn set_endTxnOnPartitionResponse(
&mut self,
v: CommandEndTxnOnPartitionResponse
)
[src]
&mut self,
v: CommandEndTxnOnPartitionResponse
)
pub fn mut_endTxnOnPartitionResponse(
&mut self
) -> &mut CommandEndTxnOnPartitionResponse
[src]
&mut self
) -> &mut CommandEndTxnOnPartitionResponse
pub fn take_endTxnOnPartitionResponse(
&mut self
) -> CommandEndTxnOnPartitionResponse
[src]
&mut self
) -> CommandEndTxnOnPartitionResponse
pub fn get_endTxnOnSubscription(&self) -> &CommandEndTxnOnSubscription
[src]
pub fn clear_endTxnOnSubscription(&mut self)
[src]
pub fn has_endTxnOnSubscription(&self) -> bool
[src]
pub fn set_endTxnOnSubscription(&mut self, v: CommandEndTxnOnSubscription)
[src]
pub fn mut_endTxnOnSubscription(&mut self) -> &mut CommandEndTxnOnSubscription
[src]
pub fn take_endTxnOnSubscription(&mut self) -> CommandEndTxnOnSubscription
[src]
pub fn get_endTxnOnSubscriptionResponse(
&self
) -> &CommandEndTxnOnSubscriptionResponse
[src]
&self
) -> &CommandEndTxnOnSubscriptionResponse
pub fn clear_endTxnOnSubscriptionResponse(&mut self)
[src]
pub fn has_endTxnOnSubscriptionResponse(&self) -> bool
[src]
pub fn set_endTxnOnSubscriptionResponse(
&mut self,
v: CommandEndTxnOnSubscriptionResponse
)
[src]
&mut self,
v: CommandEndTxnOnSubscriptionResponse
)
pub fn mut_endTxnOnSubscriptionResponse(
&mut self
) -> &mut CommandEndTxnOnSubscriptionResponse
[src]
&mut self
) -> &mut CommandEndTxnOnSubscriptionResponse
pub fn take_endTxnOnSubscriptionResponse(
&mut self
) -> CommandEndTxnOnSubscriptionResponse
[src]
&mut self
) -> CommandEndTxnOnSubscriptionResponse
Trait Implementations
impl Clear for BaseCommand
[src]
impl Clone for BaseCommand
[src]
fn clone(&self) -> BaseCommand
[src]
pub 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<'a> Default for &'a BaseCommand
[src]
fn default() -> &'a BaseCommand
[src]
impl Message for BaseCommand
[src]
fn is_initialized(&self) -> bool
[src]
fn merge_from(&mut self, is: &mut CodedInputStream<'_>) -> ProtobufResult<()>
[src]
fn compute_size(&self) -> u32
[src]
fn write_to_with_cached_sizes(
&self,
os: &mut CodedOutputStream<'_>
) -> ProtobufResult<()>
[src]
&self,
os: &mut CodedOutputStream<'_>
) -> ProtobufResult<()>
fn get_cached_size(&self) -> u32
[src]
fn get_unknown_fields(&self) -> &UnknownFields
[src]
fn mut_unknown_fields(&mut self) -> &mut UnknownFields
[src]
fn as_any(&self) -> &dyn Any
[src]
fn as_any_mut(&mut self) -> &mut dyn Any
[src]
fn into_any(self: Box<Self>) -> Box<dyn Any>
[src]
fn descriptor(&self) -> &'static MessageDescriptor
[src]
fn new() -> BaseCommand
[src]
fn default_instance() -> &'static BaseCommand
[src]
pub fn parse_from(is: &mut CodedInputStream<'_>) -> Result<Self, ProtobufError>
[src]
pub fn write_to(
&self,
os: &mut CodedOutputStream<'_>
) -> Result<(), ProtobufError>
[src]
&self,
os: &mut CodedOutputStream<'_>
) -> Result<(), ProtobufError>
pub fn write_length_delimited_to(
&self,
os: &mut CodedOutputStream<'_>
) -> Result<(), ProtobufError>
[src]
&self,
os: &mut CodedOutputStream<'_>
) -> Result<(), ProtobufError>
pub fn write_length_delimited_to_vec(
&self,
vec: &mut Vec<u8, Global>
) -> Result<(), ProtobufError>
[src]
&self,
vec: &mut Vec<u8, Global>
) -> Result<(), ProtobufError>
pub fn merge_from_bytes(&mut self, bytes: &[u8]) -> Result<(), ProtobufError>
[src]
pub fn parse_from_reader(reader: &mut dyn Read) -> Result<Self, ProtobufError>
[src]
pub fn parse_from_bytes(bytes: &[u8]) -> Result<Self, ProtobufError>
[src]
pub fn check_initialized(&self) -> Result<(), ProtobufError>
[src]
pub fn write_to_writer(&self, w: &mut dyn Write) -> Result<(), ProtobufError>
[src]
pub fn write_to_vec(&self, v: &mut Vec<u8, Global>) -> Result<(), ProtobufError>
[src]
pub fn write_to_bytes(&self) -> Result<Vec<u8, Global>, ProtobufError>
[src]
pub fn write_length_delimited_to_writer(
&self,
w: &mut dyn Write
) -> Result<(), ProtobufError>
[src]
&self,
w: &mut dyn Write
) -> Result<(), ProtobufError>
pub fn write_length_delimited_to_bytes(
&self
) -> Result<Vec<u8, Global>, ProtobufError>
[src]
&self
) -> Result<Vec<u8, Global>, ProtobufError>
pub fn type_id(&self) -> TypeId
[src]
pub fn descriptor_static() -> &'static MessageDescriptor
[src]
impl PartialEq<BaseCommand> for BaseCommand
[src]
fn eq(&self, other: &BaseCommand) -> bool
[src]
fn ne(&self, other: &BaseCommand) -> bool
[src]
impl ProtobufValue for BaseCommand
[src]
fn as_ref(&self) -> ReflectValueRef<'_>
[src]
pub fn as_any(&self) -> &(dyn Any + 'static)
[src]
pub fn is_non_zero(&self) -> bool
[src]
pub fn as_ref_copy(&self) -> ReflectValueRef<'static>
[src]
impl StructuralPartialEq for BaseCommand
[src]
Auto Trait Implementations
impl RefUnwindSafe for BaseCommand
[src]
impl Send for BaseCommand
[src]
impl Sync for BaseCommand
[src]
impl Unpin for BaseCommand
[src]
impl UnwindSafe for BaseCommand
[src]
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,
pub 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.
pub fn to_owned(&self) -> T
[src]
pub 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.
pub 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>,