Categorygithub.com/apache/pulsar-client-gopulsarinternalpulsar_proto
package
0.14.0
Repository: https://github.com/apache/pulsar-client-go.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
4
Dependents
12
Files
9.2k SLOC

# README

protoc-gen-go:

go install google.golang.org/protobuf/cmd/protoc-gen-go@latest

Generate code:

protoc --go_out=. --go_opt=paths=source_relative PulsarApi.proto

# Constants

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
transaction related.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Default values for CommandAck fields.
Default values for CommandAck fields.
Default values for CommandAckResponse fields.
Default values for CommandAckResponse fields.
Default values for CommandActiveConsumerChange fields.
Default values for CommandAddPartitionToTxn fields.
Default values for CommandAddPartitionToTxn fields.
Default values for CommandAddPartitionToTxnResponse fields.
Default values for CommandAddPartitionToTxnResponse fields.
Default values for CommandAddSubscriptionToTxn fields.
Default values for CommandAddSubscriptionToTxn fields.
Default values for CommandAddSubscriptionToTxnResponse fields.
Default values for CommandAddSubscriptionToTxnResponse fields.
Default values for CommandAuthChallenge fields.
Default values for CommandAuthResponse fields.
Default values for CommandConnect fields.
Default values for CommandConnected fields.
Default values for CommandEndTxn fields.
Default values for CommandEndTxn fields.
Default values for CommandEndTxnOnPartition fields.
Default values for CommandEndTxnOnPartition fields.
Default values for CommandEndTxnOnPartitionResponse fields.
Default values for CommandEndTxnOnPartitionResponse fields.
Default values for CommandEndTxnOnSubscription fields.
Default values for CommandEndTxnOnSubscription fields.
Default values for CommandEndTxnOnSubscriptionResponse fields.
Default values for CommandEndTxnOnSubscriptionResponse fields.
Default values for CommandEndTxnResponse fields.
Default values for CommandEndTxnResponse fields.
Default values for CommandGetTopicsOfNamespace fields.
Default values for CommandGetTopicsOfNamespaceResponse fields.
Default values for CommandGetTopicsOfNamespaceResponse fields.
Default values for CommandLookupTopic fields.
Default values for CommandLookupTopicResponse fields.
Default values for CommandLookupTopicResponse fields.
Default values for CommandMessage fields.
Default values for CommandNewTxn fields.
Default values for CommandNewTxn fields.
Default values for CommandNewTxnResponse fields.
Default values for CommandNewTxnResponse fields.
Default values for CommandProducer fields.
Default values for CommandProducer fields.
Default values for CommandProducer fields.
Default values for CommandProducer fields.
Default values for CommandProducer fields.
Default values for CommandProducerSuccess fields.
Default values for CommandProducerSuccess fields.
Default values for CommandSend fields.
Default values for CommandSend fields.
Default values for CommandSend fields.
Default values for CommandSend fields.
Default values for CommandSend fields.
Default values for CommandSend fields.
Default values for CommandSendReceipt fields.
Default values for CommandSubscribe fields.
Default values for CommandSubscribe fields.
Default values for CommandSubscribe fields.
Default values for CommandSubscribe fields.
Default values for CommandTcClientConnectRequest fields.
Default values for CommandUnsubscribe fields.
Default values for FeatureFlags fields.
Default values for FeatureFlags fields.
Default values for FeatureFlags fields.
Default values for FeatureFlags fields.
Default values for KeySharedMeta fields.
Default values for MessageIdData fields.
Default values for MessageIdData fields.
Default values for MessageMetadata fields.
Default values for MessageMetadata fields.
Default values for MessageMetadata fields.
Default values for MessageMetadata fields.
Default values for MessageMetadata fields.
Default values for MessageMetadata fields.
Default values for MessageMetadata fields.
Default values for MessageMetadata fields.
Default values for SingleMessageMetadata fields.
Default values for SingleMessageMetadata fields.
Default values for SingleMessageMetadata fields.
Default values for SingleMessageMetadata fields.
Default values for SingleMessageMetadata fields.
No description provided by the author
No description provided by the author
Require exclusive access for producer.
Require exclusive access for producer.
By default multiple producers can publish on a topic.
Producer creation is pending until it can acquire exclusive access.
Initial versioning.
Added application keep-alive.
Added proxy to broker.
C++ consumers before this version are not correctly handling the checksum field.
Added get topic's last messageId from broker.
Schema-registry : added avro schema format for json.
Add CommandAuthChallenge and CommandAuthResponse for mutual auth.
Add CommandGetOrCreateSchema and CommandGetOrCreateSchemaResponse.
Add support for broker entry metadata.
Added support ack receipt.
Add client support for broker entry metadata.
Add CommandTcClientConnectRequest and CommandTcClientConnectResponse.
Added RedeliverUnacknowledgedMessages Command.
Add client support for topic migration redirection CommandTopicMigrated.
Added compression with LZ4 and ZLib.
Added batch message support.
Added disconnect client w/o closing connection.
Added checksum computation for metadata + payload.
Added CommandLookupTopic - Binary Lookup.
Added CommandConsumerStats - Client fetches broker side consumer stats.
Added end of topic notification.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Non valid authentication.
Not authorized to use resource.
Error while verifying message checksum.
Dispatcher assign consumer error.
Unable to subscribe/unsubscribe because.
Consumer not found.
Specified schema was incompatible with topic schema.
The topic name is not valid.
Invalid txn status error.
Error with ZK/metadata.
Not allowed error.
Error writing reading from BK.
Unable to create producer because backlog quota exceeded.
Exception while creating producer because quota exceeded.
Producer with same name is already connected.
When a producer asks and fail to get exclusive producer access,.
Any error that requires client retry operation with a fresh lookup.
Subscription not found.
Error with too many simultaneously request.
Topic not found.
The topic has been terminated.
Ack with transaction conflict.
Transaction coordinator not found error.
Transaction not found.
No description provided by the author
Error when an older client/version doesn't support a required feature.
No description provided by the author
No description provided by the author

# Variables

Enum value maps for AuthMethod.
Enum value maps for AuthMethod.
Enum value maps for BaseCommand_Type.
Enum value maps for BaseCommand_Type.
Enum value maps for CommandAck_AckType.
Enum value maps for CommandAck_AckType.
Enum value maps for CommandAck_ValidationError.
Enum value maps for CommandAck_ValidationError.
Enum value maps for CommandGetTopicsOfNamespace_Mode.
Enum value maps for CommandGetTopicsOfNamespace_Mode.
Enum value maps for CommandLookupTopicResponse_LookupType.
Enum value maps for CommandLookupTopicResponse_LookupType.
Enum value maps for CommandPartitionedTopicMetadataResponse_LookupType.
Enum value maps for CommandPartitionedTopicMetadataResponse_LookupType.
Enum value maps for CommandSubscribe_InitialPosition.
Enum value maps for CommandSubscribe_InitialPosition.
Enum value maps for CommandSubscribe_SubType.
Enum value maps for CommandSubscribe_SubType.
Enum value maps for CommandTopicMigrated_ResourceType.
Enum value maps for CommandTopicMigrated_ResourceType.
Enum value maps for CompressionType.
Enum value maps for CompressionType.
No description provided by the author
Enum value maps for KeySharedMode.
Enum value maps for KeySharedMode.
Enum value maps for ProducerAccessMode.
Enum value maps for ProducerAccessMode.
Enum value maps for ProtocolVersion.
Enum value maps for ProtocolVersion.
Enum value maps for Schema_Type.
Enum value maps for Schema_Type.
Enum value maps for ServerError.
Enum value maps for ServerError.
Enum value maps for TxnAction.
Enum value maps for TxnAction.

# Structs

To support mutual authentication type, such as Sasl, reuse this command to mutual auth.
No description provided by the author
metadata added for entry from broker.
No description provided by the author
No description provided by the author
changes on active consumer.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Commands to probe the state of connection.
No description provided by the author
/ Create a new Producer on a topic, assigning the given producer_id, / all messages sent with this producer_id will be persisted on the topic.
/ Response from CommandProducer.
Message sent by broker to client when a topic has been forcefully terminated and there are no more messages left to consume.
No description provided by the author
Reset an existing consumer to a particular message id.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Type aliases

No description provided by the author
No description provided by the author
No description provided by the author
Acks can contain a flag to indicate the consumer received an invalid message that got discarded before being passed on to the application.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Each protocol version identify new features that are incrementally added to the protocol.
No description provided by the author
No description provided by the author
No description provided by the author