safeRespClose is used to close a response body

Authorize obtains an authorization grant based on an OAuth 2.0 authorization flow. The method returns a grant which may contain an initial access toke

ConvertFromStringMap convert a string map to a KeyValue []byte

GetProperties returns the properties of a topic

GetSchemaCompatibilityStrategy returns the applied schema compatibility strategy for a topic.

NewDefaultRouter set the message routing mode for the partitioned producer. Default routing mode is round-robin routing if no partition key is specifi

NewJSONSchema creates a new JSONSchema Note: the function will panic if creation of codec fails

NewMemoryLimitController threshold valid range is (0, 1.0)

Peek return the first item without dequeing, return nil if queue is empty

Refresh refreshes an authorization grant to contain a fresh access token

Seek resets the subscription associated with this reader to a specific message id. The message id can either be a specific message or represent the fi

handleAuthTokensResponse takes care of checking an http.Response that has auth tokens for errors and parsing the raw body to a TokenResult struct

AckIDCumulative the reception of all the messages in the stream up to (and including) the provided message, identified by its MessageID

Compress a []byte, the param is a []byte with the uncompressed content. The reader/writer indexes will not be modified. The return is a []byte with th

Decompress a []byte. The buffer needs to have been compressed with the matching Encoder. The src is compressed content. If dst is passed, the decompre

GetMaxConsumersPerSubscription returns max consumers per subscription for a topic. Returns -1 if not set

GetMaxMessageSize returns max message size for a topic. Returns -1 if not set

GetMessagesByID gets messages by its ledgerID and entryID

GetPersistence returns the persistence policies for a topic. Returns nil if the persistence policy is not configured at the topic level.

GetRetention returns the retention configuration for a topic. Returns nil if the retention policy is not configured at the topic level. @param topic

GetTopicsOfNamespace returns all the topics name for a given namespace.

PeekLast return last item in queue without dequeing, return nil if queue is empty

ReconsumeLater mark a message for redelivery after custom delay

SeekByTime resets the subscription associated with this reader to a specific message publish time. Note: this operation can only be done on non-parti

Take dequeue one item, block until it's available

Acquire a permit, if one is available and returns immediately, reducing the number of available permits by one.

Delete deletes a topic, this function can delete both partitioned or non-partitioned topic @param topic topicName struct @param force delete topic fo

EncryptionKeys read all the encryption keys from the MessageMetadata

GetCompactionThreshold returns the compaction threshold for a topic. Returns -1 if not set i.e. The maximum number of bytes can have before compactio

GetOIDCWellKnownEndpointsFromIssuerURL gets the well known endpoints for the passed in issuer url

GetPartitionedTopicMetadata perform a CommandPartitionedTopicMetadata request for the given topic, returns the CommandPartitionedTopicMetadataResponse

GetStats returns the stats for the topic. All the rates are computed over a 1-minute window and are relative the last completed 1-minute period

IterateUnsafe iterates the items in the queue without blocking the queue

Lookup returns the broker URL that serves the topic

NackID acknowledges the failure to process a single message. When a message is "negatively acked" it will be marked for redelivery after some fixed d

NewAuthenticationOAuth2WithParams return a interface of Provider with string map.

NewAuthenticationToken return a interface of Provider with a string token.

Poll dequeue one item, return nil if queue is empty

Terminate terminates the topic and prevent any more messages being published on it

TopicPoliciesOf returns a scoped topic policy client when the provided admin client supports it.

Try to acquire a permit. The method will return immediately with a `true` if it was possible to acquire a permit and `false` otherwise.