Uses of Interface
org.apache.pulsar.common.policies.data.DispatchRate
Packages that use DispatchRate
Package
Description
Implementation of policies.
-
Uses of DispatchRate in org.apache.pulsar.client.admin
Methods in org.apache.pulsar.client.admin that return DispatchRateModifier and TypeMethodDescriptionNamespaces.getDispatchRate(String namespace) Get message-dispatch-rate (topics under this namespace can dispatch this many messages per second).TopicPolicies.getDispatchRate(String topic) Get message-dispatch-rate (topic can dispatch this many messages per second).TopicPolicies.getDispatchRate(String topic, boolean applied) Get applied message-dispatch-rate (topic can dispatch this many messages per second).Topics.getDispatchRate(String topic) Deprecated.Topics.getDispatchRate(String topic, boolean applied) Deprecated.UseTopicPolicies.getDispatchRate(String, boolean)instead.Namespaces.getReplicatorDispatchRate(String namespace) Get replicator-message-dispatch-rate.TopicPolicies.getReplicatorDispatchRate(String topic) Get replicatorDispatchRate for the topic.TopicPolicies.getReplicatorDispatchRate(String topic, boolean applied) Get applied replicatorDispatchRate for the topic.Topics.getReplicatorDispatchRate(String topic) Deprecated.UseTopicPolicies.getReplicatorDispatchRate(String)instead.Topics.getReplicatorDispatchRate(String topic, boolean applied) Deprecated.Namespaces.getSubscriptionDispatchRate(String namespace) Get subscription-message-dispatch-rate.TopicPolicies.getSubscriptionDispatchRate(String topic) Get subscription-message-dispatch-rate for the topic.TopicPolicies.getSubscriptionDispatchRate(String topic, boolean applied) Get applied subscription-message-dispatch-rate.TopicPolicies.getSubscriptionDispatchRate(String topic, String subscriptionName) Get subscription level dispatch rate limiter setting for a specific subscription.TopicPolicies.getSubscriptionDispatchRate(String topic, String subscriptionName, boolean applied) If applied is true, get dispatch rate limiter for a specific subscription.Topics.getSubscriptionDispatchRate(String topic) Deprecated.UseTopicPolicies.getSubscriptionDispatchRate(String)instead.Topics.getSubscriptionDispatchRate(String namespace, boolean applied) Deprecated.Methods in org.apache.pulsar.client.admin that return types with arguments of type DispatchRateModifier and TypeMethodDescriptionNamespaces.getDispatchRateAsync(String namespace) Get message-dispatch-rate asynchronously.TopicPolicies.getDispatchRateAsync(String topic) Get message-dispatch-rate asynchronously.TopicPolicies.getDispatchRateAsync(String topic, boolean applied) Get applied message-dispatch-rate asynchronously.Topics.getDispatchRateAsync(String topic) Deprecated.UseTopicPolicies.getDispatchRateAsync(String)instead.Topics.getDispatchRateAsync(String topic, boolean applied) Deprecated.UseTopicPolicies.getDispatchRateAsync(String, boolean)instead.Namespaces.getReplicatorDispatchRateAsync(String namespace) Get replicator-message-dispatch-rate asynchronously.TopicPolicies.getReplicatorDispatchRateAsync(String topic) Get replicatorDispatchRate asynchronously.TopicPolicies.getReplicatorDispatchRateAsync(String topic, boolean applied) Get applied replicatorDispatchRate asynchronously.Topics.getReplicatorDispatchRateAsync(String topic) Deprecated.UseTopicPolicies.getReplicatorDispatchRateAsync(String)instead.Topics.getReplicatorDispatchRateAsync(String topic, boolean applied) Deprecated.Namespaces.getSubscriptionDispatchRateAsync(String namespace) Get subscription-message-dispatch-rate asynchronously.TopicPolicies.getSubscriptionDispatchRateAsync(String topic) Get subscription-message-dispatch-rate asynchronously.TopicPolicies.getSubscriptionDispatchRateAsync(String topic, boolean applied) Get applied subscription-message-dispatch-rate asynchronously.TopicPolicies.getSubscriptionDispatchRateAsync(String topic, String subscriptionName) Async version ofTopicPolicies.getSubscriptionDispatchRate(String, String).TopicPolicies.getSubscriptionDispatchRateAsync(String topic, String subscriptionName, boolean applied) Async version ofTopicPolicies.getSubscriptionDispatchRate(String, String, boolean).Topics.getSubscriptionDispatchRateAsync(String topic) Deprecated.Topics.getSubscriptionDispatchRateAsync(String namespace, boolean applied) Deprecated.Methods in org.apache.pulsar.client.admin with parameters of type DispatchRateModifier and TypeMethodDescriptionvoidNamespaces.setDispatchRate(String namespace, DispatchRate dispatchRate) Set message-dispatch-rate (topics under this namespace can dispatch this many messages per second).voidTopicPolicies.setDispatchRate(String topic, DispatchRate dispatchRate) Set message-dispatch-rate (topic can dispatch this many messages per second).voidTopics.setDispatchRate(String topic, DispatchRate dispatchRate) Deprecated.UseTopicPolicies.setDispatchRate(String, DispatchRate)instead.Namespaces.setDispatchRateAsync(String namespace, DispatchRate dispatchRate) Set message-dispatch-rate asynchronously.TopicPolicies.setDispatchRateAsync(String topic, DispatchRate dispatchRate) Set message-dispatch-rate asynchronously.Topics.setDispatchRateAsync(String topic, DispatchRate dispatchRate) Deprecated.voidNamespaces.setReplicatorDispatchRate(String namespace, DispatchRate dispatchRate) Set replicator-message-dispatch-rate.voidTopicPolicies.setReplicatorDispatchRate(String topic, DispatchRate dispatchRate) Set replicatorDispatchRate for the topic.voidTopics.setReplicatorDispatchRate(String topic, DispatchRate dispatchRate) Deprecated.Namespaces.setReplicatorDispatchRateAsync(String namespace, DispatchRate dispatchRate) Set replicator-message-dispatch-rate asynchronously.TopicPolicies.setReplicatorDispatchRateAsync(String topic, DispatchRate dispatchRate) Set replicatorDispatchRate for the topic asynchronously.Topics.setReplicatorDispatchRateAsync(String topic, DispatchRate dispatchRate) Deprecated.voidNamespaces.setSubscriptionDispatchRate(String namespace, DispatchRate dispatchRate) Set subscription-message-dispatch-rate.voidTopicPolicies.setSubscriptionDispatchRate(String topic, String subscriptionName, DispatchRate dispatchRate) Set dispatch rate limiter for a specific subscription.voidTopicPolicies.setSubscriptionDispatchRate(String topic, DispatchRate dispatchRate) Set subscription-message-dispatch-rate for the topic.voidTopics.setSubscriptionDispatchRate(String topic, DispatchRate dispatchRate) Deprecated.Namespaces.setSubscriptionDispatchRateAsync(String namespace, DispatchRate dispatchRate) Set subscription-message-dispatch-rate asynchronously.TopicPolicies.setSubscriptionDispatchRateAsync(String topic, String subscriptionName, DispatchRate dispatchRate) Async version ofTopicPolicies.setSubscriptionDispatchRate(String, String, DispatchRate).TopicPolicies.setSubscriptionDispatchRateAsync(String topic, DispatchRate dispatchRate) Set subscription-message-dispatch-rate for the topic asynchronously.Topics.setSubscriptionDispatchRateAsync(String topic, DispatchRate dispatchRate) Deprecated. -
Uses of DispatchRate in org.apache.pulsar.common.policies.data
Methods in org.apache.pulsar.common.policies.data that return DispatchRate -
Uses of DispatchRate in org.apache.pulsar.common.policies.data.impl
Classes in org.apache.pulsar.common.policies.data.impl that implement DispatchRate
TopicPolicies.getDispatchRate(String)instead.