Struct pulsar_binary_protocol_spec::protos::protobuf::PulsarApi::BaseCommand

pub struct BaseCommand {
    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,
    // some fields omitted
}

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

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

impl Clear for BaseCommand

fn clear(&mut self)

Clear this make, make it equivalent to newly created object.

impl Clone for BaseCommand

fn clone(&self) -> BaseCommand

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BaseCommand

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for BaseCommand

fn default() -> BaseCommand

Returns the "default value" for a type.

impl<'a> Default for &'a BaseCommand

fn default() -> &'a BaseCommand

Returns the "default value" for a type.

impl Message for BaseCommand

fn is_initialized(&self) -> bool

True iff all required fields are initialized. Always returns true for protobuf 3.

fn merge_from(&mut self, is: &mut CodedInputStream<'_>) -> ProtobufResult<()>

Update this message object with fields read from given stream.

fn compute_size(&self) -> u32

Compute and cache size of this message and all nested messages

fn write_to_with_cached_sizes(
    &self,
    os: &mut CodedOutputStream<'_>
) -> ProtobufResult<()>

Write message to the stream.

fn get_cached_size(&self) -> u32

Get size previously computed by compute_size.

fn get_unknown_fields(&self) -> &UnknownFields

Get a reference to unknown fields.

fn mut_unknown_fields(&mut self) -> &mut UnknownFields

Get a mutable reference to unknown fields.

fn as_any(&self) -> &dyn Any

View self as Any.

fn as_any_mut(&mut self) -> &mut dyn Any

View self as mutable Any.

fn into_any(self: Box<Self>) -> Box<dyn Any>

Convert boxed self to boxed Any.

fn descriptor(&self) -> &'static MessageDescriptor

Message descriptor for this message, used for reflection.

fn new() -> BaseCommand

Create an empty message object.

fn default_instance() -> &'static BaseCommand

Return a pointer to default immutable message with static lifetime.

pub fn parse_from(is: &mut CodedInputStream<'_>) -> Result<Self, ProtobufError>

Parse message from stream.

pub fn write_to(
    &self,
    os: &mut CodedOutputStream<'_>
) -> Result<(), ProtobufError>

Write the message to the stream.

pub 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.

pub fn write_length_delimited_to_vec(
    &self,
    vec: &mut Vec<u8, Global>
) -> Result<(), ProtobufError>

Write the message to the vec, prepend the message with message length encoded as varint.

pub fn merge_from_bytes(&mut self, bytes: &[u8]) -> Result<(), ProtobufError>

Update this message object with fields read from given stream.

pub fn parse_from_reader(reader: &mut dyn Read) -> Result<Self, ProtobufError>

Parse message from reader. Parse stops on EOF or when error encountered.

pub fn parse_from_bytes(bytes: &[u8]) -> Result<Self, ProtobufError>

Parse message from byte array.

pub fn check_initialized(&self) -> Result<(), ProtobufError>

Check if all required fields of this object are initialized.

pub fn write_to_writer(&self, w: &mut dyn Write) -> Result<(), ProtobufError>

Write the message to the writer.

pub fn write_to_vec(&self, v: &mut Vec<u8, Global>) -> Result<(), ProtobufError>

Write the message to bytes vec.

pub fn write_to_bytes(&self) -> Result<Vec<u8, Global>, ProtobufError>

Write the message to bytes vec.

pub 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.

pub fn write_length_delimited_to_bytes(
    &self
) -> Result<Vec<u8, Global>, ProtobufError>

Write the message to the bytes vec, prepend the message with message length encoded as varint.

pub fn type_id(&self) -> TypeId

Get type id for downcasting.

pub fn descriptor_static() -> &'static MessageDescriptor

Get message descriptor for message type.

impl PartialEq<BaseCommand> for BaseCommand

fn eq(&self, other: &BaseCommand) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &BaseCommand) -> bool

This method tests for !=.

impl ProtobufValue for BaseCommand

fn as_ref(&self) -> ReflectValueRef<'_>

As ref

pub fn as_any(&self) -> &(dyn Any + 'static)

Convert to Any

pub fn is_non_zero(&self) -> bool

Is value non-zero?

pub fn as_ref_copy(&self) -> ReflectValueRef<'static>

Return ProtobufValueRef if self is Copy.

impl StructuralPartialEq for BaseCommand