TxnState The state of the transaction. Check the state of the transaction before executing some operation with the transaction is necessary.

Clock allows for injecting fake or real clocks into code that needs to do arbitrary things based on time.

Topics is admin interface for topics management

Timer allows for injecting fake or real timers into code that needs to do arbitrary things based on time.

Acks can contain a flag to indicate the consumer received an invalid message that got discarded before being passed on to the application.

Each protocol version identify new features that are incrementally added to the protocol

SchemaType We need to define a SchemaType in this internal package, to avoid directly importing pulsar.SchemaType. In case we might encounter importin

This error is returned when `AckIDList` failed and `AckWithResponse` is true. It only contains the valid message IDs that failed to be acknowledged in

AckGroupingOptions controls how to group ACK requests If maxSize is 0 or 1, any ACK request will be sent immediately. Otherwise, the ACK requests will

To support mutual authentication type, such as Sasl, reuse this command to mutual auth.

Authentication Opaque interface that represents the authentication credentials

AuthorizationCodeExchangeRequest is used to request the exchange of an authorization code for a token

AuthorizationGrant is a credential representing the resource owner's authorization to access its protected resources, and is used by the client to obt

AuthorizationGrantRefresher refreshes OAuth 2.0 authorization grant

AuthorizationTokenResponse is the HTTP response when asking for a new token. Note that not all fields will contain data based on what kind of request

BatchBuilder is a interface of batch builders

BatcherBuilderProvider defines func which returns the BatchBuilder.

BlockingQueue is a interface of block queue

metadata added for entry from broker

BrokerStats is admin interface for broker stats management

Brokers is admin interface for brokers management

Buffer is a variable-sized buffer of bytes with Read and Write methods. The zero value for Buffer is an empty buffer ready to use.

A CachingTokenSource is anything that can return a token, and is backed by a cache.

Client represents a pulsar client

Client provides a client to the Pulsar Restful API

Client is a base client that is used to make http request to the ServiceURL

ClientCredentialsExchangeRequest is used to request the exchange of client credentials for a token

ClientCredentialsExchanger abstracts exchanging client credentials for tokens

ClientCredentialsFlow takes care of the mechanics needed for getting an access token using the OAuth 2.0 "Client Credentials Flow"

ClientCredentialsProvider abstracts getting client credentials

ClientHandlerMap is a simple concurrent-safe map for the client type

ClientOptions is used to construct a Pulsar Client instance.

ClusterData information on a cluster

Clusters is admin interface for clusters management

changes on active consumer