GetSubscriptionDispatchRate returns subscription dispatch rate for a topic. Returns nil if the subscription dispatch rate is not configured at the top

GetTopics returns the list of all the topics under a certain namespace

LastSequenceID get the last sequence id that was published by this producer. This represent either the automatically assigned or custom sequence id (s

NewAuthenticationOAuth2 Creates OAuth2 Authentication provider

NewAuthenticationToken Creates new Authentication provider with specified auth token

NewFakeClock constructs a fake clock set to the provided time.

NewProtoSchema creates a new ProtoSchema Note: the function will panic if creation of codec fails

NewPulsarClientWithAuthProvider create a client with auth provider.

NewSnappyProvider returns a Provider interface

NewTokenRetriever allows a TokenRetriever the internal of a new TokenRetriever to be easily set up

OnAcknowledge This is called consumer sends the acknowledgment to the broker.

RedeliveryCount returns message redelivery count, redelivery count maintain in pulsar broker. When client nack acknowledge messages, broker will dispa

Release a permit, returning it to the semaphore. Release a permit, increasing the number of available permits by one. If any threads are trying to ac

Reset the backoff to the initial state

_setConn sets the internal connection field of this partition producer atomically. Note: should only be called by this partition producer when a new c

set a new producerState and return the last state returns bool if the new state has been set or not

mockKeyFile will mock a temp key file for testing.

mockKeyFile will mock a temp key file for testing.

mockOAuthServer will mock a oauth service for the tests

newClientCredentialsRequest builds a new ClientCredentialsExchangeRequest wrapped in an http.Request

safeRespClose is used to close a response body

nolint:unparam

Returns a new instance of the same provider, with the same exact configuration

Close the producer and releases resources allocated No more writes will be accepted from this producer. Waits until all pending write request are pers

Close all the connections in the pool

CompareAndPoll compare the first item and poll it if meet the conditions

CreateSchemaByPayload creates a schema for a given <tt>topic</tt>

Encrypt payload using encryption keys and add encrypted data key to message metadata. Here data key is encrypted using public key

ForceDeleteSchema force deletes the schema associated with a given <tt>topic</tt>

GetAndAdd perform atomic read and update

GetBookieAffinityGroup returns bookie affinity group configured for a namespace. Returns nil if the bookie affinity group is not configured at the nam

GetConnection get a connection from ConnectionPool.

GetDeduplicationStatus returns the deduplication policy for a topic

GetInactiveTopicPolicies returns the inactive topic policies on a topic @param topic topicName struct @param applied when set to true, function will

GetLastMessageID get the last message id available for consume. It only works for single topic reader. It will return an error when the reader is the

GetMaxConsumersPerTopic returns the maxProducersPerTopic for a namespace. Returns -1 if not set

GetMaxProducersPerTopic returns the maxProducersPerTopic for a namespace. Returns -1 if not set

GetNamespaceMessageTTL returns the message TTL for a namespace. Returns -1 if not set

GetOffloadDeleteLag returns the offload deletion lag for a namespace, in milliseconds. Returns -1 if not set