--- Helpers newGrabConnTestConsumer builds a minimal partitionConsumer wired to the given spy connection and RPC client, suitable for testing grabConn

topicDiff returns all topics in topics1 that are not in topics2

Abort You can abort the transaction when you want to abort all the sending/acknowledging operations with the transaction.

AddPublicKeyCipher encrypt data key using keyCrypto and cache

ConvertToStringMap convert a KeyValue []byte to string map

GetLastMessageIDs get all the last message id of the topics the consumer subscribed. The list of MessageID instances of all the topics that the consu

GetPartitionedStats returns the stats for the partitioned topic All the rates are computed over a 1-minute window and are relative the last completed

GetReplicationClusters returns the replication clusters of a topic

GetWithContext returns the configuration data for the specified cluster

Metadata get key metadata

NewAuthenticationTLS Creates new Authentication provider with specified TLS certificate and private key

NewEncryptionKeyInfo create a new EncryptionKeyInfo

NewLz4Provider return a interface of Provider.

NewZLibProvider returns a Provider interface

Next returns the delay to wait before next retry

SetSchemaCompatibilityStrategy sets schema compatibility strategy for a topic

WrittenBytes advance the writer index when data was written in a slice

AckCumulative the reception of all the messages in the stream up to (and including) the provided message.

AckWithTxn the consumption of a single message with a transaction

Capacity returns the capacity of the buffer's underlying byte slice, that is, the total space allocated for the buffer's data.

Close the consumer and stop the broker to push more messages

ConnectionClosed close the TCP connection.

CreateTableView creates a table view instance. This method will block until the table view is created successfully.

Decrypt the payload using decrypted data key. Here data key is read from the message metadata and decrypted using private key.

DeserializeMessageID reconstruct a MessageID object from its serialized representation

EncryptionParam read the ecryption parameter from the MessageMetadata

GenerateRoundRobinIndex generates a round-robin index.

GetAutoSubscriptionCreation returns auto subscription creation override for a topic. Returns nil if the auto subscription creation override is not con

GetBacklogQuotaMap returns backlog quota map for a topic @param topic topicName struct @param applied when set to true, function will try to find pol

GetDeduplicationSnapshotInterval returns deduplication snapshot interval for a topic. Returns -1 if not set

GetDelayedDelivery returns the delayed delivery policy for a topic. Returns nil if the delayed delivery policy is not configured at the topic level.

GetDispatchRate returns message dispatch rate for a topic. Returns nil if the dispatch rate is not configured at the topic level.

GetMaxConsumers returns max number of consumers for a topic. Returns -1 if not set

GetMaxProducers Get max number of producers for a topic. Returns -1 if not set

GetMaxSubscriptionsPerTopic returns max subscriptions per topic. Returns -1 if not set

GetMaxUnackMessagesPerConsumer returns max unacked messages policy on consumer for a topic. Returns -1 if not set

GetMaxUnackMessagesPerSubscription returns max unacked messages policy on subscription for a topic. Returns -1 if not set

GetMetadata returns metadata of a partitioned topic

GetOffloadPolicies returns offload policies for a topic. Returns nil if the offload policies are not configured at the topic level.

GetPublishRate returns message publish rate for a topic. Returns nil if the publish rate is not configured at the topic level.

GetReplicatorDispatchRate returns replicator dispatch rate for a topic. Returns nil if the replicator dispatch rate is not configured at the topic lev

GetSchemaCompatibilityStrategyApplied returns schema compatibility strategy for a topic. @param topic topicName struct @param applied when set to tru

GetSchemaValidationEnforced returns schema validation enforced flag for a topic

GetSubscribeRate returns subscribe rate configuration for a topic. Returns nil if the subscribe rate is not configured at the topic level.