Package org.apache.pulsar.common.policies.data

Class Policies

java.lang.Object
org.apache.pulsar.common.policies.data.Policies
public class Policies extends Object
Definition of Pulsar policies.

  • Field Details

    • auth_policies

      public final AuthPolicies auth_policies

    • replication_clusters

      public Set<String> replication_clusters

    • allowed_clusters

      public Set<String> allowed_clusters
      This field has a unique usage: defines whether a namespace is allowed to access by the current cluster. Instead of access this field directly, please call
      invalid reference 
      BrokerService#isCurrentClusterAllowed
      .

    • bundles

      public BundlesData bundles

    • backlog_quota_map

      public Map<BacklogQuota.BacklogQuotaType,BacklogQuota> backlog_quota_map

    • clusterDispatchRate

      @Deprecated public Map<String,DispatchRateImpl> clusterDispatchRate
      Deprecated.

    • topicDispatchRate

      public Map<String,DispatchRateImpl> topicDispatchRate

    • subscriptionDispatchRate

      public Map<String,DispatchRateImpl> subscriptionDispatchRate

    • replicatorDispatchRate

      public Map<String,DispatchRateImpl> replicatorDispatchRate

    • clusterSubscribeRate

      public Map<String,SubscribeRate> clusterSubscribeRate

    • persistence

      public PersistencePolicies persistence

    • deduplicationEnabled

      public Boolean deduplicationEnabled

    • autoTopicCreationOverride

      public AutoTopicCreationOverride autoTopicCreationOverride

    • autoSubscriptionCreationOverride

      public AutoSubscriptionCreationOverride autoSubscriptionCreationOverride

    • publishMaxMessageRate

      public Map<String,PublishRate> publishMaxMessageRate

    • latency_stats_sample_rate

      public Map<String,Integer> latency_stats_sample_rate

    • message_ttl_in_seconds

      public Integer message_ttl_in_seconds

    • subscription_expiration_time_minutes

      public Integer subscription_expiration_time_minutes

    • retention_policies

      public RetentionPolicies retention_policies

    • deleted

      public boolean deleted

    • FIRST_BOUNDARY

      public static final String FIRST_BOUNDARY
      See Also:

    • LAST_BOUNDARY

      public static final String LAST_BOUNDARY
      See Also:

    • encryption_required

      public boolean encryption_required

    • delayed_delivery_policies

      public DelayedDeliveryPolicies delayed_delivery_policies

    • inactive_topic_policies

      public InactiveTopicPolicies inactive_topic_policies

    • subscription_auth_mode

      public SubscriptionAuthMode subscription_auth_mode

    • max_producers_per_topic

      public Integer max_producers_per_topic

    • max_consumers_per_topic

      public Integer max_consumers_per_topic

    • max_consumers_per_subscription

      public Integer max_consumers_per_subscription

    • max_unacked_messages_per_consumer

      public Integer max_unacked_messages_per_consumer

    • max_unacked_messages_per_subscription

      public Integer max_unacked_messages_per_subscription

    • max_subscriptions_per_topic

      public Integer max_subscriptions_per_topic

    • compaction_threshold

      public Long compaction_threshold

    • offload_threshold

      public long offload_threshold

    • offload_threshold_in_seconds

      public long offload_threshold_in_seconds

    • offload_deletion_lag_ms

      public Long offload_deletion_lag_ms

    • max_topics_per_namespace

      public Integer max_topics_per_namespace

    • schema_auto_update_compatibility_strategy

      @Deprecated public SchemaAutoUpdateCompatibilityStrategy schema_auto_update_compatibility_strategy
      Deprecated.

    • schema_compatibility_strategy

      public SchemaCompatibilityStrategy schema_compatibility_strategy

    • is_allow_auto_update_schema

      public Boolean is_allow_auto_update_schema

    • schema_validation_enforced

      public boolean schema_validation_enforced

    • offload_policies

      public OffloadPolicies offload_policies

    • deduplicationSnapshotIntervalSeconds

      public Integer deduplicationSnapshotIntervalSeconds

    • subscription_types_enabled

      public Set<String> subscription_types_enabled

    • properties

      public Map<String,String> properties

    • resource_group_name

      public String resource_group_name

    • migrated

      public boolean migrated

    • dispatcherPauseOnAckStatePersistentEnabled

      public Boolean dispatcherPauseOnAckStatePersistentEnabled

    • entryFilters

      public EntryFilters entryFilters

  • Constructor Details

    • Policies

      public Policies()

  • Method Details

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object

    • getClusterThatCanDeleteNamespace

      public String getClusterThatCanDeleteNamespace()
      Get the cluster that can delete the namespace.

    • checkNewReplicationClusters

      public static boolean checkNewReplicationClusters(Policies oldNsPolicies, Set<String> newReplicationClusters)
      Replication clusters should be included in allowed clusters.

    • checkNewAllowedClusters

      public static boolean checkNewAllowedClusters(Policies oldNsPolicies, Set<String> newAllowedClusters)
      Allowed cluster should contain all clusters that are defined in replication clusters.

    • checkAllowedAndReplicationClusters

      public boolean checkAllowedAndReplicationClusters()
      Replication clusters should be included in allowed clusters if allowed clusters are not empty.