Index (Pulsar Client Admin :: API 2.10.2 API)

A B C D E F G H I J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

aborted - Variable in class org.apache.pulsar.common.policies.data.TransactionInBufferStats: The flag of this transaction have been aborted.
ackedPartitions - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata: The ackedPartitions of this transaction.
active(boolean) - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus.Builder
active(boolean) - Method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies.Builder
active(boolean) - Method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl.BrokerStatusImplBuilder
active(boolean) - Method in class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl.DelayedDeliveryPoliciesImplBuilder
add(NonPersistentTopicStats) - Method in interface org.apache.pulsar.common.policies.data.NonPersistentPartitionedTopicStats
add(ResourceQuota) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota: Add quota.
add(TopicStats) - Method in interface org.apache.pulsar.common.policies.data.PartitionedTopicStats
addInstance(FunctionStatus.FunctionInstanceStatus) - Method in class org.apache.pulsar.common.policies.data.FunctionStatus
addInstance(SinkStatus.SinkInstanceStatus) - Method in class org.apache.pulsar.common.policies.data.SinkStatus
addInstance(SourceStatus.SourceInstanceStatus) - Method in class org.apache.pulsar.common.policies.data.SourceStatus
adminRoles(Set<String>) - Method in interface org.apache.pulsar.common.policies.data.TenantInfo.Builder
AllocatorStats - Class in org.apache.pulsar.common.stats: Allocator statistics.
AllocatorStats() - Constructor for class org.apache.pulsar.common.stats.AllocatorStats
AllocatorStats.PoolArenaStats - Class in org.apache.pulsar.common.stats: Pool arena statistics.
AllocatorStats.PoolChunkListStats - Class in org.apache.pulsar.common.stats: Pool chunk list statistics.
AllocatorStats.PoolChunkStats - Class in org.apache.pulsar.common.stats: Pool chunk statistics.
AllocatorStats.PoolSubpageStats - Class in org.apache.pulsar.common.stats: Pool subpage statistics.
allowAutoSubscriptionCreation(boolean) - Method in interface org.apache.pulsar.common.policies.data.AutoSubscriptionCreationOverride.Builder
allowAutoSubscriptionCreation(boolean) - Method in class org.apache.pulsar.common.policies.data.impl.AutoSubscriptionCreationOverrideImpl.AutoSubscriptionCreationOverrideImplBuilder
allowAutoTopicCreation(boolean) - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride.Builder
allowAutoTopicCreation(boolean) - Method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder
allowedClusters(Set<String>) - Method in interface org.apache.pulsar.common.policies.data.TenantInfo.Builder
allowTlsInsecureConnection(boolean) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Configure whether the Pulsar admin client accept untrusted TLS certificate from broker (default: false).
ALWAYS_COMPATIBLE - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Always compatible.
ALWAYS_INCOMPATIBLE - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Always incompatible.
AlwaysCompatible - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy: Always Compatible - The new schema will not be checked for compatibility against old schemas.
ATLEAST_ONCE - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees
ATMOST_ONCE - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees
auth_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
AuthAction - Enum Class in org.apache.pulsar.common.policies.data: Authorization action for Pulsar policies.
authentication(String, String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Set the authentication provider to use in the Pulsar client instance.
authentication(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Set the authentication provider to use in the Pulsar client instance.
authentication(Authentication) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Set the authentication provider to use in the Pulsar admin instance.
AuthenticationConfig - Class in org.apache.pulsar.common.functions: Configuration to aggregate various authentication params.
AuthenticationConfig() - Constructor for class org.apache.pulsar.common.functions.AuthenticationConfig
authenticationParameters(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
authenticationPlugin(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
AuthPolicies - Interface in org.apache.pulsar.common.policies.data: Authentication policies.
AuthPolicies.Builder - Interface in org.apache.pulsar.common.policies.data
autoCertRefreshTime(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: This sets auto cert refresh time if Pulsar admin uses tls authentication.
autoFailoverPolicy(AutoFailoverPolicyData) - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData.Builder
AutoFailoverPolicy - Class in org.apache.pulsar.common.policies: Basic definition of an auto-failover policy.
AutoFailoverPolicy() - Constructor for class org.apache.pulsar.common.policies.AutoFailoverPolicy
AutoFailoverPolicyData - Interface in org.apache.pulsar.common.policies.data
AutoFailoverPolicyData.Builder - Interface in org.apache.pulsar.common.policies.data
AutoFailoverPolicyFactory - Class in org.apache.pulsar.common.policies.impl: Factory to generate an instance of AutoFailoverPolicy.
AutoFailoverPolicyFactory() - Constructor for class org.apache.pulsar.common.policies.impl.AutoFailoverPolicyFactory
AutoFailoverPolicyType - Enum Class in org.apache.pulsar.common.policies.data: The policy type of auto failover.
autoSubscriptionCreationOverride - Variable in class org.apache.pulsar.common.policies.data.Policies
AutoSubscriptionCreationOverride - Interface in org.apache.pulsar.common.policies.data: Override of autoSubscriptionCreation settings on a namespace level.
AutoSubscriptionCreationOverride.Builder - Interface in org.apache.pulsar.common.policies.data
AutoSubscriptionCreationOverrideImpl - Class in org.apache.pulsar.common.policies.data.impl: Override of autoSubscriptionCreation settings on a namespace level.
AutoSubscriptionCreationOverrideImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.AutoSubscriptionCreationOverrideImpl
AutoSubscriptionCreationOverrideImpl.AutoSubscriptionCreationOverrideImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
AutoSubscriptionCreationOverrideImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.AutoSubscriptionCreationOverrideImpl.AutoSubscriptionCreationOverrideImplBuilder
autoTopicCreationOverride - Variable in class org.apache.pulsar.common.policies.data.Policies
AutoTopicCreationOverride - Interface in org.apache.pulsar.common.policies.data: Override of autoTopicCreation settings on a namespace level.
AutoTopicCreationOverride.Builder - Interface in org.apache.pulsar.common.policies.data
AutoTopicCreationOverrideImpl - Class in org.apache.pulsar.common.policies.data.impl: Override of autoTopicCreation settings on a namespace level.
AutoTopicCreationOverrideImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl
AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
AutoTopicCreationOverrideImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder
AutoUpdateDisabled - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy: Don't allow any auto updates.
averageLatency - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData

B

backlog_quota_map - Variable in class org.apache.pulsar.common.policies.data.Policies
BacklogQuota - Interface in org.apache.pulsar.common.policies.data: Unit of a backlog quota configuration for a scoped resource in a Pulsar instance.
BacklogQuota.BacklogQuotaType - Enum Class in org.apache.pulsar.common.policies.data: Identifier to a backlog quota configuration (an instance of BacklogQuota).
BacklogQuota.Builder - Interface in org.apache.pulsar.common.policies.data
BacklogQuota.RetentionPolicy - Enum Class in org.apache.pulsar.common.policies.data: Enumeration type determines how to retain backlog against the resource shortages.
backlogQuotaCheck() - Method in interface org.apache.pulsar.client.admin.Brokers: Manually trigger backlogQuotaCheck.
backlogQuotaCheckAsync() - Method in interface org.apache.pulsar.client.admin.Brokers: Manually trigger backlogQuotaCheck asynchronously.
BacklogQuotaImpl - Class in org.apache.pulsar.common.policies.data.impl
BacklogQuotaImpl(long, int, BacklogQuota.RetentionPolicy) - Constructor for class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
BacklogQuotaImpl.BacklogQuotaImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
BacklogQuotaImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl.BacklogQuotaImplBuilder
Backward - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy: Messages written in the previous schema can be read by the new schema.
BACKWARD - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Messages written by an old schema can be read by a new schema.
BACKWARD_TRANSITIVE - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Be similar to BACKWARD, BACKWARD_TRANSITIVE ensure all previous version schema can be read by the new schema.
BackwardTransitive - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy: Be similar to Backward.
BATCHSOURCE_CLASSNAME_KEY - Static variable in class org.apache.pulsar.common.io.BatchSourceConfig
BATCHSOURCE_CONFIG_KEY - Static variable in class org.apache.pulsar.common.io.BatchSourceConfig
BatchSourceConfig - Class in org.apache.pulsar.common.io: Pulsar Batch Source configuration.
BatchSourceConfig() - Constructor for class org.apache.pulsar.common.io.BatchSourceConfig
BookieAffinityGroupData - Interface in org.apache.pulsar.common.policies.data: Description of a BookKeeper's affinity group.
BookieAffinityGroupData.Builder - Interface in org.apache.pulsar.common.policies.data
BookieAffinityGroupDataImpl - Class in org.apache.pulsar.common.policies.data.impl: Description of a BookKeeper's affinity group.
BookieAffinityGroupDataImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl
BookieAffinityGroupDataImpl.BookieAffinityGroupDataImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
BookieAffinityGroupDataImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl.BookieAffinityGroupDataImplBuilder
BookieInfo - Interface in org.apache.pulsar.common.policies.data: Bookie information.
BookieInfo.Builder - Interface in org.apache.pulsar.common.policies.data
BookieInfoImpl - Class in org.apache.pulsar.common.policies.data.impl: Bookie information.
BookieInfoImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl
BookieInfoImpl.BookieInfoImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
BookieInfoImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl.BookieInfoImplBuilder
bookies() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
bookies(List<RawBookieInfo>) - Method in interface org.apache.pulsar.common.policies.data.BookiesClusterInfo.Builder
bookies(List<RawBookieInfo>) - Method in class org.apache.pulsar.common.policies.data.impl.BookiesClusterInfoImpl.BookiesClusterInfoImplBuilder
Bookies - Interface in org.apache.pulsar.client.admin: Admin interface for bookies rack placement management.
BookiesClusterInfo - Interface in org.apache.pulsar.common.policies.data: Raw bookies information.
BookiesClusterInfo.Builder - Interface in org.apache.pulsar.common.policies.data
BookiesClusterInfoImpl - Class in org.apache.pulsar.common.policies.data.impl: Raw bookies information.
BookiesClusterInfoImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookiesClusterInfoImpl
BookiesClusterInfoImpl.BookiesClusterInfoImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
BookiesClusterInfoImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BookiesClusterInfoImpl.BookiesClusterInfoImplBuilder
BookiesRackConfiguration - Class in org.apache.pulsar.common.policies.data: The rack configuration map for bookies.
BookiesRackConfiguration() - Constructor for class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
BOOKKEEPER_FIRST - Enum constant in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority: For offloaded messages, readers will try to read from bookkeeper at first, if messages not exist at bookkeeper then read from offloaded storage.
bookkeeperAffinityGroupPrimary(String) - Method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData.Builder
bookkeeperAffinityGroupPrimary(String) - Method in class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl.BookieAffinityGroupDataImplBuilder
bookkeeperAffinityGroupSecondary(String) - Method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData.Builder
bookkeeperAffinityGroupSecondary(String) - Method in class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl.BookieAffinityGroupDataImplBuilder
boundaries(List<String>) - Method in interface org.apache.pulsar.common.policies.data.BundlesData.Builder
boundaries(List<String>) - Method in class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl.BundlesDataImplBuilder
broker_assignment - Variable in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
brokerAddress(String) - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus.Builder
brokerAddress(String) - Method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl.BrokerStatusImplBuilder
BrokerAssignment - Enum Class in org.apache.pulsar.common.policies.data: Definition of possible broker assignments.
brokerClientTlsEnabled(boolean) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
brokerClientTlsEnabledWithKeyStore(boolean) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
brokerClientTlsTrustStore(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
brokerClientTlsTrustStorePassword(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
brokerClientTlsTrustStoreType(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
brokerClientTrustCertsFilePath(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
BrokerInfo - Interface in org.apache.pulsar.common.policies.data: Broker Information.
BrokerInfo.Builder - Interface in org.apache.pulsar.common.policies.data
BrokerInfoImpl - Class in org.apache.pulsar.common.policies.data.impl: Broker Information.
BrokerInfoImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BrokerInfoImpl
BrokerInfoImpl.BrokerInfoImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
BrokerInfoImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BrokerInfoImpl.BrokerInfoImplBuilder
brokerName(String) - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData.Builder
BrokerNamespaceIsolationData - Interface in org.apache.pulsar.common.policies.data
BrokerNamespaceIsolationData.Builder - Interface in org.apache.pulsar.common.policies.data
brokers() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
brokers(Set<String>) - Method in interface org.apache.pulsar.common.policies.data.FailureDomain.Builder
Brokers - Interface in org.apache.pulsar.client.admin: Admin interface for brokers management.
brokerServiceUrl(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
brokerServiceUrlTls(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
brokerStats() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
BrokerStats - Interface in org.apache.pulsar.client.admin: Admin interface for brokers management.
BrokerStatus - Interface in org.apache.pulsar.common.policies.data: Information about the broker status.
BrokerStatus.Builder - Interface in org.apache.pulsar.common.policies.data
BrokerStatusImpl - Class in org.apache.pulsar.common.policies.data.impl: Information about the broker status.
BrokerStatusImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl
BrokerStatusImpl.BrokerStatusImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
BrokerStatusImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl.BrokerStatusImplBuilder
build() - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
build() - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.AutoSubscriptionCreationOverride.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.BookieInfo.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.BookiesClusterInfo.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.BrokerInfo.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.BundlesData.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.DispatchRate.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.FailureDomain.Builder
build() - Method in class org.apache.pulsar.common.policies.data.impl.AutoSubscriptionCreationOverrideImpl.AutoSubscriptionCreationOverrideImplBuilder
build() - Method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder
build() - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl.BacklogQuotaImplBuilder
build() - Method in class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl.BookieAffinityGroupDataImplBuilder
build() - Method in class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl.BookieInfoImplBuilder
build() - Method in class org.apache.pulsar.common.policies.data.impl.BookiesClusterInfoImpl.BookiesClusterInfoImplBuilder
build() - Method in class org.apache.pulsar.common.policies.data.impl.BrokerInfoImpl.BrokerInfoImplBuilder
build() - Method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl.BrokerStatusImplBuilder
build() - Method in class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl.BundlesDataImplBuilder
build() - Method in class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl.DelayedDeliveryPoliciesImplBuilder
build() - Method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
build() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
build() - Method in interface org.apache.pulsar.common.policies.data.TenantInfo.Builder
builder() - Static method in interface org.apache.pulsar.client.admin.PulsarAdmin: Get a new builder instance that can used to configure and build a PulsarAdmin instance.
builder() - Static method in interface org.apache.pulsar.common.policies.data.AuthPolicies
builder() - Static method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
builder() - Static method in interface org.apache.pulsar.common.policies.data.AutoSubscriptionCreationOverride
builder() - Static method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride
builder() - Static method in interface org.apache.pulsar.common.policies.data.BacklogQuota
builder() - Static method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData
builder() - Static method in interface org.apache.pulsar.common.policies.data.BookieInfo
builder() - Static method in interface org.apache.pulsar.common.policies.data.BookiesClusterInfo
builder() - Static method in interface org.apache.pulsar.common.policies.data.BrokerInfo
builder() - Static method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
builder() - Static method in interface org.apache.pulsar.common.policies.data.BrokerStatus
builder() - Static method in interface org.apache.pulsar.common.policies.data.BundlesData
builder() - Static method in interface org.apache.pulsar.common.policies.data.ClusterData
builder() - Static method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies
builder() - Static method in interface org.apache.pulsar.common.policies.data.DispatchRate
builder() - Static method in interface org.apache.pulsar.common.policies.data.FailureDomain
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.AutoSubscriptionCreationOverrideImpl
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BookieAffinityGroupDataImpl
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BookiesClusterInfoImpl
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BrokerInfoImpl
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl
builder() - Static method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl
builder() - Static method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
builder() - Static method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
builder() - Static method in interface org.apache.pulsar.common.policies.data.TenantInfo
Bundle - Enum constant in enum class org.apache.pulsar.client.admin.Topics.QueryParam
bundles - Variable in class org.apache.pulsar.common.policies.data.Policies
BundlesData - Interface in org.apache.pulsar.common.policies.data: Holder for bundles.
BundlesData.Builder - Interface in org.apache.pulsar.common.policies.data
BundlesDataImpl - Class in org.apache.pulsar.common.policies.data.impl: Holder for bundles.
BundlesDataImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl
BundlesDataImpl.BundlesDataImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
BundlesDataImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl.BundlesDataImplBuilder
BYTES_IN_GIGABYTE - Static variable in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl

C

cacheSize - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
calculateOverall() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
checkArgument(boolean, Object) - Static method in class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl.BookieInfoImplBuilder
chunkLists - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
chunks - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkListStats
chunkSize - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkStats
clearNamespaceBacklog(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for all topics on a namespace.
clearNamespaceBacklogAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for all topics on a namespace asynchronously.
clearNamespaceBacklogForSubscription(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for a given subscription on all topics on a namespace.
clearNamespaceBacklogForSubscriptionAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for a given subscription on all topics on a namespace asynchronously.
clearNamespaceBundleBacklog(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for all topics on a namespace bundle.
clearNamespaceBundleBacklogAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for all topics on a namespace bundle asynchronously.
clearNamespaceBundleBacklogForSubscription(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for a given subscription on all topics on a namespace bundle.
clearNamespaceBundleBacklogForSubscriptionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for a given subscription on all topics on a namespace bundle asynchronously.
clearOffloadDeleteLag(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear the offload deletion lag for a namespace.
clearOffloadDeleteLagAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear the offload deletion lag for a namespace asynchronously.
clearProperties(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear all properties of a namespace.
clearPropertiesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear all properties of a namespace asynchronously.
clone() - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Create a copy of the current client builder.
clone() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
close() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin: Close the PulsarAdminClient and release all the resources.
ClusterData - Interface in org.apache.pulsar.common.policies.data
ClusterData.Builder - Interface in org.apache.pulsar.common.policies.data
clusterDispatchRate - Variable in class org.apache.pulsar.common.policies.data.Policies: Deprecated.
clusters() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Clusters - Interface in org.apache.pulsar.client.admin: Admin interface for clusters management.
clusterSubscribeRate - Variable in class org.apache.pulsar.common.policies.data.Policies
compactedLedger - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
compaction_threshold - Variable in class org.apache.pulsar.common.policies.data.Policies
CompactionStats - Interface in org.apache.pulsar.common.policies.data: Statistics about compaction.
compactionStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics: Check the status of an ongoing compaction for a topic.
compactionStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Check the status of an ongoing compaction for a topic asynchronously.
compareByBandwidthIn(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
compareByBandwidthOut(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
compareByCacheSize(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
compareByMsgRate(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
compareByTopicConnections(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
compareTo(BrokerStatus) - Method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl
compareTo(NamespaceBundleStats) - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
compareTo(ResourceUsage) - Method in class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage: this may be wrong since we are comparing available and not the usage.
ConflictException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConflictException
ConnectException(String, Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConnectException
ConnectException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConnectException
connectionTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: This sets the connection time out for the pulsar admin client.
ConnectorDefinition - Class in org.apache.pulsar.common.io: Basic information about a Pulsar connector.
ConnectorDefinition() - Constructor for class org.apache.pulsar.common.io.ConnectorDefinition
consume - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction: Permission to consume messages.
consumer_backlog_eviction - Enum constant in enum class org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy: Policy which evicts the oldest message from the slowest consumer's backlog.
ConsumerConfig - Class in org.apache.pulsar.common.functions: Configuration of a consumer.
ConsumerConfig(String) - Constructor for class org.apache.pulsar.common.functions.ConsumerConfig
consumerCount - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
ConsumerStats - Interface in org.apache.pulsar.common.policies.data: Consumer statistics.
create(Map<String, String>) - Static method in class org.apache.pulsar.common.stats.Metrics: Creates a metrics object with the dimensions map immutable.
create(AutoFailoverPolicyData) - Static method in class org.apache.pulsar.common.policies.impl.AutoFailoverPolicyFactory
createCluster(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters: Create a new cluster.
createClusterAsync(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters: Create a new cluster asynchronously.
createFailureDomain(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters: Create a domain into cluster.
createFailureDomainAsync(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters: Create a domain into cluster asynchronously.
createFunction(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Create a new function.
createFunctionAsync(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Create a new function asynchronously.
createFunctionWithUrl(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Create a new function with package url.
createFunctionWithUrlAsync(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Create a new function with package url asynchronously.
createMissedPartitions(String) - Method in interface org.apache.pulsar.client.admin.Topics: Create missed partitions for partitioned topic.
createMissedPartitionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Create missed partitions for partitioned topic asynchronously.
createNamespace(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace.
createNamespace(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace.
createNamespace(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace.
createNamespace(String, BundlesData) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace.
createNamespace(String, Policies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace.
createNamespaceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace asynchronously.
createNamespaceAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace.
createNamespaceAsync(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace asynchronously.
createNamespaceAsync(String, BundlesData) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace asynchronously.
createNamespaceAsync(String, Policies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace asynchronously.
createNamespaceIsolationPolicy(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters: Create a namespace isolation policy for a cluster.
createNamespaceIsolationPolicyAsync(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters: Create a namespace isolation policy for a cluster asynchronously.
createNonPartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics: Create a non-partitioned topic.
createNonPartitionedTopic(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics: Create a non-partitioned topic.
createNonPartitionedTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Create a non-partitioned topic asynchronously.
createNonPartitionedTopicAsync(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics: Create a non-partitioned topic asynchronously.
createPartitionedTopic(String, int) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Create a partitioned topic.
createPartitionedTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Create a partitioned topic.
createPartitionedTopic(String, int, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics: Create a partitioned topic.
createPartitionedTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Create a partitioned topic asynchronously.
createPartitionedTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Create a partitioned topic asynchronously.
createPartitionedTopicAsync(String, int, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics: Create a partitioned topic asynchronously.
createProperty(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Properties: Deprecated.

Create a new property.
createResourceGroup(String, ResourceGroup) - Method in interface org.apache.pulsar.client.admin.ResourceGroups: Create a new resourcegroup.
createResourceGroupAsync(String, ResourceGroup) - Method in interface org.apache.pulsar.client.admin.ResourceGroups: Create a new resourcegroup.
createSchema(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas: Create a schema for a given topic.
createSchema(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas: Create a schema for a given topic with the provided schema info.
createSchemaAsync(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas: Create a schema for a given topic asynchronously.
createSchemaAsync(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas: Create a schema for a given topic with the provided schema info asynchronously.
createSink(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Create a new sink.
createSinkAsync(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Create a new sink asynchronously.
createSinkWithUrl(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Create a new sink with package url.
createSinkWithUrlAsync(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Create a new sink with package url asynchronously.
createSource(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Create a new source.
createSourceAsync(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Create a new source asynchronously.
createSourceWithUrl(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Create a new source with package url.
createSourceWithUrlAsync(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Create a new source with package url asynchronously.
createSubscription(String, String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics: Create a new subscription on a topic.
createSubscription(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Create a new subscription on a topic.
createSubscription(String, String, MessageId, boolean, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics: Create a new subscription on a topic.
createSubscriptionAsync(String, String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics: Create a new subscription on a topic.
createSubscriptionAsync(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Create a new subscription on a topic.
createSubscriptionAsync(String, String, MessageId, boolean, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics: Create a new subscription on a topic.
createTenant(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants: Create a new tenant.
createTenantAsync(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants: Create a new tenant asynchronously.
CryptoConfig - Class in org.apache.pulsar.common.functions: Configuration of the producer inside the function.
CryptoConfig() - Constructor for class org.apache.pulsar.common.functions.CryptoConfig
cumulativeAckPosition - Variable in class org.apache.pulsar.common.policies.data.TransactionInPendingAckStats: The position of this transaction cumulative ack.
currentLedgerEntries - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The count of messages written to the ledger that is currently open for writing.
currentLedgerSize - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The size of messages written to the ledger that is currently open for writing (in bytes).
cursorLedger - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
cursorLedgerLastEntry - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
cursors - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The list of all cursors on this topic.
CursorStats() - Constructor for class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats

D

deduplicationEnabled - Variable in class org.apache.pulsar.common.policies.data.Policies
deduplicationSnapshotIntervalSeconds - Variable in class org.apache.pulsar.common.policies.data.Policies
DefaultImplementation - Class in org.apache.pulsar.client.admin.utils: Helper class for class instantiations and it also contains methods to work with schemas.
DefaultImplementation() - Constructor for class org.apache.pulsar.client.admin.utils.DefaultImplementation
defaultNumPartitions(Integer) - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride.Builder
defaultNumPartitions(Integer) - Method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder
delayed_delivery_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
DelayedDeliveryPolicies - Interface in org.apache.pulsar.common.policies.data: Definition of the delayed delivery policy.
DelayedDeliveryPolicies.Builder - Interface in org.apache.pulsar.common.policies.data
DelayedDeliveryPoliciesImpl - Class in org.apache.pulsar.common.policies.data.impl: Definition of the delayed delivery policy.
DelayedDeliveryPoliciesImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl
DelayedDeliveryPoliciesImpl.DelayedDeliveryPoliciesImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
DelayedDeliveryPoliciesImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl.DelayedDeliveryPoliciesImplBuilder
delete(String) - Method in interface org.apache.pulsar.client.admin.Packages: Delete the specified package.
delete(String) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a topic.
delete(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
delete(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a topic.
delete_when_no_subscriptions - Enum constant in enum class org.apache.pulsar.common.policies.data.InactiveTopicDeleteMode: The topic can be deleted when no subscriptions and no active producers.
delete_when_subscriptions_caught_up - Enum constant in enum class org.apache.pulsar.common.policies.data.InactiveTopicDeleteMode: The topic can be deleted when all subscriptions catchup and no active producers/consumers.
deleteAsync(String) - Method in interface org.apache.pulsar.client.admin.Packages: Delete the specified package asynchronously.
deleteAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a topic asynchronously.
deleteAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
deleteAsync(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a topic asynchronously.
deleteBookieAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete bookie affinity group configured for a namespace.
deleteBookieAffinityGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete bookie affinity group configured for a namespace asynchronously.
deleteBookieRackInfo(String) - Method in interface org.apache.pulsar.client.admin.Bookies: Remove rack placement information for a specific bookie in the cluster.
deleteBookieRackInfoAsync(String) - Method in interface org.apache.pulsar.client.admin.Bookies: Remove rack placement information for a specific bookie in the cluster asynchronously.
deleteCluster(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Delete an existing cluster.
deleteClusterAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Delete an existing cluster asynchronously.
deleted - Variable in class org.apache.pulsar.common.policies.data.Policies
deleteDynamicConfiguration(String) - Method in interface org.apache.pulsar.client.admin.Brokers: It deletes dynamic configuration value into ZooKeeper.
deleteDynamicConfigurationAsync(String) - Method in interface org.apache.pulsar.client.admin.Brokers: It deletes dynamic configuration value into ZooKeeper asynchronously.
deleteFailureDomain(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Delete a domain in cluster.
deleteFailureDomainAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Delete a domain in cluster asynchronously.
deleteFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Delete an existing function.
deleteFunctionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Delete an existing function asynchronously.
deleteNamespace(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing namespace.
deleteNamespace(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing namespace.
deleteNamespaceAntiAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete anti-affinity group name for a namespace.
deleteNamespaceAntiAffinityGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete anti-affinity group name for a namespace.
deleteNamespaceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing namespace asynchronously.
deleteNamespaceAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing namespace asynchronously.
deleteNamespaceBundle(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing bundle in a namespace.
deleteNamespaceBundle(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing bundle in a namespace.
deleteNamespaceBundleAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing bundle in a namespace asynchronously.
deleteNamespaceBundleAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing bundle in a namespace asynchronously.
deleteNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Delete a namespace isolation policy for a cluster.
deleteNamespaceIsolationPolicyAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Delete a namespace isolation policy for a cluster asynchronously.
deletePartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a partitioned topic.
deletePartitionedTopic(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
deletePartitionedTopic(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a partitioned topic.
deletePartitionedTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a partitioned topic asynchronously.
deletePartitionedTopicAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
deletePartitionedTopicAsync(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a partitioned topic asynchronously.
deleteProperty(String) - Method in interface org.apache.pulsar.client.admin.Properties: Deprecated.

Delete an existing property.
deleteResourceGroup(String) - Method in interface org.apache.pulsar.client.admin.ResourceGroups: Delete an existing resourcegroup.
deleteResourceGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.ResourceGroups: Delete an existing resourcegroup.
deleteSchema(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Delete the schema associated with a given topic.
deleteSchemaAsync(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Delete the schema associated with a given topic asynchronously.
deleteSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Delete an existing sink.
deleteSinkAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Delete an existing sink asynchronously.
deleteSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Delete an existing source.
deleteSourceAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Delete an existing source asynchronously.
deleteSubscription(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a subscription.
deleteSubscription(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a subscription.
deleteSubscriptionAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a subscription asynchronously.
deleteSubscriptionAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a subscription asynchronously.
deleteTenant(String) - Method in interface org.apache.pulsar.client.admin.Tenants: Delete an existing tenant.
deleteTenant(String, boolean) - Method in interface org.apache.pulsar.client.admin.Tenants: Delete an existing tenant.
deleteTenantAsync(String) - Method in interface org.apache.pulsar.client.admin.Tenants: Delete an existing tenant asynchronously.
deleteTenantAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Tenants: Delete an existing tenant asynchronously.
destination_storage - Enum constant in enum class org.apache.pulsar.common.policies.data.BacklogQuota.BacklogQuotaType
directArenas - Variable in class org.apache.pulsar.common.stats.AllocatorStats
disableDeduplication(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
disableDeduplicationAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
DispatchRate - Interface in org.apache.pulsar.common.policies.data: Dispatch rate.
DispatchRate.Builder - Interface in org.apache.pulsar.common.policies.data
DispatchRateImpl - Class in org.apache.pulsar.common.policies.data.impl: Dispatch rate.
DispatchRateImpl() - Constructor for class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl
DispatchRateImpl.DispatchRateImplBuilder - Class in org.apache.pulsar.common.policies.data.impl
DispatchRateImplBuilder() - Constructor for class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
dispatchThrottlingRateInByte(long) - Method in interface org.apache.pulsar.common.policies.data.DispatchRate.Builder
dispatchThrottlingRateInByte(long) - Method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
dispatchThrottlingRateInMsg(int) - Method in interface org.apache.pulsar.common.policies.data.DispatchRate.Builder
dispatchThrottlingRateInMsg(int) - Method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
download(String, String) - Method in interface org.apache.pulsar.client.admin.Packages: Download a package from the package management service.
downloadAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Packages: Download a package from the package management service asynchronously.
downloadFunction(String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Download Function Code.
downloadFunction(String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Download Function Code.
downloadFunctionAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Download Function Code.
downloadFunctionAsync(String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Download Function Code asynchronously.

E

EFFECTIVELY_ONCE - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees
elementSize - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolSubpageStats
enableDeduplication(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
enableDeduplicationAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
enableTlsHostnameVerification(boolean) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: It allows to validate hostname verification when client connects to broker over TLS.
encryption_required - Variable in class org.apache.pulsar.common.policies.data.Policies
entries - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
entriesAddedCounter - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: Messages published since this broker loaded this managedLedger.
equals(Object) - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
equals(Object) - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
equals(Object) - Method in class org.apache.pulsar.common.policies.data.Policies
equals(Object) - Method in class org.apache.pulsar.common.policies.data.PublishRate
equals(Object) - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
equals(Object) - Method in class org.apache.pulsar.common.policies.data.SubscribeRate
equals(Object) - Method in class org.apache.pulsar.common.stats.Metrics
equalsName(String) - Method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
error - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
error - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
error - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
ERROR - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
ErrorData - Class in org.apache.pulsar.common.policies.data: Class holding data in case of error responses.
ErrorData() - Constructor for class org.apache.pulsar.common.policies.data.ErrorData
ErrorData(String) - Constructor for class org.apache.pulsar.common.policies.data.ErrorData
examineMessage(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Examine a specific message on a topic by position relative to the earliest or the latest message.
examineMessageAsync(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Examine a specific message on a topic by position relative to the earliest or the latest message.
ExceptionInformation - Class in org.apache.pulsar.common.policies.data: Exception information.
ExceptionInformation() - Constructor for class org.apache.pulsar.common.policies.data.ExceptionInformation
expireMessages(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Expire all messages older than given N (expireTimeInSeconds) seconds for a given subscription.
expireMessages(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Expire all messages older than given N (expireTimeInSeconds) seconds for a given subscription.
expireMessagesAsync(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Expire all messages older than given N (expireTimeInSeconds) seconds for a given subscription asynchronously.
expireMessagesAsync(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Expire all messages older than given N (expireTimeInSeconds) seconds for a given subscription asynchronously.
expireMessagesForAllSubscriptions(String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Expire all messages older than given N seconds for all subscriptions of the persistent-topic.
expireMessagesForAllSubscriptionsAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Expire all messages older than given N seconds for all subscriptions of the persistent-topic asynchronously.

F

fail(String) - Static method in class org.apache.pulsar.common.policies.data.ValidateResult
FailureDomain - Interface in org.apache.pulsar.common.policies.data
FailureDomain.Builder - Interface in org.apache.pulsar.common.policies.data
fileSystemProfilePath(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
fileSystemURI(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
FIRST_BOUNDARY - Static variable in class org.apache.pulsar.common.policies.data.Policies
forError(String) - Static method in class org.apache.pulsar.client.admin.LongRunningProcessStatus
forError(String) - Static method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
forStatus(LongRunningProcessStatus.Status) - Static method in class org.apache.pulsar.client.admin.LongRunningProcessStatus
forStatus(LongRunningProcessStatus.Status) - Static method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
forSuccess(MessageId) - Static method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
Forward - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy: Messages written in the new schema can be read by the previous schema.
FORWARD - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Messages written by a new schema can be read by an old schema.
FORWARD_TRANSITIVE - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Be similar to FORWARD, FORWARD_TRANSITIVE ensure new schema can be ready by all previous version schema.
ForwardTransitive - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy: Be similar to Forward, ForwardTransitive ensure new schema can be ready by all previous version schema.
freeBytes - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkStats
fromAutoUpdatePolicy(SchemaAutoUpdateCompatibilityStrategy) - Static method in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
fromString(String) - Static method in enum class org.apache.pulsar.common.policies.data.AutoFailoverPolicyType
fromString(String) - Static method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
Full - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy: Backward and Forward.
FULL - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Equivalent to both FORWARD and BACKWARD.
FULL_TRANSITIVE - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Equivalent to both FORWARD_TRANSITIVE and BACKWARD_TRANSITIVE.
FullTransitive - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy: BackwardTransitive and ForwardTransitive.
FUNCTION - Enum constant in enum class org.apache.pulsar.packages.management.core.common.PackageType
FunctionConfig - Class in org.apache.pulsar.common.functions: Configuration of Pulsar Function.
FunctionConfig() - Constructor for class org.apache.pulsar.common.functions.FunctionConfig
FunctionConfig.ProcessingGuarantees - Enum Class in org.apache.pulsar.common.functions: Definition of possible processing guarantees.
FunctionConfig.Runtime - Enum Class in org.apache.pulsar.common.functions: Definition of possible runtime environments.
FunctionInstanceStats - Interface in org.apache.pulsar.common.policies.data
FunctionInstanceStatsData - Interface in org.apache.pulsar.common.policies.data
FunctionInstanceStatsDataBase - Interface in org.apache.pulsar.common.policies.data
FunctionInstanceStatus() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus
FunctionInstanceStatusData() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
functions - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction: Permissions for functions ops.
functions() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Functions - Interface in org.apache.pulsar.client.admin: Admin interface for function management.
FunctionState - Class in org.apache.pulsar.common.functions: Function state.
FunctionState() - Constructor for class org.apache.pulsar.common.functions.FunctionState
FunctionStats - Interface in org.apache.pulsar.common.policies.data
FunctionStatus - Class in org.apache.pulsar.common.policies.data: Data lass containing status of Pulsar Function.
FunctionStatus() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStatus
FunctionStatus.FunctionInstanceStatus - Class in org.apache.pulsar.common.policies.data: Function instance status.
FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData - Class in org.apache.pulsar.common.policies.data: Function instance status data.

G

gcsManagedLedgerOffloadBucket(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
gcsManagedLedgerOffloadMaxBlockSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
gcsManagedLedgerOffloadReadBufferSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
gcsManagedLedgerOffloadRegion(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
gcsManagedLedgerOffloadServiceAccountKeyFile(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
getAccessMode() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats
getActiveBrokers(String) - Method in interface org.apache.pulsar.client.admin.Brokers: Get the list of active brokers in the cluster.
getActiveBrokersAsync(String) - Method in interface org.apache.pulsar.client.admin.Brokers: Get the list of active brokers in the cluster asynchronously.
getActiveConsumerName() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: The name of the consumer that is active for single active consumer subscriptions i.e.
getAddress() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Address of this consumer.
getAddress() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: Address of this publisher.
getAdminRoles() - Method in interface org.apache.pulsar.common.policies.data.TenantInfo
getAllDynamicConfigurations() - Method in interface org.apache.pulsar.client.admin.Brokers: Get values of all overridden dynamic-configs.
getAllDynamicConfigurationsAsync() - Method in interface org.apache.pulsar.client.admin.Brokers: Get values of all overridden dynamic-configs asynchronously.
getAllocatorStats(String) - Method in interface org.apache.pulsar.client.admin.BrokerStats: Get the stats for the Netty allocator.
getAllocatorStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.BrokerStats: Get the stats for the Netty allocator asynchronously.
getAllowedClusters() - Method in interface org.apache.pulsar.common.policies.data.TenantInfo
getAllSchemas(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Get all version schemas topic.
getAllSchemasAsync(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Get all version schemas topic asynchronously.
getAntiAffinityNamespaces(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get all namespaces that grouped with given anti-affinity group.
getAntiAffinityNamespacesAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get all namespaces that grouped with given anti-affinity group asynchronously.
getAssignments() - Method in interface org.apache.pulsar.client.admin.Worker: Get the function assignment among the cluster.
getAssignmentsAsync() - Method in interface org.apache.pulsar.client.admin.Worker: Get the function assignment among the cluster asynchronously.
getAuthenticationParameters() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getAuthenticationPlugin() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getAutoFailoverPolicy() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
getAutoSubscriptionCreation(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the autoSubscriptionCreation info within a namespace.
getAutoSubscriptionCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the autoSubscriptionCreation info within a namespace asynchronously.
getAutoTopicCreation(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the autoTopicCreation info within a namespace.
getAutoTopicCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the autoTopicCreation info within a namespace asynchronously.
getAvailablePermits() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Number of available message permits for the consumer.
getAverageMsgSize() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: Average message size published by this publisher.
getAverageMsgSize() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Average size of published messages (bytes).
getAvgMessagesPerEntry() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Number of average messages per entry for the consumer consumed.
getAvgProcessLatency() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsDataBase
getAvgProcessLatency() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
getBacklogQuotaMap(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get backlog quota map on a namespace.
getBacklogQuotaMap(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get backlog quota map for a topic.
getBacklogQuotaMap(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getBacklogQuotaMap(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get applied backlog quota map for a topic.
getBacklogQuotaMap(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getBacklogQuotaMapAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get backlog quota map on a namespace asynchronously.
getBacklogSize() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Size of backlog in byte.
getBacklogSize() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Get estimated total unconsumed or backlog size in bytes.
getBacklogSizeByMessageId(String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics: Get backlog size by a message ID.
getBacklogSizeByMessageIdAsync(String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics: Get backlog size by a message ID asynchronously.
getBandwidthIn() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getBandwidthOut() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getBookie(String) - Method in class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
getBookieAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get bookie affinity group configured for a namespace.
getBookieAffinityGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get bookie affinity group configured for a namespace asynchronously.
getBookieRackInfo(String) - Method in interface org.apache.pulsar.client.admin.Bookies: Gets the rack placement information for a specific bookie in the cluster.
getBookieRackInfoAsync(String) - Method in interface org.apache.pulsar.client.admin.Bookies: Gets the rack placement information for a specific bookie in the cluster asynchronously.
getBookies() - Method in interface org.apache.pulsar.client.admin.Bookies: Gets discovery information for all the bookies in the cluster.
getBookies() - Method in interface org.apache.pulsar.common.policies.data.BookiesClusterInfo
getBookiesAsync() - Method in interface org.apache.pulsar.client.admin.Bookies: Gets discovery information for all the bookies in the cluster asynchronously.
getBookiesRackInfo() - Method in interface org.apache.pulsar.client.admin.Bookies: Gets the rack placement information for all the bookies in the cluster.
getBookiesRackInfoAsync() - Method in interface org.apache.pulsar.client.admin.Bookies: Gets the rack placement information for all the bookies in the cluster asynchronously.
getBookkeeperAckQuorum() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
getBookkeeperAffinityGroupPrimary() - Method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData
getBookkeeperAffinityGroupSecondary() - Method in interface org.apache.pulsar.common.policies.data.BookieAffinityGroupData
getBookkeeperEnsemble() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
getBookkeeperMetadataServiceUri() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
getBookkeeperWriteQuorum() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
getBoundaries() - Method in interface org.apache.pulsar.common.policies.data.BundlesData
getBrokerAddress() - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus
getBrokerClientTlsTrustStore() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getBrokerClientTlsTrustStorePassword() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getBrokerClientTlsTrustStoreType() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getBrokerClientTrustCertsFilePath() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getBrokerName() - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
getBrokers() - Method in interface org.apache.pulsar.common.policies.data.FailureDomain
getBrokerServiceUrl() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getBrokerServiceUrlTls() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getBrokersWithNamespaceIsolationPolicy(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Returns list of active brokers with namespace-isolation policies attached to it.
getBrokersWithNamespaceIsolationPolicyAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Returns list of active brokers with namespace-isolation policies attached to it asynchronously.
getBrokerVersionString() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getBrokerWithNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Returns active broker with namespace-isolation policies attached to it.
getBrokerWithNamespaceIsolationPolicyAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Returns active broker with namespace-isolation policies attached to it asynchronously.
getBuiltInSinks() - Method in interface org.apache.pulsar.client.admin.Sinks: Fetches a list of supported Pulsar IO sinks currently running in cluster mode.
getBuiltInSinksAsync() - Method in interface org.apache.pulsar.client.admin.Sinks: Fetches a list of supported Pulsar IO sinks currently running in cluster mode asynchronously.
getBuiltInSources() - Method in interface org.apache.pulsar.client.admin.Sources: Fetches a list of supported Pulsar IO sources currently running in cluster mode.
getBuiltInSourcesAsync() - Method in interface org.apache.pulsar.client.admin.Sources: Fetches a list of supported Pulsar IO sources currently running in cluster mode asynchronously.
getBundleRange(String) - Method in interface org.apache.pulsar.client.admin.Lookup: Get a bundle range of a topic.
getBundleRangeAsync(String) - Method in interface org.apache.pulsar.client.admin.Lookup: Get a bundle range of a topic asynchronously.
getBundles(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the list of bundles.
getBundlesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the list of bundles asynchronously.
getBundleStats() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getBytesInCounter() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Total bytes published to the topic (bytes).
getBytesOutCounter() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Total bytes delivered to consumer (bytes).
getBytesOutCounter() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Total bytes delivered to consumer (bytes).
getBytesOutCounter() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Total bytes delivered to consumer (bytes).
getChunkedMessageRate() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: The total rate of chunked messages delivered to this consumer.
getChunkedMessageRate() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: The total rate of chunked messages published by this publisher.
getChunkedMessageRate() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Chunked message dispatch rate.
getClientVersion() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Client library version.
getClientVersion() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: Client library version.
getCluster() - Method in interface org.apache.pulsar.client.admin.Worker: Get List of all workers belonging to this cluster.
getCluster(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get the configuration data for the specified cluster.
getClusterAsync() - Method in interface org.apache.pulsar.client.admin.Worker: Get List of all workers belonging to this cluster asynchronously.
getClusterAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get the configuration data for the specified cluster asynchronously.
getClusterLeader() - Method in interface org.apache.pulsar.client.admin.Worker: Get the worker who is the leader of the cluster.
getClusterLeaderAsync() - Method in interface org.apache.pulsar.client.admin.Worker: Get the worker who is the leader of the cluster asynchronously.
getClusters() - Method in interface org.apache.pulsar.client.admin.Clusters: Get the list of clusters.
getClustersAsync() - Method in interface org.apache.pulsar.client.admin.Clusters: Get the list of clusters asynchronously.
getCompaction() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: The compaction stats.
getCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the compactionThreshold for a namespace.
getCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the compactionThreshold for a topic.
getCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getCompactionThreshold(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the compactionThreshold for a topic.
getCompactionThreshold(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the compactionThreshold for a namespace asynchronously.
getCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the compactionThreshold for a topic asynchronously.
getCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getCompactionThresholdAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the compactionThreshold for a topic asynchronously.
getCompactionThresholdAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getConfigurationMetadataStoreUrl() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
getConfigurationStoreServers() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData: Deprecated.
getConnectedSince() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Timestamp of connection.
getConnectedSince() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: Timestamp of connection.
getConnections() - Method in interface org.apache.pulsar.client.admin.ProxyStats: Returns Connections metrics.
getConnectorsList() - Method in interface org.apache.pulsar.client.admin.Functions: Deprecated.
getConsumerName() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Name of the consumer.
getConsumers() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: List of connected consumers on this subscription w/ their stats.
getConsumersAfterMarkDeletePosition() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: This is for Key_Shared subscription to get the recentJoinedConsumers in the Key_Shared subscription.
getCoordinatorInternalStats(int, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction coordinator internal stats.
getCoordinatorInternalStatsAsync(int, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction coordinator internal stats.
getCoordinatorStats() - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction metadataStore stats.
getCoordinatorStatsAsync() - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction metadataStore stats.
getCoordinatorStatsById(int) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction metadataStore stats.
getCoordinatorStatsByIdAsync(int) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction metadataStore stats.
getCpu() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getDeduplicationEnabled(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDeduplicationEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the deduplicationSnapshotInterval for a namespace.
getDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the deduplication snapshot interval for specified topic.
getDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the deduplicationSnapshotInterval for a namespace asynchronously.
getDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the deduplication snapshot interval for specified topic asynchronously.
getDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDeduplicationStatus() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
getDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the deduplication status for all topics within a namespace .
getDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get deduplication enabled of a topic.
getDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get applied deduplication enabled of a topic.
getDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the deduplication status for all topics within a namespace asynchronously.
getDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get deduplication enabled of a topic asynchronously.
getDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDeduplicationStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get applied deduplication enabled of a topic asynchronously.
getDeduplicationStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDefaultNumPartitions() - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride
getDefaultResourceQuota() - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Get default resource quota for new resource bundles.
getDefaultResourceQuotaAsync() - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Get default resource quota for new resource bundles asynchronously.
getDefaultResources() - Static method in class org.apache.pulsar.common.functions.Resources
getDelayedDelivery(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the delayed delivery messages for all topics within a namespace.
getDelayedDeliveryAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the delayed delivery messages for all topics within a namespace asynchronously.
getDelayedDeliveryPolicy(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the delayed delivery policy for a specified topic.
getDelayedDeliveryPolicy(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDelayedDeliveryPolicy(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the delayed delivery policy applied for a specified topic.
getDelayedDeliveryPolicy(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDelayedDeliveryPolicyAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the delayed delivery policy for a specified topic asynchronously.
getDelayedDeliveryPolicyAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDelayedDeliveryPolicyAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the delayed delivery policy applied for a specified topic asynchronously.
getDelayedDeliveryPolicyAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDimension(String) - Method in class org.apache.pulsar.common.stats.Metrics
getDimensions() - Method in class org.apache.pulsar.common.stats.Metrics
getDirectMemory() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get message-dispatch-rate (topics under this namespace can dispatch this many messages per second).
getDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get message-dispatch-rate (topic can dispatch this many messages per second).
getDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get applied message-dispatch-rate (topic can dispatch this many messages per second).
getDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get message-dispatch-rate asynchronously.
getDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get message-dispatch-rate asynchronously.
getDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get applied message-dispatch-rate asynchronously.
getDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getDispatchThrottlingRateInByte() - Method in interface org.apache.pulsar.common.policies.data.DispatchRate
getDispatchThrottlingRateInMsg() - Method in interface org.apache.pulsar.common.policies.data.DispatchRate
getDynamic() - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
getDynamicConfigurationNames() - Method in interface org.apache.pulsar.client.admin.Brokers: Get list of updatable configuration name.
getDynamicConfigurationNamesAsync() - Method in interface org.apache.pulsar.client.admin.Brokers: Get list of updatable configuration name asynchronously.
getEarliestMsgPublishTimeInBacklog() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Get the publish time of the earliest message in the backlog.
getEarliestMsgPublishTimeInBacklogs() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Get the publish time of the earliest message over all the backlogs.
getEncryptionRequiredStatus(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the encryption required status within a namespace.
getEncryptionRequiredStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the encryption required status within a namespace asynchronously.
getEnum(String) - Static method in enum class org.apache.pulsar.common.naming.TopicDomain
getEnum(String) - Static method in enum class org.apache.pulsar.packages.management.core.common.PackageType
getFailureDomain(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get the domain registered into a cluster.
getFailureDomainAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get the domain registered into a cluster asynchronously.
getFailureDomains(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get all registered domains in cluster.
getFailureDomainsAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get all registered domains in cluster asynchronously.
getFileSystemProfilePath() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getFileSystemURI() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getFirstUnoffloadedMessage() - Method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
getFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Get the configuration for the specified function.
getFunctionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Get the configuration for the specified function asynchronously.
getFunctions(String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Get the list of functions.
getFunctionsAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Get the list of functions asynchronously.
getFunctionsStats() - Method in interface org.apache.pulsar.client.admin.Worker: Get all functions stats on a worker.
getFunctionsStatsAsync() - Method in interface org.apache.pulsar.client.admin.Worker: Get all functions stats on a worker asynchronously.
getFunctionState(String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Fetch the current state associated with a Pulsar Function.
getFunctionStateAsync(String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Fetch the current state associated with a Pulsar Function asynchronously.
getFunctionStats(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current stats of a function.
getFunctionStats(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current stats of a function instance.
getFunctionStatsAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current stats of a function asynchronously.
getFunctionStatsAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current stats of a function instance asynchronously.
getFunctionStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current status of a function.
getFunctionStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current status of a function instance.
getFunctionStatusAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current status of a function asynchronously.
getFunctionStatusAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current status of a function instance asynchronously.
getGcsManagedLedgerOffloadBucket() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getGcsManagedLedgerOffloadMaxBlockSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getGcsManagedLedgerOffloadReadBufferSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getGcsManagedLedgerOffloadRegion() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getGcsManagedLedgerOffloadServiceAccountKeyFile() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getHostname() - Method in interface org.apache.pulsar.common.policies.data.BookieInfo
getHttpError() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException
getInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the inactive deletion strategy for all topics within a namespace synchronously.
getInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get inactive topic policies of a topic.
getInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getInactiveTopicPolicies(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get inactive topic policies applied for a topic.
getInactiveTopicPolicies(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the inactive deletion strategy for all topics within a namespace asynchronously.
getInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get inactive topic policies of a topic asynchronously.
getInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getInactiveTopicPoliciesAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get inactive topic policies applied for a topic asynchronously.
getInactiveTopicPoliciesAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getInboundConnectedSince() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Timestamp of incoming connection establishment time.
getInboundConnection() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Address of incoming replication connection.
getInstanceId() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStats
getInstances() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
getInternalConfigurationData() - Method in interface org.apache.pulsar.client.admin.Brokers: Get the internal configuration data.
getInternalConfigurationDataAsync() - Method in interface org.apache.pulsar.client.admin.Brokers: Get the internal configuration data asynchronously.
getInternalInfo(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get a JSON representation of the topic metadata stored in ZooKeeper.
getInternalInfoAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get a JSON representation of the topic metadata stored in ZooKeeper.
getInternalStats(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Get the internal stats for the topic.
getInternalStats(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the internal stats for the topic.
getInternalStats(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Get the internal stats for the topic.
getInternalStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Get the internal stats for the topic asynchronously.
getInternalStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the internal stats for the topic asynchronously.
getInternalStatsAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Get the internal stats for the topic asynchronously.
getIsAllowAutoUpdateSchema(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get whether allow auto update schema.
getIsAllowAutoUpdateSchemaAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get whether allow auto update schema asynchronously.
getKeyHashRanges() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Hash ranges assigned to this consumer if is Key_Shared sub mode.
getKeySharedMode() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Whether the Key_Shared subscription mode is AUTO_SPLIT or STICKY.
getLastAckedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
getLastAckedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Last acked message timestamp.
getLastCompactionDurationTimeInMills() - Method in interface org.apache.pulsar.common.policies.data.CompactionStats: The duration time of last compaction.
getLastCompactionFailedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.CompactionStats: The timestamp of last failed compaction.
getLastCompactionRemovedEventCount() - Method in interface org.apache.pulsar.common.policies.data.CompactionStats: The removed event count of last compaction.
getLastCompactionSucceedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.CompactionStats: The timestamp of last succeed compaction.
getLastConsumedFlowTimestamp() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Last received consume flow command timestamp.
getLastConsumedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats
getLastConsumedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Last consume message timestamp.
getLastError() - Method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
getLastExpireTimestamp() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Last message expire execution timestamp.
getLastInvocation() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsData
getLastInvocation() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
getLastMarkDeleteAdvancedTimestamp() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Last MarkDelete position advanced timesetamp.
getLastMessageId(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the last commit message Id of a topic.
getLastMessageIdAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the last commit message Id of a topic asynchronously.
getLastUpdate() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getLeaderBroker() - Method in interface org.apache.pulsar.client.admin.Brokers: Get the information of the leader broker.
getLeaderBrokerAsync() - Method in interface org.apache.pulsar.client.admin.Brokers: Get the service url of the leader broker asynchronously.
getLedgersRootPath() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData: Deprecated.
getLimit() - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota: Deprecated.
getLimit() - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl: Deprecated.
getLimitSize() - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota: Gets quota limit in size.
getLimitSize() - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
getLimitTime() - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota: Gets quota limit in time.
getLimitTime() - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
getList(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Get list of topics exist into given namespace.
getList(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the both persistent and non-persistent topics under a namespace.
getList(String, TopicDomain) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of topics under a namespace.
getList(String, TopicDomain, Map<Topics.QueryParam, Object>) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of topics under a namespace.
getListAsync(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Get list of topics exist into given namespace asynchronously.
getListAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get both persistent and non-persistent topics under a namespace asynchronously.
getListAsync(String, TopicDomain) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of topics under a namespace asynchronously.
getListAsync(String, TopicDomain, Map<Topics.QueryParam, Object>) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of topics under a namespace asynchronously.
getListenerName() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getListInBundle(String, String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Get list of topics exist into given bundle.
getListInBundle(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Get list of topics exist into given bundle.
getListInBundleAsync(String, String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Get list of topics exist into given bundle asynchronously.
getListInBundleAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Get list of topics exist into given bundle asynchronously.
getLoadFactor() - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus
getLoadReport() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Get load for this broker.
getLoadReportAsync() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Get load for this broker asynchronously.
getManagedLedgerMaxMarkDeleteRate() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
getManagedLedgerOffloadBucket() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getManagedLedgerOffloadDeletionLagInMillis() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getManagedLedgerOffloadDriver() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getManagedLedgerOffloadedReadPriority() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getManagedLedgerOffloadMaxBlockSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getManagedLedgerOffloadMaxThreads() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getManagedLedgerOffloadPrefetchRounds() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getManagedLedgerOffloadReadBufferSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getManagedLedgerOffloadRegion() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getManagedLedgerOffloadServiceEndpoint() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getManagedLedgerOffloadThresholdInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getMaxConsumers(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max number of consumer for specified topic.
getMaxConsumers(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxConsumers(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max number of consumer applied for specified topic.
getMaxConsumers(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxConsumersAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max number of consumer for specified topic asynchronously.
getMaxConsumersAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxConsumersAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max number of consumer applied for specified topic asynchronously.
getMaxConsumersAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxConsumersPerSubscription for a namespace.
getMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the maxConsumersPerSubscription for a topic.
getMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxConsumersPerSubscription for a namespace asynchronously.
getMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the maxConsumersPerSubscription for a topic asynchronously.
getMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxConsumersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxProducersPerTopic for a namespace.
getMaxConsumersPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxProducersPerTopic for a namespace asynchronously.
getMaxMessageSize(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max message size for specified topic.
getMaxMessageSize(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxMessageSizeAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max message size for specified topic asynchronously.
getMaxMessageSizeAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxProducers(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max number of producer for specified topic.
getMaxProducers(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxProducers(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max number of producer applied for specified topic.
getMaxProducers(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxProducersAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max number of producer for specified topic asynchronously.
getMaxProducersAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxProducersAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max number of producer applied for specified topic asynchronously.
getMaxProducersAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxProducersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxProducersPerTopic for a namespace.
getMaxProducersPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxProducersPerTopic for a namespace asynchronously.
getMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxSubscriptionsPerTopic for a namespace.
getMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max number of subscriptions for specified topic.
getMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxSubscriptionsPerTopic for a namespace asynchronously.
getMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the max number of subscriptions for specified topic asynchronously.
getMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxTopicsPerNamespace(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get maxTopicsPerNamespace for a namespace.
getMaxTopicsPerNamespaceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get maxTopicsPerNamespace for a namespace asynchronously.
getMaxUnackedMessagesOnConsumer(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get max unacked messages on a consumer of a topic.
getMaxUnackedMessagesOnConsumer(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxUnackedMessagesOnConsumer(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get applied max unacked messages on consumer of a topic.
getMaxUnackedMessagesOnConsumer(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxUnackedMessagesOnConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get max unacked messages on consumer of a topic asynchronously.
getMaxUnackedMessagesOnConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxUnackedMessagesOnConsumerAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get applied max unacked messages on consumer of a topic asynchronously.
getMaxUnackedMessagesOnConsumerAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxUnackedMessagesOnSubscription(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get max unacked messages on subscription of a topic.
getMaxUnackedMessagesOnSubscription(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxUnackedMessagesOnSubscription(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get max unacked messages on subscription of a topic.
getMaxUnackedMessagesOnSubscription(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxUnackedMessagesOnSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get max unacked messages on subscription of a topic asynchronously.
getMaxUnackedMessagesOnSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxUnackedMessagesOnSubscriptionAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get max unacked messages on subscription of a topic asynchronously.
getMaxUnackedMessagesOnSubscriptionAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMaxUnackedMessagesPerConsumer(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxUnackedMessagesPerConsumer for a namespace.
getMaxUnackedMessagesPerConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxUnackedMessagesPerConsumer for a namespace asynchronously.
getMaxUnackedMessagesPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxUnackedMessagesPerSubscription for a namespace.
getMaxUnackedMessagesPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxUnackedMessagesPerSubscription for a namespace asynchronously.
getMBeans() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Requests JSON string server mbean dump.
getMBeansAsync() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Requests JSON string server mbean dump asynchronously.
getMemory() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getMessageAckRate() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Total rate of message ack(msg/s).
getMessageAckRate() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Total rate of message ack(msg/s).
getMessageById(String, long, long) - Method in interface org.apache.pulsar.client.admin.Topics: Get a message by its messageId via a topic subscription.
getMessageByIdAsync(String, long, long) - Method in interface org.apache.pulsar.client.admin.Topics: Get a message by its messageId via a topic subscription asynchronously.
getMessageIdByTimestamp(String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Get message ID published at or just after this absolute timestamp (in ms).
getMessageIdByTimestampAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Get message ID published at or just after this absolute timestamp (in ms) asynchronously.
getMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get message TTL for a topic.
getMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMessageTTL(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get message TTL applied for a topic.
getMessageTTL(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getMetadata() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Metadata (key/value strings) associated with this consumer.
getMetadata() - Method in interface org.apache.pulsar.common.policies.data.PartitionedTopicStats
getMetadata() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: Metadata (key/value strings) associated with this publisher.
getMetadata(String) - Method in interface org.apache.pulsar.client.admin.Packages: Get a package metadata information.
getMetadataAsync(String) - Method in interface org.apache.pulsar.client.admin.Packages: Get a package metadata information asynchronously.
getMetadataStoreUrl() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
getMetrics() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Returns Monitoring metrics.
getMetrics() - Method in interface org.apache.pulsar.client.admin.Worker: Get worker metrics.
getMetrics() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStats
getMetrics() - Method in class org.apache.pulsar.common.stats.Metrics
getMetricsAsync() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Returns Monitoring metrics asynchronously.
getMetricsAsync() - Method in interface org.apache.pulsar.client.admin.Worker: Get worker metrics asynchronously.
getMsgBacklog() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Number of messages in the subscription backlog.
getMsgBacklogNoDelayed() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Number of messages in the subscription backlog that do not contain the delay messages.
getMsgDelayed() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Number of delayed messages currently being tracked.
getMsgDropRate() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentPublisherStats: for non-persistent topic: broker drops msg if publisher publishes messages more than configured max inflight messages per connection.
getMsgDropRate() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentReplicatorStats: for non-persistent topic: broker drops msg for replicator if replicator connection is not writable.
getMsgDropRate() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentSubscriptionStats: for non-persistent topic: broker drops msg for subscription if none of the consumer available for message delivery.
getMsgDropRate() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentTopicStats: for non-persistent topic: broker drops msg if publisher publishes messages more than configured max inflight messages per connection.
getMsgInCounter() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Total messages published to the topic (msg).
getMsgOutCounter() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Total messages delivered to consumer (msg).
getMsgOutCounter() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Total messages delivered to consumer (msg).
getMsgOutCounter() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Total messages delivered to consumer (msg).
getMsgRateExpired() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Total rate of messages expired (msg/s).
getMsgRateExpired() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Total rate of messages expired on this subscription (msg/s).
getMsgRateIn() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: Total rate of messages published by this publisher (msg/s).
getMsgRateIn() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Total rate of messages received from the remote cluster (msg/s).
getMsgRateIn() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Total rate of messages published on the topic (msg/s).
getMsgRateIn() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getMsgRateOut() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Total rate of messages delivered to the consumer (msg/s).
getMsgRateOut() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Total rate of messages delivered to the replication-subscriber (msg/s).
getMsgRateOut() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Total rate of messages delivered on this subscription (msg/s).
getMsgRateOut() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Total rate of messages dispatched for the topic (msg/s).
getMsgRateOut() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getMsgRateRedeliver() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Total rate of messages redelivered by this consumer (msg/s).
getMsgRateRedeliver() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Total rate of messages redelivered on this subscription (msg/s).
getMsgThroughputIn() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: Total throughput of messages published by this publisher (byte/s).
getMsgThroughputIn() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Total throughput received from the remote cluster (bytes/s).
getMsgThroughputIn() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Total throughput of messages published on the topic (byte/s).
getMsgThroughputIn() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getMsgThroughputOut() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Total throughput delivered to the consumer (bytes/s).
getMsgThroughputOut() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Total throughput delivered to the replication-subscriber (bytes/s).
getMsgThroughputOut() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Total throughput delivered on this subscription (bytes/s).
getMsgThroughputOut() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Total throughput of messages dispatched for the topic (byte/s).
getMsgThroughputOut() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getNamespaceAntiAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get anti-affinity group name for a namespace.
getNamespaceAntiAffinityGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get anti-affinity group name for a namespace asynchronously.
getNamespaceAuthentication() - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies
getNamespaceBundleResourceQuota(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Get resource quota of a namespace bundle.
getNamespaceBundleResourceQuotaAsync(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Get resource quota of a namespace bundle asynchronously.
getNamespaceIsolationPolicies(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get the namespace isolation policies of a cluster.
getNamespaceIsolationPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get the namespace isolation policies of a cluster asynchronously.
getNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get a single namespace isolation policy for a cluster.
getNamespaceIsolationPolicyAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get a single namespace isolation policy for a cluster asynchronously.
getNamespaceMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the message TTL for a namespace.
getNamespaceMessageTTLAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the message TTL for a namespace asynchronously.
getNamespaceRegex() - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
getNamespaceReplicationClusters(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the replication clusters for a namespace.
getNamespaceReplicationClustersAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the replication clusters for a namespace asynchronously.
getNamespaceResourceGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the ResourceGroup for a namespace.
getNamespaceResourceGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the ResourceGroup for a namespace asynchronously.
getNamespaces() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
getNamespaces(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the list of namespaces.
getNamespaces(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Deprecated.
getNamespacesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the list of namespaces asynchronously.
getNonContiguousDeletedMessagesRanges() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: The number of non-contiguous deleted messages ranges.
getNonContiguousDeletedMessagesRanges() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: The number of non-contiguous deleted messages ranges.
getNonContiguousDeletedMessagesRangesSerializedSize() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: The serialized size of non-contiguous deleted messages ranges.
getNonContiguousDeletedMessagesRangesSerializedSize() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: The serialized size of non-contiguous deleted messages ranges.
getNumBundles() - Method in interface org.apache.pulsar.common.policies.data.BundlesData
getNumBundles() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getNumConsumers() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getNumProducers() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getNumTopics() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
getOffloadDeleteLagMs(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the offload deletion lag for a namespace, in milliseconds.
getOffloadDeleteLagMsAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the offload deletion lag asynchronously for a namespace, in milliseconds.
getOffloadedStorageSize() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Space used to store the offloaded messages for the topic/.
getOffloadersDirectory() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the offload configuration for a namespace.
getOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get offload policies of a topic.
getOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getOffloadPolicies(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get applied offload policies of a topic.
getOffloadPolicies(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the offload configuration for a namespace asynchronously.
getOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get offload policies of a topic asynchronously.
getOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getOffloadPoliciesAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: get applied offload policies of a topic asynchronously.
getOffloadPoliciesAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getOffloadThreshold(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the offloadThreshold for a namespace.
getOffloadThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the offloadThreshold for a namespace asynchronously.
getOneMin() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsData
getOneMin() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
getOutboundConnectedSince() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Timestamp of outbound connection establishment time.
getOutboundConnection() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Address of outbound replication connection.
getOwnedNamespaces(String, String) - Method in interface org.apache.pulsar.client.admin.Brokers: Get the map of owned namespaces and their status from a single broker in the cluster.
getOwnedNamespacesAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Brokers: Get the map of owned namespaces and their status from a single broker in the cluster asynchronously.
getParameters() - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
getPartitionedInternalStats(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the stats for the partitioned topic.
getPartitionedInternalStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the stats-internal for the partitioned topic asynchronously.
getPartitionedStats(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getPartitionedStats(String, boolean, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Get the stats for the partitioned topic
getPartitionedStatsAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getPartitionedStatsAsync(String, boolean, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Get the stats for the partitioned topic asynchronously.
getPartitionedTopicList(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of partitioned topics under a namespace.
getPartitionedTopicListAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of partitioned topics under a namespace asynchronously.
getPartitionedTopicMetadata(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Get metadata of a partitioned topic.
getPartitionedTopicMetadata(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get metadata of a partitioned topic.
getPartitionedTopicMetadataAsync(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Get metadata of a partitioned topic asynchronously.
getPartitionedTopicMetadataAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get metadata of a partitioned topic asynchronously.
getPartitions() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentPartitionedTopicStats
getPartitions() - Method in interface org.apache.pulsar.common.policies.data.PartitionedTopicStats
getPeerClusterNames() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getPeerClusterNames(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get peer-cluster names.
getPeerClusterNamesAsync(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get peer-cluster names asynchronously.
getPendingAckInternalStats(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions: Get pending ack internal stats.
getPendingAckInternalStatsAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Transactions: Get pending ack internal stats.
getPendingAckStats(String, String) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction pending ack stats.
getPendingAckStatsAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction pending ack stats.
getPendingBookieOpsStats() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Get pending bookie client op stats by namespace.
getPendingBookieOpsStatsAsync() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Get pending bookie client op stats by namespace asynchronously.
getPermissionOnSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get permission to role to access subscription's admin-api.
getPermissionOnSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get permission to role to access subscription's admin-api asynchronously.
getPermissions(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get permissions on a namespace.
getPermissions(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get permissions on a topic.
getPermissionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get permissions on a namespace asynchronously.
getPermissionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get permissions on a topic asynchronously.
getPersistence(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the persistence configuration for a namespace.
getPersistence(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the configuration of persistence policies for specified topic.
getPersistence(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getPersistence(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the applied configuration of persistence policies for specified topic.
getPersistence(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getPersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the persistence configuration for a namespace asynchronously.
getPersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the configuration of persistence policies for specified topic asynchronously.
getPersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getPersistenceAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the applied configuration of persistence policies for specified topic asynchronously.
getPersistenceAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get policies for a namespace.
getPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get policies for a namespace asynchronously.
getPolicy() - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota
getPolicy() - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
getPolicyName() - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
getPolicyType() - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
getPrimary() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
getProcessedSuccessfullyTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsDataBase
getProcessedSuccessfullyTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
getProducerId() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: Id of this publisher.
getProducerName() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: Producer name.
getProperties() - Method in interface org.apache.pulsar.client.admin.Properties: Deprecated.

Get the list of properties.
getProperties(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get all properties of a namespace.
getProperties(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get properties of a topic.
getPropertiesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get all properties of a namespace asynchronously.
getPropertiesAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get properties of a topic asynchronously.
getProperty(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get property value for a given key.
getPropertyAdmin(String) - Method in interface org.apache.pulsar.client.admin.Properties: Deprecated.

Get the config of the property.
getPropertyAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get property value for a given key.
getProtocol(String) - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData: Get the protocol data of the given protocol.
getProtocols() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData: Get all the protocols advertised by the broker.
getProxyProtocol() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getProxyServiceUrl() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getPublishers() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentTopicStats: List of connected publishers on this topic w/ their stats.
getPublishers() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: List of connected publishers on this topic w/ their stats.
getPublishRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get message-publish-rate (topics under this namespace can publish this many messages per second).
getPublishRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get message-publish-rate (topics can publish this many messages per second).
getPublishRate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getPublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get message-publish-rate (topics under this namespace can publish this many messages per second) asynchronously.
getPublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get message-publish-rate (topics can publish this many messages per second) asynchronously.
getPublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getPulsarServiceUrl() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
getPulsarServiceUrlTls() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
getRack() - Method in interface org.apache.pulsar.common.policies.data.BookieInfo
getRatePeriodInSecond() - Method in interface org.apache.pulsar.common.policies.data.DispatchRate
getReadPositionWhenJoining() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: The read position of the cursor when the consumer joining.
getReceivedTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsDataBase
getReceivedTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
getReplicatedSubscriptionStatus(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Get replicated subscription status on a topic.
getReplicatedSubscriptionStatusAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Get replicated subscription status on a topic asynchronously.
getReplication() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentTopicStats: Map of replication statistics by remote cluster context.
getReplication() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Map of replication statistics by remote cluster context.
getReplicationBacklog() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Number of messages pending to be replicated to remote cluster.
getReplicationClusters(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Get the replication clusters for a topic.
getReplicationClustersAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Get the replication clusters for a topic asynchronously.
getReplicationConfigVersion(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the replication configuration version for a given namespace.
getReplicationConfigVersionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the replication configuration version for a given namespace asynchronously.
getReplicationDelayInSeconds() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: Time in seconds from the time a message was produced to the time when it is about to be replicated.
getReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get replicator-message-dispatch-rate.
getReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get replicatorDispatchRate for the topic.
getReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getReplicatorDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get applied replicatorDispatchRate for the topic.
getReplicatorDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get replicator-message-dispatch-rate asynchronously.
getReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get replicatorDispatchRate asynchronously.
getReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getReplicatorDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get applied replicatorDispatchRate asynchronously.
getReplicatorDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getResourceGroup(String) - Method in interface org.apache.pulsar.client.admin.ResourceGroups: Get configuration for a resourcegroup.
getResourceGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.ResourceGroups: Get policies for a namespace asynchronously.
getResourceGroups() - Method in interface org.apache.pulsar.client.admin.ResourceGroups: Get the list of resourcegroups.
getResourceGroupsAsync() - Method in interface org.apache.pulsar.client.admin.ResourceGroups: Get the list of resourcegroups asynchronously.
getRetention(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the retention configuration for a namespace.
getRetention(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the retention configuration for a topic.
getRetention(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getRetention(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the applied retention configuration for a topic.
getRetention(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the retention configuration for a namespace asynchronously.
getRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the retention configuration for a topic asynchronously.
getRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getRetentionAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get the applied retention configuration for a topic asynchronously.
getRetentionAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getRetentionSizeInMB() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
getRetentionTimeInMinutes() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
getRuntimeConfigurations() - Method in interface org.apache.pulsar.client.admin.Brokers: Get values of runtime configuration.
getRuntimeConfigurationsAsync() - Method in interface org.apache.pulsar.client.admin.Brokers: Get values of runtime configuration asynchronously.
getS3ManagedLedgerOffloadBucket() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getS3ManagedLedgerOffloadCredentialId() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getS3ManagedLedgerOffloadCredentialSecret() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getS3ManagedLedgerOffloadMaxBlockSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getS3ManagedLedgerOffloadReadBufferSizeInBytes() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getS3ManagedLedgerOffloadRegion() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getS3ManagedLedgerOffloadRole() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getS3ManagedLedgerOffloadRoleSessionName() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getS3ManagedLedgerOffloadServiceEndpoint() - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies
getSchemaAutoUpdateCompatibilityStrategy(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Deprecated.
getSchemaCompatibilityStrategy(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed.
getSchemaCompatibilityStrategy(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get schema compatibility strategy on a topic.
getSchemaCompatibilityStrategyAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed asynchronously.
getSchemaCompatibilityStrategyAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get schema compatibility strategy on a topic asynchronously.
getSchemaInfo(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Retrieve the latest schema of a topic.
getSchemaInfo(String, long) - Method in interface org.apache.pulsar.client.admin.Schemas: Retrieve the schema of a topic at a given version.
getSchemaInfoAsync(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Retrieve the latest schema of a topic asynchronously.
getSchemaInfoAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Schemas: Retrieve the schema of a topic at a given version asynchronously.
getSchemaInfoWithVersion(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Retrieve the latest schema with verison of a topic.
getSchemaInfoWithVersionAsync(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Retrieve the latest schema with verison of a topic asynchronously.
getSchemaValidationEnforced(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get schema validation enforced for namespace.
getSchemaValidationEnforced(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get schema validation enforced for namespace.
getSchemaValidationEnforcedAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get schema validation enforced for namespace asynchronously.
getSchemaValidationEnforcedAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get schema validation enforced for namespace asynchronously.
getSecondary() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
getServiceUrl() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
getServiceUrl() - Method in interface org.apache.pulsar.common.policies.data.BrokerInfo
getServiceUrl() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getServiceUrlTls() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
getSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Get the configuration for the specified sink.
getSinkAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Get the configuration for the specified sink asynchronously.
getSinks() - Method in interface org.apache.pulsar.client.admin.Functions: Deprecated.
getSinkStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Gets the current status of a sink.
getSinkStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Gets the current status of a sink instance.
getSinkStatusAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Gets the current status of a sink asynchronously.
getSinkStatusAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Gets the current status of a sink instance asynchronously.
getSlowTransactions(long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Transactions: Get slow transactions.
getSlowTransactionsAsync(long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Transactions: Get slow transactions.
getSlowTransactionsByCoordinatorId(Integer, long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Transactions: Get slow transactions by coordinator id.
getSlowTransactionsByCoordinatorIdAsync(Integer, long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Transactions: Get slow transactions by coordinator id.
getSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Get the configuration for the specified source.
getSourceAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Get the configuration for the specified source asynchronously.
getSources() - Method in interface org.apache.pulsar.client.admin.Functions: Deprecated.
getSourceStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Gets the current status of a source.
getSourceStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Gets the current status of a source instance.
getSourceStatusAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Gets the current status of a source asynchronously.
getSourceStatusAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Gets the current status of a source instance asynchronously.
getStateStorageServiceUrl() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
getStats(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Get the stats for the topic.
getStats(String) - Method in interface org.apache.pulsar.client.admin.Topics
getStats(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getStats(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getStats(String, boolean, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getStats(String, GetStatsOptions) - Method in interface org.apache.pulsar.client.admin.Topics: Get the stats for the topic.
getStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Get the stats for the topic asynchronously.
getStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getStatsAsync(String, boolean, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Get the stats for the topic asynchronously.
GetStatsOptions - Class in org.apache.pulsar.client.admin
GetStatsOptions() - Constructor for class org.apache.pulsar.client.admin.GetStatsOptions
getStatus() - Method in interface org.apache.pulsar.client.admin.OffloadProcessStatus
getStatusCode() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException
getStorageSize() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Space used to store the messages for the topic (bytes).
getSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get namespace-subscribe-rate (topics under this namespace allow subscribe times per consumer in a period).
getSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get topic-subscribe-rate (topics allow subscribe times per consumer in a period).
getSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getSubscribeRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get applied topic-subscribe-rate (topics allow subscribe times per consumer in a period).
getSubscribeRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get namespace-subscribe-rate asynchronously.
getSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get topic-subscribe-rate asynchronously.
getSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getSubscribeRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get applied topic-subscribe-rate asynchronously.
getSubscribeRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getSubscriptionAuthentication() - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies
getSubscriptionAuthMode(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the subscriptionAuthMode within a namespace.
getSubscriptionAuthModeAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the subscriptionAuthMode within a namespace asynchronously.
getSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get subscription-message-dispatch-rate.
getSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get subscription-message-dispatch-rate for the topic.
getSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getSubscriptionDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get applied subscription-message-dispatch-rate.
getSubscriptionDispatchRate(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get subscription-message-dispatch-rate asynchronously.
getSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get subscription-message-dispatch-rate asynchronously.
getSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getSubscriptionDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get applied subscription-message-dispatch-rate asynchronously.
getSubscriptionDispatchRateAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getSubscriptionExpirationTime(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the subscription expiration time for a namespace.
getSubscriptionExpirationTimeAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the subscription expiration time for a namespace asynchronously.
getSubscriptionProperties() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: SubscriptionProperties (key/value strings) associated with this subscribe.
getSubscriptions() - Method in interface org.apache.pulsar.common.policies.data.NonPersistentTopicStats: Map of subscriptions with their individual statistics.
getSubscriptions() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Map of subscriptions with their individual statistics.
getSubscriptions(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of subscriptions.
getSubscriptionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of subscriptions asynchronously.
getSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the subscriptionTypesEnabled policy for a given namespace, overriding broker settings.
getSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get is enable sub types.
getSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the subscriptionTypesEnabled policy for a given namespace, overriding broker settings.
getSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Get is enable sub types asynchronously.
getSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
getSystemExceptionsTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsDataBase
getSystemExceptionsTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
getTenantInfo(String) - Method in interface org.apache.pulsar.client.admin.Tenants: Get the config of the tenant.
getTenantInfoAsync(String) - Method in interface org.apache.pulsar.client.admin.Tenants: Get the config of the tenant asynchronously.
getTenants() - Method in interface org.apache.pulsar.client.admin.Tenants: Get the list of tenants.
getTenantsAsync() - Method in interface org.apache.pulsar.client.admin.Tenants: Get the list of tenants asynchronously.
getTickTime() - Method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies
GettingAuthenticationDataException(String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.GettingAuthenticationDataException
GettingAuthenticationDataException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.GettingAuthenticationDataException
getTopicAuthentication() - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies
getTopicEpoch() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: The topic epoch or empty if not set.
getTopics() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Returns JSON string topics stats.
getTopics() - Method in interface org.apache.pulsar.client.admin.ProxyStats: Returns Topics metrics.
getTopics(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the list of topics.
getTopicsAsync() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Returns JSON string topics stats asynchronously.
getTopicsAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the list of topics asynchronously.
getTopicType() - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride
getTotalMsgExpired() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Total messages expired on this subscription.
getTransactionBufferStats(String) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction buffer stats.
getTransactionBufferStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction buffer stats.
getTransactionInBufferStats(TxnID, String) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction in buffer stats.
getTransactionInBufferStatsAsync(TxnID, String) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction in buffer stats.
getTransactionInPendingAckStats(TxnID, String, String) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction in pending ack stats.
getTransactionInPendingAckStatsAsync(TxnID, String, String) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction in pending ack stats.
getTransactionMetadata(TxnID) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction metadata.
getTransactionMetadataAsync(TxnID) - Method in interface org.apache.pulsar.client.admin.Transactions: Get transaction metadata.
getType() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Whether this subscription is Exclusive or Shared or Failover.
getUnackedMessages() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Number of unacknowledged messages for the consumer.
getUnackedMessages() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Number of unacknowledged messages for the subscription.
getUserExceptionsTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsDataBase
getUserExceptionsTotal() - Method in interface org.apache.pulsar.common.policies.data.FunctionStats
getUserMetrics() - Method in interface org.apache.pulsar.common.policies.data.FunctionInstanceStatsData
getValue() - Method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
getVersion() - Method in interface org.apache.pulsar.client.admin.Brokers: Get version of broker.
getVersionBySchema(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas: Find schema version topic.
getVersionBySchema(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas: Find schema version topic.
getVersionBySchemaAsync(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas: Find schema version topic asynchronously.
getVersionBySchemaAsync(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas: Find schema version topic asynchronously.
getWaitingPublishers() - Method in interface org.apache.pulsar.common.policies.data.TopicStats
getWebServiceUrl() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
getWebServiceUrlTls() - Method in interface org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData
getZookeeperServers() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData: Deprecated.
GO - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.Runtime
grantPermission(String, String, Set<AuthAction>) - Method in interface org.apache.pulsar.client.admin.Topics: Grant permission on a topic.
grantPermissionAsync(String, String, Set<AuthAction>) - Method in interface org.apache.pulsar.client.admin.Topics: Grant permission on a topic asynchronously.
grantPermissionOnNamespace(String, String, Set<AuthAction>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Grant permission on a namespace.
grantPermissionOnNamespaceAsync(String, String, Set<AuthAction>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Grant permission on a namespace asynchronously.
grantPermissionOnSubscription(String, String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Grant permission to role to access subscription's admin-api.
grantPermissionOnSubscriptionAsync(String, String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Grant permission to role to access subscription's admin-api asynchronously.

H

hashCode() - Method in class org.apache.pulsar.common.conf.InternalConfigurationData
hashCode() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
hashCode() - Method in class org.apache.pulsar.common.policies.data.Policies
hashCode() - Method in class org.apache.pulsar.common.policies.data.PublishRate
hashCode() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
hashCode() - Method in class org.apache.pulsar.common.policies.data.SubscribeRate
hashCode() - Method in class org.apache.pulsar.common.stats.Metrics
healthcheck() - Method in interface org.apache.pulsar.client.admin.Brokers: Deprecated.
healthcheck(TopicVersion) - Method in interface org.apache.pulsar.client.admin.Brokers: Run a healthcheck on the broker.
healthcheckAsync() - Method in interface org.apache.pulsar.client.admin.Brokers: Deprecated.
healthcheckAsync(TopicVersion) - Method in interface org.apache.pulsar.client.admin.Brokers: Run a healthcheck on the broker asynchronously.
heapArenas - Variable in class org.apache.pulsar.common.stats.AllocatorStats
hostname(String) - Method in interface org.apache.pulsar.common.policies.data.BookieInfo.Builder
hostname(String) - Method in class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl.BookieInfoImplBuilder
HOT - Enum constant in enum class org.apache.pulsar.common.policies.data.Policies.BundleType
HttpErrorException(Exception) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.HttpErrorException
HttpErrorException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.HttpErrorException

I

inactive_topic_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
InactiveTopicDeleteMode - Enum Class in org.apache.pulsar.common.policies.data: Inactive topic deletion mode.
InactiveTopicPolicies - Class in org.apache.pulsar.common.policies.data: Definition of the inactive topic policy.
InactiveTopicPolicies() - Constructor for class org.apache.pulsar.common.policies.data.InactiveTopicPolicies
individuallyDeletedMessages - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
instanceId - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus
instanceId - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus
instanceId - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus
instances - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus
instances - Variable in class org.apache.pulsar.common.policies.data.SinkStatus
instances - Variable in class org.apache.pulsar.common.policies.data.SourceStatus
InternalConfigurationData - Class in org.apache.pulsar.common.conf: Internal configuration data.
InternalConfigurationData() - Constructor for class org.apache.pulsar.common.conf.InternalConfigurationData
InternalConfigurationData(String, String, String, String, String) - Constructor for class org.apache.pulsar.common.conf.InternalConfigurationData
is_active - Variable in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
is_allow_auto_update_schema - Variable in class org.apache.pulsar.common.policies.data.Policies
is_controlled - Variable in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
isActive() - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus
isActive() - Method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies
isAllowAutoSubscriptionCreation() - Method in interface org.apache.pulsar.common.policies.data.AutoSubscriptionCreationOverride
isAllowAutoTopicCreation() - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride
isAllowOutOfOrderDelivery() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Whether out of order delivery is allowed on the Key_Shared subscription.
isBlockedConsumerOnUnackedMsgs() - Method in interface org.apache.pulsar.common.policies.data.ConsumerStats: Flag to verify if consumer is blocked due to reaching threshold of unacked messages.
isBlockedSubscriptionOnUnackedMsgs() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Flag to verify if subscription is blocked due to reaching threshold of unacked messages.
isBrokerAvailable(BrokerStatus) - Method in class org.apache.pulsar.common.policies.AutoFailoverPolicy: Determine whether a broker is considered available or not.
isBrokerAvailable(BrokerStatus) - Method in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
isBrokerClientTlsEnabled() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
isBrokerClientTlsEnabledWithKeyStore() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
IsCompatibilityResponse - Class in org.apache.pulsar.common.protocol.schema: Response defining if a schema is compatible with existing topic's schema.
IsCompatibilityResponse() - Constructor for class org.apache.pulsar.common.protocol.schema.IsCompatibilityResponse
isConnected() - Method in interface org.apache.pulsar.common.policies.data.ReplicatorStats: is the replication-subscriber up and running to replicate to remote cluster.
isDurable() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Tells whether this subscription is durable or ephemeral (eg.: from a reader).
isMsgChunkPublished() - Method in interface org.apache.pulsar.common.policies.data.TopicStats: Topic has chunked message published on it.
isNonPersistentTopicsEnabled() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
isPersistentTopicsEnabled() - Method in interface org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport
isPrimary() - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
isRelativeToPublishRate() - Method in interface org.apache.pulsar.common.policies.data.DispatchRate
isReplicated() - Method in interface org.apache.pulsar.common.policies.data.SubscriptionStats: Mark that the subscription state is kept in sync across different regions.
isSupportsPartialProducer() - Method in interface org.apache.pulsar.common.policies.data.PublisherStats: Whether partial producer is supported at client.
isTlsAllowInsecureConnection() - Method in interface org.apache.pulsar.common.policies.data.ClusterData
isUndefined(SchemaCompatibilityStrategy) - Static method in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy
isUpdateAuthData() - Method in interface org.apache.pulsar.common.functions.UpdateOptions
isValidTopicType(String) - Static method in enum class org.apache.pulsar.common.policies.data.TopicType

J

JAVA - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.Runtime

L

LARGEST - Enum constant in enum class org.apache.pulsar.common.policies.data.Policies.BundleType
LAST_BOUNDARY - Static variable in class org.apache.pulsar.common.policies.data.Policies
lastConfirmedEntry - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The ledgerid: entryid of the last message that is written successfully.
lastError - Variable in class org.apache.pulsar.client.admin.LongRunningProcessStatus
lastInvocationTime - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
lastLedgerCreatedTimestamp - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The time when the last ledger is created.
lastLedgerCreationFailureTimestamp - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The time when the last ledger failed.
lastLedgerSwitchTimestamp - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
lastReceivedTime - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
lastReceivedTime - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
lastSnapshotTimestamps - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats: The last snapshot timestamps of this transaction buffer.
latency_stats_sample_rate - Variable in class org.apache.pulsar.common.policies.data.Policies
latestSinkExceptions - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
latestSourceExceptions - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
latestSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
latestSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
latestSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
latestUserExceptions - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
leastSigBits - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats: The sequenceId of transaction metadataStore.
leastSigBits - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStatus: The sequenceId of transaction metadataStore.
ledgerId - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
LedgerInfo() - Constructor for class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
ledgers - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The ordered list of all ledgers for this topic holding messages.
limit - Variable in class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
limitSize(long) - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota.Builder
limitSize(long) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl.BacklogQuotaImplBuilder
limitTime(int) - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota.Builder
limitTime(int) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl.BacklogQuotaImplBuilder
listenerName(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
listPackages(String, String) - Method in interface org.apache.pulsar.client.admin.Packages: List all the packages with the given type in a namespace.
listPackagesAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Packages: List all the packages with the given type in a namespace asynchronously.
listPackageVersions(String) - Method in interface org.apache.pulsar.client.admin.Packages: List all the versions of a package.
listPackageVersionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Packages: List all the versions of a package asynchronously.
listSinks(String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Get the list of sinks.
listSinksAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Get the list of sinks asynchronously.
listSources(String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Get the list of sources.
listSourcesAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Get the list of sources asynchronously.
loadConf(Map<String, Object>) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Load the configuration from provided config map.
loadFactor(int) - Method in interface org.apache.pulsar.common.policies.data.BrokerStatus.Builder
loadFactor(int) - Method in class org.apache.pulsar.common.policies.data.impl.BrokerStatusImpl.BrokerStatusImplBuilder
LoadManagerReport - Interface in org.apache.pulsar.policies.data.loadbalancer: This class represents the overall load of the broker - it includes overall SystemResourceUsage and Bundle-usage.
LongRunningProcessStatus - Class in org.apache.pulsar.client.admin: Status of long running process.
LongRunningProcessStatus() - Constructor for class org.apache.pulsar.client.admin.LongRunningProcessStatus
LongRunningProcessStatus.Status - Enum Class in org.apache.pulsar.client.admin: Status code.
Lookup - Interface in org.apache.pulsar.client.admin: This is an interface class to allow using command line tool to quickly lookup the broker serving the topic.
lookupPartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Lookup: Lookup a partitioned topic.
lookupPartitionedTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Lookup: Lookup a partitioned topic.
lookups() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
lookupTopic(String) - Method in interface org.apache.pulsar.client.admin.Lookup: Lookup a topic.
lookupTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Lookup: Lookup a topic asynchronously.
lowWaterMark - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats: The low water mark of transaction metadataStore.
lowWaterMark - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStatus: The low water mark of transaction metadataStore.

M

managedLedgerInternalStats - Variable in class org.apache.pulsar.common.policies.data.TransactionLogStats: The manage ledger internal stats.
ManagedLedgerInternalStats - Class in org.apache.pulsar.common.policies.data: ManagedLedger internal statistics.
ManagedLedgerInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats
ManagedLedgerInternalStats.CursorStats - Class in org.apache.pulsar.common.policies.data: Pulsar cursor statistics.
ManagedLedgerInternalStats.LedgerInfo - Class in org.apache.pulsar.common.policies.data: Ledger information.
managedLedgerName - Variable in class org.apache.pulsar.common.policies.data.TransactionLogStats: The managed ledger name.
managedLedgerOffloadBucket(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
managedLedgerOffloadDeletionLagInMillis(Long) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
managedLedgerOffloadDriver(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
managedLedgerOffloadedReadPriority(OffloadedReadPriority) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
managedLedgerOffloadMaxBlockSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
managedLedgerOffloadMaxThreads(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
managedLedgerOffloadPrefetchRounds(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
managedLedgerOffloadReadBufferSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
managedLedgerOffloadRegion(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
managedLedgerOffloadServiceEndpoint(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
managedLedgerOffloadThresholdInBytes(Long) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
markDeletePosition - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
max_consumers_per_subscription - Variable in class org.apache.pulsar.common.policies.data.Policies
max_consumers_per_topic - Variable in class org.apache.pulsar.common.policies.data.Policies
max_producers_per_topic - Variable in class org.apache.pulsar.common.policies.data.Policies
max_subscriptions_per_topic - Variable in class org.apache.pulsar.common.policies.data.Policies
max_topics_per_namespace - Variable in class org.apache.pulsar.common.policies.data.Policies
max_unacked_messages_per_consumer - Variable in class org.apache.pulsar.common.policies.data.Policies
max_unacked_messages_per_subscription - Variable in class org.apache.pulsar.common.policies.data.Policies
maxNumElements - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolSubpageStats
maxReadPosition - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats: The max read position of this transaction buffer.
maxUsage - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkListStats
MEDIA_TYPE - Static variable in class org.apache.pulsar.common.partition.PartitionedTopicMetadata
mergeWithDefault(Resources) - Static method in class org.apache.pulsar.common.functions.Resources
message_age - Enum constant in enum class org.apache.pulsar.common.policies.data.BacklogQuota.BacklogQuotaType
message_ttl_in_seconds - Variable in class org.apache.pulsar.common.policies.data.Policies
messagesConsumedCounter - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
metadata - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
metadata - Variable in class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
MetadataFormatException(String) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException.MetadataFormatException: Constructs an MetadataFormatException with the specified detail message.
MetadataFormatException(String, Throwable) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException.MetadataFormatException: Constructs an MetadataFormatException with the specified detail message and the cause.
metrics - Variable in class org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats
Metrics - Class in org.apache.pulsar.common.stats: WARNING : do not add any getters as the Jackson parser will output that getter.
Metrics() - Constructor for class org.apache.pulsar.common.stats.Metrics
Metrics(Map<String, String>) - Constructor for class org.apache.pulsar.common.stats.Metrics
min_available - Enum constant in enum class org.apache.pulsar.common.policies.data.AutoFailoverPolicyType
min_limit - Variable in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
MinAvailablePolicy - Class in org.apache.pulsar.common.policies.impl: Implementation of min available policy.
MinAvailablePolicy(AutoFailoverPolicyData) - Constructor for class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
minUsage - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkListStats
msgRateIn - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
msgRateOut - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
msgThroughputIn - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
msgThroughputOut - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats

N

name - Variable in class org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats: Fully qualified function instance name.
namespaceAuthentication(Map<String, Set<AuthAction>>) - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies.Builder
NamespaceBundleStats - Class in org.apache.pulsar.policies.data.loadbalancer
NamespaceBundleStats() - Constructor for class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
NamespaceIsolationData - Interface in org.apache.pulsar.common.policies.data
NamespaceIsolationData.Builder - Interface in org.apache.pulsar.common.policies.data
NamespaceOwnershipStatus - Class in org.apache.pulsar.common.policies.data: Information about the namespace's ownership.
NamespaceOwnershipStatus() - Constructor for class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
NamespaceOwnershipStatus(BrokerAssignment, boolean, boolean) - Constructor for class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
namespaceRegex(List<String>) - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData.Builder
namespaces() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
namespaces(List<String>) - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData.Builder
Namespaces - Interface in org.apache.pulsar.client.admin: Admin interface for namespaces management.
newAdminClientBuilder() - Static method in class org.apache.pulsar.client.admin.utils.DefaultImplementation
newBuilder(String) - Static method in class org.apache.pulsar.client.admin.utils.ReflectionUtils
newOffloadProcessStatus(LongRunningProcessStatus.Status, String, MessageId) - Static method in class org.apache.pulsar.client.admin.utils.DefaultImplementation
NON_PARTITIONED - Enum constant in enum class org.apache.pulsar.common.policies.data.TopicType
NON_PARTITIONED - Static variable in class org.apache.pulsar.common.partition.PartitionedTopicMetadata: A topic with '0' partitions is treated like non-partitioned topic.
non_persistent - Enum constant in enum class org.apache.pulsar.common.naming.TopicDomain
None - Enum constant in enum class org.apache.pulsar.common.policies.data.SubscriptionAuthMode: Every subscription name can be used by every role.
NonPersistentPartitionedTopicStats - Interface in org.apache.pulsar.common.policies.data: Statistics for a non-persistent partitioned topic.
NonPersistentPublisherStats - Interface in org.apache.pulsar.common.policies.data: Non-persistent publisher statistics.
NonPersistentReplicatorStats - Interface in org.apache.pulsar.common.policies.data: Statistics for a non-persistent replicator.
NonPersistentSubscriptionStats - Interface in org.apache.pulsar.common.policies.data: Statistics for subscription to non-persistent topics.
nonPersistentTopics() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin: Deprecated.
Since 2.0. See PulsarAdmin.topics()
NonPersistentTopics - Interface in org.apache.pulsar.client.admin: Deprecated.
since 2.0. See Topics
NonPersistentTopicStats - Interface in org.apache.pulsar.common.policies.data: Statistics for a non-persistent topic.
normalCacheSize - Variable in class org.apache.pulsar.common.stats.AllocatorStats
normalize(PublishRate) - Static method in class org.apache.pulsar.common.policies.data.PublishRate
normalize(SubscribeRate) - Static method in class org.apache.pulsar.common.policies.data.SubscribeRate
NOT_RUN - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
NotAllowedException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.NotAllowedException
NotAuthorizedException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.NotAuthorizedException
NotFoundException(String) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException.NotFoundException: Constructs an NotFoundException with the specified detail message.
NotFoundException(String, Throwable) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException.NotFoundException: Constructs an NotFoundException with the specified detail message and the cause.
NotFoundException(Throwable) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException.NotFoundException: Constructs an NotFoundException with the specified cause.
NotFoundException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.NotFoundException
numActiveAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numActiveHugeAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numActiveNormalAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numActiveSmallAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numAvailable - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolSubpageStats
numberOfEntries - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The total number of entries being tracked.
numberOfEntriesSinceFirstNotAckedMessage - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
numBundles(int) - Method in interface org.apache.pulsar.common.policies.data.BundlesData.Builder
numBundles(int) - Method in class org.apache.pulsar.common.policies.data.impl.BundlesDataImpl.BundlesDataImplBuilder
numChunkLists - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numDeallocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numDirectArenas - Variable in class org.apache.pulsar.common.stats.AllocatorStats
numHeapArenas - Variable in class org.apache.pulsar.common.stats.AllocatorStats
numHugeAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numHugeDeallocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numInstances - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus
numInstances - Variable in class org.apache.pulsar.common.policies.data.SinkStatus
numInstances - Variable in class org.apache.pulsar.common.policies.data.SourceStatus
numNormalAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numNormalDeallocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numReadFromPulsar - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
numReceived - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
numReceivedFromSource - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
numRestarts - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
numRestarts - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
numRestarts - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
numRunning - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus
numRunning - Variable in class org.apache.pulsar.common.policies.data.SinkStatus
numRunning - Variable in class org.apache.pulsar.common.policies.data.SourceStatus
numSinkExceptions - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
numSmallAllocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numSmallDeallocations - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numSmallSubpages - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
numSourceExceptions - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
numSuccessfullyProcessed - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
numSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
numSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
numSystemExceptions - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
numThreadLocalCaches - Variable in class org.apache.pulsar.common.stats.AllocatorStats
numUserExceptions - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
numWritten - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
numWrittenToSink - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData

O

of(String, String, int) - Static method in class org.apache.pulsar.common.functions.WorkerInfo
offload_deletion_lag_ms - Variable in class org.apache.pulsar.common.policies.data.Policies
offload_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
offload_threshold - Variable in class org.apache.pulsar.common.policies.data.Policies
offloaded - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
OffloadedReadPriority - Enum Class in org.apache.pulsar.common.policies.data
offloadersDirectory(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
OffloadPolicies - Interface in org.apache.pulsar.common.policies.data
OffloadPolicies.Builder - Interface in org.apache.pulsar.common.policies.data
OffloadProcessStatus - Interface in org.apache.pulsar.client.admin: interface class of Status of offload process.
offloadStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics: Check the status of an ongoing offloading operation for a topic.
offloadStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Check the status of an ongoing offloading operation for a topic asynchronously.
openTimestamp - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata: The open time of this transaction.
org.apache.pulsar.client.admin - package org.apache.pulsar.client.admin: Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.pulsar.client.admin.utils - package org.apache.pulsar.client.admin.utils: Helpers which provide useful functionality for the implementation of Pulsar Client API.
org.apache.pulsar.common.conf - package org.apache.pulsar.common.conf: Classes for internal configuration.
org.apache.pulsar.common.functions - package org.apache.pulsar.common.functions: Implementation of policies.
org.apache.pulsar.common.io - package org.apache.pulsar.common.io: Implementation of policies.
org.apache.pulsar.common.naming - package org.apache.pulsar.common.naming: Implementation of policies.
org.apache.pulsar.common.partition - package org.apache.pulsar.common.partition: Implementation of policies.
org.apache.pulsar.common.policies - package org.apache.pulsar.common.policies: Implementation of policies.
org.apache.pulsar.common.policies.data - package org.apache.pulsar.common.policies.data: Implementation of policies.
org.apache.pulsar.common.policies.data.impl - package org.apache.pulsar.common.policies.data.impl: Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.pulsar.common.policies.impl - package org.apache.pulsar.common.policies.impl: Implementation of policies.
org.apache.pulsar.common.protocol.schema - package org.apache.pulsar.common.protocol.schema: Implementation of policies.
org.apache.pulsar.common.stats - package org.apache.pulsar.common.stats: Implementation of policies.
org.apache.pulsar.packages.management.core.common - package org.apache.pulsar.packages.management.core.common: Packages management general classes.
org.apache.pulsar.packages.management.core.exceptions - package org.apache.pulsar.packages.management.core.exceptions: Exceptions of the packages management service thrown.
org.apache.pulsar.policies.data.loadbalancer - package org.apache.pulsar.policies.data.loadbalancer: Implementation of policies.

P

PackageMetadata - Class in org.apache.pulsar.packages.management.core.common: Package metadata.
PackageMetadata() - Constructor for class org.apache.pulsar.packages.management.core.common.PackageMetadata
packages - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction: Permissions for packages ops.
packages() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Packages - Interface in org.apache.pulsar.client.admin: Administration operations of the packages management service.
PackagesManagementException - Exception in org.apache.pulsar.packages.management.core.exceptions: Packages management related exceptions.
PackagesManagementException(String) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException: Constructs an PackagesManagementException with the specified detail message.
PackagesManagementException(String, Throwable) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException: Constructs an PackagesManagementException with the specified detail message and the cause.
PackagesManagementException(Throwable) - Constructor for exception org.apache.pulsar.packages.management.core.exceptions.PackagesManagementException: Constructs an PackagesManagementException with the specified cause.
PackagesManagementException.MetadataFormatException - Exception in org.apache.pulsar.packages.management.core.exceptions
PackagesManagementException.NotFoundException - Exception in org.apache.pulsar.packages.management.core.exceptions
PackageType - Enum Class in org.apache.pulsar.packages.management.core.common: PackageType used to identify the package type.
pageSize - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolSubpageStats
parameters(Map<String, String>) - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData.Builder
parseFrom(String) - Static method in class org.apache.pulsar.common.functions.WorkerInfo
PARTITIONED - Enum constant in enum class org.apache.pulsar.common.policies.data.TopicType
PartitionedTopicInternalStats - Class in org.apache.pulsar.common.policies.data: Internal statistics for a partitioned topic.
PartitionedTopicInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
PartitionedTopicInternalStats(PartitionedTopicMetadata) - Constructor for class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
PartitionedTopicMetadata - Class in org.apache.pulsar.common.partition: Metadata of a partitioned topic.
PartitionedTopicMetadata() - Constructor for class org.apache.pulsar.common.partition.PartitionedTopicMetadata
PartitionedTopicMetadata(int) - Constructor for class org.apache.pulsar.common.partition.PartitionedTopicMetadata
PartitionedTopicMetadata(int, Map<String, String>) - Constructor for class org.apache.pulsar.common.partition.PartitionedTopicMetadata
PartitionedTopicStats - Interface in org.apache.pulsar.common.policies.data: Statistics for a partitioned topic.
partitions - Variable in class org.apache.pulsar.common.partition.PartitionedTopicMetadata
partitions - Variable in class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
peekMessages(String, String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Peek messages from a topic subscription.
peekMessagesAsync(String, String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Peek messages from a topic subscription asynchronously.
peerClusterNames(LinkedHashSet<String>) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
pendingAckLogStats - Variable in class org.apache.pulsar.common.policies.data.TransactionPendingAckInternalStats: The transaction pending ack log stats.
pendingAddEntriesCount - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The number of messages that complete (asynchronous) write requests.
pendingReadOps - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
percentUsage() - Method in class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
persistence - Variable in class org.apache.pulsar.common.policies.data.Policies
PersistencePolicies - Class in org.apache.pulsar.common.policies.data: Configuration of bookkeeper persistence policies.
PersistencePolicies() - Constructor for class org.apache.pulsar.common.policies.data.PersistencePolicies
PersistencePolicies(int, int, int, double) - Constructor for class org.apache.pulsar.common.policies.data.PersistencePolicies
persistent - Enum constant in enum class org.apache.pulsar.common.naming.TopicDomain
PersistentTopicInternalStats - Class in org.apache.pulsar.common.policies.data: Persistent topic internal statistics.
PersistentTopicInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
Policies - Class in org.apache.pulsar.common.policies.data: Definition of Pulsar policies.
Policies() - Constructor for class org.apache.pulsar.common.policies.data.Policies
Policies.BundleType - Enum Class in org.apache.pulsar.common.policies.data
policyName(String) - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData.Builder
policyType(AutoFailoverPolicyType) - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData.Builder
PoolArenaStats() - Constructor for class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
PoolChunkListStats() - Constructor for class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkListStats
PoolChunkStats() - Constructor for class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkStats
PoolSubpageStats() - Constructor for class org.apache.pulsar.common.stats.AllocatorStats.PoolSubpageStats
PostSchemaPayload - Class in org.apache.pulsar.common.protocol.schema: Payload with information about a schema.
PostSchemaPayload() - Constructor for class org.apache.pulsar.common.protocol.schema.PostSchemaPayload
PreconditionFailedException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.PreconditionFailedException
Prefix - Enum constant in enum class org.apache.pulsar.common.policies.data.SubscriptionAuthMode: Subscription name with auth role prefix can be used by the role.
primary - Enum constant in enum class org.apache.pulsar.common.policies.data.BrokerAssignment
primary(boolean) - Method in interface org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData.Builder
primary(List<String>) - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData.Builder
produce - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction: Permission to produce/publish messages.
producedPartitions - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata: The producedPartitions of this transaction.
producer_exception - Enum constant in enum class org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy: Policy which throws javax.jms.ResourceAllocationException to the producer.
producer_request_hold - Enum constant in enum class org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy: Policy which holds producer's send request until the resource becomes available (or holding times out).
ProducerConfig - Class in org.apache.pulsar.common.functions: Configuration of the producer inside the function.
ProducerConfig() - Constructor for class org.apache.pulsar.common.functions.ProducerConfig
producerCount - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
properties - Variable in class org.apache.pulsar.common.partition.PartitionedTopicMetadata
properties - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
properties - Variable in class org.apache.pulsar.common.policies.data.Policies
properties() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin: Deprecated.
since 2.0. See PulsarAdmin.tenants()
Properties - Interface in org.apache.pulsar.client.admin: Deprecated.
see Tenants from PulsarAdmin.tenants()
proxyProtocol(ProxyProtocol) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
proxyServiceUrl(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
proxyStats() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
ProxyStats - Interface in org.apache.pulsar.client.admin: Admin interface for proxy stats management.
PublisherStats - Interface in org.apache.pulsar.common.policies.data: Statistics about a publisher.
publishMaxMessageRate - Variable in class org.apache.pulsar.common.policies.data.Policies
PublishRate - Class in org.apache.pulsar.common.policies.data: Publish-rate to manage publish throttling.
PublishRate() - Constructor for class org.apache.pulsar.common.policies.data.PublishRate
PublishRate(int, long) - Constructor for class org.apache.pulsar.common.policies.data.PublishRate
publishThrottlingRateInByte - Variable in class org.apache.pulsar.common.policies.data.PublishRate
publishThrottlingRateInMsg - Variable in class org.apache.pulsar.common.policies.data.PublishRate
PulsarAdmin - Interface in org.apache.pulsar.client.admin
PulsarAdminBuilder - Interface in org.apache.pulsar.client.admin: Builder class for a PulsarAdmin instance.
PulsarAdminException - Exception in org.apache.pulsar.client.admin: Pulsar admin exceptions.
PulsarAdminException(String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
PulsarAdminException(String, Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
PulsarAdminException(String, Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
PulsarAdminException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
PulsarAdminException(Throwable, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
PulsarAdminException.ConflictException - Exception in org.apache.pulsar.client.admin: Conflict Exception.
PulsarAdminException.ConnectException - Exception in org.apache.pulsar.client.admin: Connect Exception.
PulsarAdminException.GettingAuthenticationDataException - Exception in org.apache.pulsar.client.admin: Getting Authentication Data Exception.
PulsarAdminException.HttpErrorException - Exception in org.apache.pulsar.client.admin: Http Error Exception.
PulsarAdminException.NotAllowedException - Exception in org.apache.pulsar.client.admin: Not Allowed Exception.
PulsarAdminException.NotAuthorizedException - Exception in org.apache.pulsar.client.admin: Not Authorized Exception.
PulsarAdminException.NotFoundException - Exception in org.apache.pulsar.client.admin: Not Found Exception.
PulsarAdminException.PreconditionFailedException - Exception in org.apache.pulsar.client.admin: Precondition Failed Exception.
PulsarAdminException.ServerSideErrorException - Exception in org.apache.pulsar.client.admin: Server Side Error Exception.
PulsarAdminException.TimeoutException - Exception in org.apache.pulsar.client.admin: Timeout Exception.
put(String, Object) - Method in class org.apache.pulsar.common.stats.Metrics
putAll(Map<String, Object>) - Method in class org.apache.pulsar.common.stats.Metrics
putFunctionState(String, String, String, FunctionState) - Method in interface org.apache.pulsar.client.admin.Functions: Puts the given state associated with a Pulsar Function.
putFunctionStateAsync(String, String, String, FunctionState) - Method in interface org.apache.pulsar.client.admin.Functions: Puts the given state associated with a Pulsar Function asynchronously.
PYTHON - Enum constant in enum class org.apache.pulsar.common.functions.FunctionConfig.Runtime

R

rack(String) - Method in interface org.apache.pulsar.common.policies.data.BookieInfo.Builder
rack(String) - Method in class org.apache.pulsar.common.policies.data.impl.BookieInfoImpl.BookieInfoImplBuilder
ratePeriodInSecond - Variable in class org.apache.pulsar.common.policies.data.SubscribeRate
ratePeriodInSecond(int) - Method in interface org.apache.pulsar.common.policies.data.DispatchRate.Builder
ratePeriodInSecond(int) - Method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
RawBookieInfo - Class in org.apache.pulsar.common.policies.data: Bookie information.
RawBookieInfo() - Constructor for class org.apache.pulsar.common.policies.data.RawBookieInfo
readPosition - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
readTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: This sets the server response read time out for the pulsar admin client for any request.
reason - Variable in class org.apache.pulsar.common.policies.data.ErrorData
rebalance() - Method in interface org.apache.pulsar.client.admin.Worker: Triggers a rebalance of functions to workers.
rebalanceAsync() - Method in interface org.apache.pulsar.client.admin.Worker: Triggers a rebalance of functions to workersasynchronously..
ReflectionUtils - Class in org.apache.pulsar.client.admin.utils
ReflectionUtils() - Constructor for class org.apache.pulsar.client.admin.utils.ReflectionUtils
relativeToPublishRate(boolean) - Method in interface org.apache.pulsar.common.policies.data.DispatchRate.Builder
relativeToPublishRate(boolean) - Method in class org.apache.pulsar.common.policies.data.impl.DispatchRateImpl.DispatchRateImplBuilder
reloadBuiltInSinks() - Method in interface org.apache.pulsar.client.admin.Sinks: Reload the available built-in connectors, include Source and Sink.
reloadBuiltInSinksAsync() - Method in interface org.apache.pulsar.client.admin.Sinks: Reload the available built-in connectors, include Source and Sink asynchronously.
reloadBuiltInSources() - Method in interface org.apache.pulsar.client.admin.Sources: Reload the available built-in connectors, include Source and Source.
reloadBuiltInSourcesAsync() - Method in interface org.apache.pulsar.client.admin.Sources: Reload the available built-in connectors, include Source and Source asynchronously.
removeAutoSubscriptionCreation(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Removes the autoSubscriptionCreation policy for a given namespace.
removeAutoSubscriptionCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Removes the autoSubscriptionCreation policy for a given namespace asynchronously.
removeAutoTopicCreation(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Removes the autoTopicCreation policy for a given namespace.
removeAutoTopicCreationAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Removes the autoTopicCreation policy for a given namespace asynchronously.
removeBacklogQuota(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
removeBacklogQuota(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
removeBacklogQuota(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeBacklogQuota(String, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove a backlog quota policy from a namespace.
removeBacklogQuota(String, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove a backlog quota policy from a topic.
removeBacklogQuota(String, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeBacklogQuotaAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
removeBacklogQuotaAsync(String, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove a backlog quota policy from a namespace asynchronously.
removeBookie(String) - Method in class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
removeCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete the compactionThreshold for a namespace.
removeCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the compactionThreshold for a topic.
removeCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete the compactionThreshold for a namespace asynchronously.
removeCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the compactionThreshold for a topic asynchronously.
removeCompactionThresholdAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the deduplicationSnapshotInterval for a namespace.
removeDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the deduplication snapshot interval for specified topic.
removeDeduplicationSnapshotInterval(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the deduplicationSnapshotInterval for a namespace asynchronously.
removeDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the deduplication snapshot interval for specified topic asynchronously.
removeDeduplicationSnapshotIntervalAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the deduplication status for all topics within a namespace.
removeDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: remove deduplication enabled of a topic.
removeDeduplicationStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the deduplication status for all topics within a namespace asynchronously.
removeDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: remove deduplication enabled of a topic asynchronously.
removeDeduplicationStatusAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeDelayedDeliveryMessages(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the delayed delivery messages for all topics within a namespace.
removeDelayedDeliveryMessagesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the delayed delivery messages for all topics within a namespace asynchronously.
removeDelayedDeliveryPolicy(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the delayed delivery policy for a specified topic.
removeDelayedDeliveryPolicy(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeDelayedDeliveryPolicyAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the delayed delivery policy for a specified topic asynchronously.
removeDelayedDeliveryPolicyAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove message-dispatch-rate.
removeDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove message-dispatch-rate.
removeDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove message-dispatch-rate asynchronously.
removeDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove message-dispatch-rate asynchronously.
removeDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove inactive topic policies from a namespace.
removeInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: remove inactive topic policies of a topic.
removeInactiveTopicPolicies(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: remove InactiveTopicPolicies from a namespace asynchronously.
removeInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: remove inactive topic policies of a topic asynchronously.
removeInactiveTopicPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxConsumers(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the max number of consumer for specified topic.
removeMaxConsumers(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxConsumersAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the max number of consumer for specified topic asynchronously.
removeMaxConsumersAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove maxConsumersPerSubscription for a namespace.
removeMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the maxConsumersPerSubscription for a topic.
removeMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove maxConsumersPerSubscription for a namespace asynchronously.
removeMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the maxConsumersPerSubscription for a topic asynchronously.
removeMaxConsumersPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxConsumersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove maxConsumersPerTopic for a namespace.
removeMaxConsumersPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove maxConsumersPerTopic for a namespace asynchronously.
removeMaxMessageSize(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the max message size for specified topic.
removeMaxMessageSize(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxMessageSizeAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the max message size for specified topic asynchronously.
removeMaxMessageSizeAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxProducers(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the max number of producer for specified topic.
removeMaxProducers(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxProducersAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the max number of producer for specified topic asynchronously.
removeMaxProducersAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxProducersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove maxProducersPerTopic for a namespace.
removeMaxProducersPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxProducersPerTopic for a namespace asynchronously.
removeMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the maxSubscriptionsPerTopic for a namespace.
removeMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the max number of subscriptions for specified topic.
removeMaxSubscriptionsPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the maxSubscriptionsPerTopic for a namespace asynchronously.
removeMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the max number of subscriptions for specified topic asynchronously.
removeMaxSubscriptionsPerTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxTopicsPerNamespace(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: remove maxTopicsPerNamespace for a namespace.
removeMaxTopicsPerNamespaceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: remove maxTopicsPerNamespace for a namespace asynchronously.
removeMaxUnackedMessagesOnConsumer(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: remove max unacked messages on consumer of a topic.
removeMaxUnackedMessagesOnConsumer(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxUnackedMessagesOnConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: remove max unacked messages on consumer of a topic asynchronously.
removeMaxUnackedMessagesOnConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxUnackedMessagesOnSubscription(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: remove max unacked messages on subscription of a topic.
removeMaxUnackedMessagesOnSubscription(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxUnackedMessagesOnSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: remove max unacked messages on subscription of a topic asynchronously.
removeMaxUnackedMessagesOnSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeMaxUnackedMessagesPerConsumer(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove maxUnackedMessagesPerConsumer for a namespace.
removeMaxUnackedMessagesPerConsumerAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove maxUnackedMessagesPerConsumer for a namespace asynchronously.
removeMaxUnackedMessagesPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove maxUnackedMessagesPerSubscription for a namespace.
removeMaxUnackedMessagesPerSubscriptionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove maxUnackedMessagesPerSubscription for a namespace asynchronously.
removeMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove message TTL for a topic.
removeMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeNamespaceMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the messages Time to Live for all the topics within a namespace.
removeNamespaceMessageTTLAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the messages Time to Live for all the topics within a namespace asynchronously.
removeNamespaceResourceGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the ResourceGroup on a namespace.
removeNamespaceResourceGroupAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the ResourceGroup on a namespace asynchronously.
removeOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the offload configuration for a namespace.
removeOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: remove offload policies of a topic.
removeOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the offload configuration for a namespace asynchronously.
removeOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: remove offload policies of a topic asynchronously.
removeOffloadPoliciesAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removePersistence(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the persistence configuration on a namespace.
removePersistence(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the configuration of persistence policies for specified topic.
removePersistence(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removePersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the persistence configuration on a namespace asynchronously.
removePersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the configuration of persistence policies for specified topic asynchronously.
removePersistenceAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeProperty(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove a property for a given key.
removePropertyAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove a property for a given key.
removePublishRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove message-publish-rate (topics under this namespace can publish this many messages per second).
removePublishRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove message-publish-rate.
removePublishRate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removePublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove message-publish-rate asynchronously.
removePublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove message-publish-rate asynchronously.
removePublishRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeReplicationClusters(String) - Method in interface org.apache.pulsar.client.admin.Topics: Remove the replication clusters for the topic.
removeReplicationClustersAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Remove the replication clusters for the topic asynchronously.
removeReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove replicator-message-dispatch-rate.
removeReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove replicatorDispatchRate for a topic.
removeReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set replicator-message-dispatch-rate asynchronously.
removeReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove replicatorDispatchRate for a topic asynchronously.
removeReplicatorDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeRetention(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the retention configuration for all the topics on a namespace.
removeRetention(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the retention configuration for all the topics on a topic.
removeRetention(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the retention configuration for all the topics on a namespace asynchronously.
removeRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove the retention configuration for all the topics on a topic asynchronously.
removeRetentionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeSchemaCompatibilityStrategy(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove schema compatibility strategy on a topic.
removeSchemaCompatibilityStrategyAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove schema compatibility strategy on a topic asynchronously.
removeSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove namespace-subscribe-rate (topics under this namespace will limit by subscribeRate).
removeSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove topic-subscribe-rate.
removeSubscribeRate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove namespace-subscribe-rate (topics under this namespace will limit by subscribeRate) asynchronously.
removeSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove topic-subscribe-rate asynchronously.
removeSubscribeRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove subscription-message-dispatch-rate.
removeSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove subscription-message-dispatch-rate for a topic.
removeSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove subscription-message-dispatch-rate asynchronously.
removeSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove subscription-message-dispatch-rate for a topic asynchronously.
removeSubscriptionDispatchRateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeSubscriptionExpirationTime(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the subscription expiration time for a namespace.
removeSubscriptionExpirationTimeAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove the subscription expiration time for a namespace asynchronously.
removeSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Removes the subscriptionTypesEnabled policy for a given namespace.
removeSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove subscription types enabled for a topic.
removeSubscriptionTypesEnabled(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
removeSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Removes the subscriptionTypesEnabled policy for a given namespace.
removeSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Remove subscription types enabled for a topic asynchronously.
removeSubscriptionTypesEnabledAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
replication_clusters - Variable in class org.apache.pulsar.common.policies.data.Policies
replicatorDispatchRate - Variable in class org.apache.pulsar.common.policies.data.Policies
ReplicatorStats - Interface in org.apache.pulsar.common.policies.data: Statistics about a replicator.
requestTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: This sets the server request time out for the pulsar admin client for any request.
reset() - Method in class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
reset() - Method in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
resetCursor(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Reset cursor position on a topic subscription.
resetCursor(String, String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics: Reset cursor position on a topic subscription.
resetCursor(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Reset cursor position on a topic subscription.
resetCursorAsync(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Reset cursor position on a topic subscription.
resetCursorAsync(String, String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics: Reset cursor position on a topic subscription.
resetCursorAsync(String, String, MessageId, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Reset cursor position on a topic subscription.
resetNamespaceBundleResourceQuota(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Reset resource quota for a namespace bundle to default value.
resetNamespaceBundleResourceQuotaAsync(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Reset resource quota for a namespace bundle to default value asynchronously.
resource_group_name - Variable in class org.apache.pulsar.common.policies.data.Policies
ResourceGroup - Class in org.apache.pulsar.common.policies.data
ResourceGroup() - Constructor for class org.apache.pulsar.common.policies.data.ResourceGroup
resourcegroups() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
ResourceGroups - Interface in org.apache.pulsar.client.admin: Admin interface for ResourceGroups management.
ResourceQuota - Class in org.apache.pulsar.common.policies.data: Resource quota for a namespace or namespace bundle.
ResourceQuota() - Constructor for class org.apache.pulsar.common.policies.data.ResourceQuota
resourceQuotas() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
ResourceQuotas - Interface in org.apache.pulsar.client.admin: Admin interface on interacting with resource quotas.
Resources - Class in org.apache.pulsar.common.functions: Class representing resources, such as CPU, RAM, and disk size.
Resources() - Constructor for class org.apache.pulsar.common.functions.Resources
ResourceUsage - Class in org.apache.pulsar.policies.data.loadbalancer: POJO used to represent any system specific resource usage this is the format that load manager expects it in.
ResourceUsage() - Constructor for class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
ResourceUsage(double, double) - Constructor for class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
restartFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Restart all function instances.
restartFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Restart function instance.
restartFunctionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Restart all function instances asynchronously.
restartFunctionAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Restart function instance asynchronously.
restartSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Restart all sink instances.
restartSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Restart sink instance.
restartSinkAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Restart all sink instances asynchronously.
restartSinkAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Restart sink instance asynchronously.
restartSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Restart all source instances.
restartSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Restart source instance.
restartSourceAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Restart all source instances asynchronously.
restartSourceAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Restart source instance asynchronously.
retention_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
RetentionPolicies - Class in org.apache.pulsar.common.policies.data: Definition of the retention policy.
RetentionPolicies() - Constructor for class org.apache.pulsar.common.policies.data.RetentionPolicies
RetentionPolicies(int, int) - Constructor for class org.apache.pulsar.common.policies.data.RetentionPolicies
retentionPolicy(BacklogQuota.RetentionPolicy) - Method in interface org.apache.pulsar.common.policies.data.BacklogQuota.Builder
retentionPolicy(BacklogQuota.RetentionPolicy) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl.BacklogQuotaImplBuilder
revokePermissionOnSubscription(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Revoke permissions on a subscription's admin-api access.
revokePermissionOnSubscriptionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Revoke permissions on a subscription's admin-api access asynchronously.
revokePermissions(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Revoke permissions on a topic.
revokePermissionsAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Revoke permissions on a topic asynchronously.
revokePermissionsOnNamespace(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Revoke permissions on a namespace.
revokePermissionsOnNamespaceAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Revoke permissions on a namespace asynchronously.
running - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
running - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
running - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
RUNNING - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status

S

s3ManagedLedgerOffloadBucket(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
s3ManagedLedgerOffloadCredentialId(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
s3ManagedLedgerOffloadCredentialSecret(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
s3ManagedLedgerOffloadMaxBlockSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
s3ManagedLedgerOffloadReadBufferSizeInBytes(Integer) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
s3ManagedLedgerOffloadRegion(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
s3ManagedLedgerOffloadRole(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
s3ManagedLedgerOffloadServiceEndpoint(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
schema_auto_update_compatibility_strategy - Variable in class org.apache.pulsar.common.policies.data.Policies: Deprecated.
schema_compatibility_strategy - Variable in class org.apache.pulsar.common.policies.data.Policies
schema_validation_enforced - Variable in class org.apache.pulsar.common.policies.data.Policies
SchemaAutoUpdateCompatibilityStrategy - Enum Class in org.apache.pulsar.common.policies.data: Strategy to use when checking an auto-updated schema for compatibility to the current schema.
SchemaCompatibilityStrategy - Enum Class in org.apache.pulsar.common.policies.data: Pulsar Schema compatibility strategy.
schemaLedgers - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
schemas() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Schemas - Interface in org.apache.pulsar.client.admin: Admin interface on interacting with schemas.
secondary - Enum constant in enum class org.apache.pulsar.common.policies.data.BrokerAssignment
secondary(List<String>) - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData.Builder
ServerSideErrorException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ServerSideErrorException
ServerSideErrorException(Throwable, String, String, int) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ServerSideErrorException
serviceHttpUrl(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Set the Pulsar service HTTP URL for the admin endpoint (eg.
ServiceLookupData - Interface in org.apache.pulsar.policies.data.loadbalancer: For backwards compatibility purposes.
serviceUrl(String) - Method in interface org.apache.pulsar.common.policies.data.BrokerInfo.Builder
serviceUrl(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
serviceUrl(String) - Method in class org.apache.pulsar.common.policies.data.impl.BrokerInfoImpl.BrokerInfoImplBuilder
serviceUrlTls(String) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
setAutoSubscriptionCreation(String, AutoSubscriptionCreationOverride) - Method in interface org.apache.pulsar.client.admin.Namespaces: Sets the autoSubscriptionCreation policy for a given namespace, overriding broker settings.
setAutoSubscriptionCreationAsync(String, AutoSubscriptionCreationOverride) - Method in interface org.apache.pulsar.client.admin.Namespaces: Sets the autoSubscriptionCreation policy for a given namespace, overriding broker settings asynchronously.
setAutoTopicCreation(String, AutoTopicCreationOverride) - Method in interface org.apache.pulsar.client.admin.Namespaces: Sets the autoTopicCreation policy for a given namespace, overriding broker settings.
setAutoTopicCreationAsync(String, AutoTopicCreationOverride) - Method in interface org.apache.pulsar.client.admin.Namespaces: Sets the autoTopicCreation policy for a given namespace, overriding broker settings asynchronously.
setBacklogQuota(String, BacklogQuota) - Method in interface org.apache.pulsar.client.admin.Namespaces
setBacklogQuota(String, BacklogQuota) - Method in interface org.apache.pulsar.client.admin.TopicPolicies
setBacklogQuota(String, BacklogQuota) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setBacklogQuota(String, BacklogQuota, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set a backlog quota for all the topics on a namespace.
setBacklogQuota(String, BacklogQuota, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set a backlog quota for a topic.
setBacklogQuota(String, BacklogQuota, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setBacklogQuotaAsync(String, BacklogQuota) - Method in interface org.apache.pulsar.client.admin.Namespaces
setBacklogQuotaAsync(String, BacklogQuota, BacklogQuota.BacklogQuotaType) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set a backlog quota for all the topics on a namespace asynchronously.
setBookieAffinityGroup(String, BookieAffinityGroupData) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set bookie affinity group for a namespace to isolate namespace write to bookies that are part of given affinity group.
setBookieAffinityGroupAsync(String, BookieAffinityGroupData) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set bookie affinity group for a namespace to isolate namespace write to bookies that are part of given affinity group asynchronously.
setCompactionThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the compactionThreshold for a namespace.
setCompactionThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the compactionThreshold for a topic.
setCompactionThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setCompactionThresholdAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the compactionThreshold for a namespace asynchronously.
setCompactionThresholdAsync(String, long) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the compactionThreshold for a topic asynchronously.
setCompactionThresholdAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setConfigurationStoreServers(String) - Method in class org.apache.pulsar.common.conf.InternalConfigurationData: Deprecated.
setContextClassLoader(ClassLoader) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
setDeduplicationSnapshotInterval(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the deduplication snapshot interval for specified topic.
setDeduplicationSnapshotInterval(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setDeduplicationSnapshotInterval(String, Integer) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the deduplicationSnapshotInterval for a namespace.
setDeduplicationSnapshotIntervalAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the deduplication snapshot interval for specified topic asynchronously.
setDeduplicationSnapshotIntervalAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setDeduplicationSnapshotIntervalAsync(String, Integer) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the deduplicationSnapshotInterval for a namespace asynchronously.
setDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the deduplication status for all topics within a namespace.
setDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: set deduplication enabled of a topic.
setDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setDeduplicationStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the deduplication status for all topics within a namespace asynchronously.
setDeduplicationStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: set deduplication enabled of a topic asynchronously.
setDeduplicationStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setDefaultResourceQuota(ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Set default resource quota for new namespace bundles.
setDefaultResourceQuotaAsync(ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Set default resource quota for new namespace bundles asynchronously.
setDelayedDeliveryMessages(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the delayed delivery messages for all topics within a namespace.
setDelayedDeliveryMessagesAsync(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the delayed delivery messages for all topics within a namespace asynchronously.
setDelayedDeliveryPolicy(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the delayed delivery policy for a specified topic.
setDelayedDeliveryPolicy(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setDelayedDeliveryPolicyAsync(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the delayed delivery policy for a specified topic asynchronously.
setDelayedDeliveryPolicyAsync(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set message-dispatch-rate (topics under this namespace can dispatch this many messages per second).
setDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set message-dispatch-rate (topic can dispatch this many messages per second).
setDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set message-dispatch-rate asynchronously.
setDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set message-dispatch-rate asynchronously.
setDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setEncryptionRequiredStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the encryption required status for all topics within a namespace.
setEncryptionRequiredStatusAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the encryption required status for all topics within a namespace asynchronously.
setInactiveTopicPolicies(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: As same as setInactiveTopicPoliciesAsync，but it is synchronous.
setInactiveTopicPolicies(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: set inactive topic policies of a topic.
setInactiveTopicPolicies(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setInactiveTopicPoliciesAsync(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: You can set the inactive deletion strategy at the namespace level.
setInactiveTopicPoliciesAsync(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: set inactive topic policies of a topic asynchronously.
setInactiveTopicPoliciesAsync(String, InactiveTopicPolicies) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setIsAllowAutoUpdateSchema(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set whether to allow automatic schema updates.
setIsAllowAutoUpdateSchemaAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set whether to allow automatic schema updates asynchronously.
setLimit(long) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl: Deprecated.
setLimitSize(long) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
setLimitTime(int) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
setMaxConsumers(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the max number of consumer for specified topic.
setMaxConsumers(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxConsumersAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the max number of consumer for specified topic asynchronously.
setMaxConsumersAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxConsumersPerSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxConsumersPerSubscription for a namespace.
setMaxConsumersPerSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set maxConsumersPerSubscription for a topic.
setMaxConsumersPerSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxConsumersPerSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxConsumersPerSubscription for a namespace asynchronously.
setMaxConsumersPerSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set maxConsumersPerSubscription for a topic asynchronously.
setMaxConsumersPerSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxConsumersPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxConsumersPerTopic for a namespace.
setMaxConsumersPerTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxConsumersPerTopic for a namespace asynchronously.
setMaxMessageSize(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the max message size for specified topic.
setMaxMessageSize(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxMessageSizeAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the max message size for specified topic asynchronously.0 disables.
setMaxMessageSizeAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxProducers(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the max number of producer for specified topic.
setMaxProducers(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxProducersAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the max number of producer for specified topic asynchronously.
setMaxProducersAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxProducersPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxProducersPerTopic for a namespace.
setMaxProducersPerTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxProducersPerTopic for a namespace asynchronously.
setMaxSubscriptionsPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the maxSubscriptionsPerTopic for a namespace.
setMaxSubscriptionsPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the max number of subscriptions for specified topic.
setMaxSubscriptionsPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxSubscriptionsPerTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the maxSubscriptionsPerTopic for a namespace asynchronously.
setMaxSubscriptionsPerTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the max number of subscriptions for specified topic asynchronously.
setMaxSubscriptionsPerTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxTopicsPerNamespace(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxTopicsPerNamespace for a namespace.
setMaxTopicsPerNamespaceAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxTopicsPerNamespace for a namespace asynchronously.
setMaxUnackedMessagesOnConsumer(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: set max unacked messages on consumer of a topic.
setMaxUnackedMessagesOnConsumer(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxUnackedMessagesOnConsumerAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: set max unacked messages on consumer of a topic asynchronously.
setMaxUnackedMessagesOnConsumerAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxUnackedMessagesOnSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: set max unacked messages on subscription of a topic.
setMaxUnackedMessagesOnSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxUnackedMessagesOnSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: set max unacked messages on subscription of a topic asynchronously.
setMaxUnackedMessagesOnSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setMaxUnackedMessagesPerConsumer(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxUnackedMessagesPerConsumer for a namespace.
setMaxUnackedMessagesPerConsumerAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxUnackedMessagesPerConsumer for a namespace asynchronously.
setMaxUnackedMessagesPerSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxUnackedMessagesPerSubscription for a namespace.
setMaxUnackedMessagesPerSubscriptionAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxUnackedMessagesPerSubscription for a namespace asynchronously.
setMessageTTL(String, int) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set message TTL for a topic.
setMessageTTL(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setNamespaceAntiAffinityGroup(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set anti-affinity group name for a namespace.
setNamespaceAntiAffinityGroupAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set anti-affinity group name for a namespace asynchronously.
setNamespaceBundleResourceQuota(String, String, ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Set resource quota for a namespace bundle.
setNamespaceBundleResourceQuotaAsync(String, String, ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Set resource quota for a namespace bundle asynchronously.
setNamespaceMessageTTL(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the messages Time to Live for all the topics within a namespace.
setNamespaceMessageTTLAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the messages Time to Live for all the topics within a namespace asynchronously.
setNamespaceReplicationClusters(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the replication clusters for a namespace.
setNamespaceReplicationClustersAsync(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the replication clusters for a namespace asynchronously.
setNamespaceResourceGroup(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the ResourceGroup for a namespace.
setNamespaceResourceGroupAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the ResourceGroup for a namespace asynchronously.
setOffloadDeleteLag(String, long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the offload deletion lag for a namespace.
setOffloadDeleteLagAsync(String, long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the offload deletion lag for a namespace asynchronously.
setOffloadPolicies(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the offload configuration for all the topics in a namespace.
setOffloadPolicies(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: set offload policies of a topic.
setOffloadPolicies(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setOffloadPoliciesAsync(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the offload configuration for all the topics in a namespace asynchronously.
setOffloadPoliciesAsync(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: set offload policies of a topic asynchronously.
setOffloadPoliciesAsync(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setOffloadThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the offloadThreshold for a namespace.
setOffloadThresholdAsync(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the offloadThreshold for a namespace asynchronously.
setPersistence(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the persistence configuration for all the topics on a namespace.
setPersistence(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the configuration of persistence policies for specified topic.
setPersistence(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setPersistenceAsync(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the persistence configuration for all the topics on a namespace asynchronously.
setPersistenceAsync(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the configuration of persistence policies for specified topic asynchronously.
setPersistenceAsync(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setPolicy(BacklogQuota.RetentionPolicy) - Method in class org.apache.pulsar.common.policies.data.impl.BacklogQuotaImpl
setProperties(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set key value pair properties for a namespace.
setPropertiesAsync(String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set key value pair properties for a namespace asynchronously.
setProperty(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set key value pair property for a namespace.
setPropertyAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: <<<<<<< HEAD Set key value pair property for a namespace.
setPublishRate(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set message-publish-rate (topics under this namespace can publish this many messages per second).
setPublishRate(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set message-publish-rate (topics can publish this many messages per second).
setPublishRate(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setPublishRateAsync(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set message-publish-rate (topics under this namespace can publish this many messages per second) asynchronously.
setPublishRateAsync(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set message-publish-rate (topics can publish this many messages per second) asynchronously.
setPublishRateAsync(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setReplicatedSubscriptionStatus(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Enable or disable a replicated subscription on a topic.
setReplicatedSubscriptionStatusAsync(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Enable or disable a replicated subscription on a topic asynchronously.
setReplicationClusters(String, List<String>) - Method in interface org.apache.pulsar.client.admin.Topics: Set the replication clusters for the topic.
setReplicationClustersAsync(String, List<String>) - Method in interface org.apache.pulsar.client.admin.Topics: Set the replication clusters for the topic asynchronously.
setReplicatorDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set replicator-message-dispatch-rate.
setReplicatorDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set replicatorDispatchRate for the topic.
setReplicatorDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setReplicatorDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set replicator-message-dispatch-rate asynchronously.
setReplicatorDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set replicatorDispatchRate for the topic asynchronously.
setReplicatorDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setRetention(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the retention configuration for all the topics on a namespace.
setRetention(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the retention configuration on a topic.
setRetention(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setRetentionAsync(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the retention configuration for all the topics on a namespace asynchronously.
setRetentionAsync(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set the retention configuration for all the topics on a topic asynchronously.
setRetentionAsync(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setS3ManagedLedgerOffloadRoleSessionName(String) - Method in interface org.apache.pulsar.common.policies.data.OffloadPolicies.Builder
setSchemaAutoUpdateCompatibilityStrategy(String, SchemaAutoUpdateCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.Namespaces: Deprecated.
setSchemaCompatibilityStrategy(String, SchemaCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed.
setSchemaCompatibilityStrategy(String, SchemaCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set schema compatibility strategy on a topic.
setSchemaCompatibilityStrategyAsync(String, SchemaCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed asynchronously.
setSchemaCompatibilityStrategyAsync(String, SchemaCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set schema compatibility strategy on a topic asynchronously.
setSchemaValidationEnforced(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set schema validation enforced for namespace.
setSchemaValidationEnforcedAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set schema validation enforced for namespace asynchronously.
setSubscribeRate(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set namespace-subscribe-rate (topics under this namespace will limit by subscribeRate).
setSubscribeRate(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set topic-subscribe-rate (topic will limit by subscribeRate).
setSubscribeRate(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setSubscribeRateAsync(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set namespace-subscribe-rate (topics under this namespace will limit by subscribeRate) asynchronously.
setSubscribeRateAsync(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set topic-subscribe-rate (topics will limit by subscribeRate) asynchronously.
setSubscribeRateAsync(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setSubscriptionAuthMode(String, SubscriptionAuthMode) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the given subscription auth mode on all topics on a namespace.
setSubscriptionAuthModeAsync(String, SubscriptionAuthMode) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the given subscription auth mode on all topics on a namespace asynchronously.
setSubscriptionDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set subscription-message-dispatch-rate.
setSubscriptionDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set subscription-message-dispatch-rate for the topic.
setSubscriptionDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setSubscriptionDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set subscription-message-dispatch-rate asynchronously.
setSubscriptionDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set subscription-message-dispatch-rate for the topic asynchronously.
setSubscriptionDispatchRateAsync(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setSubscriptionExpirationTime(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the subscription expiration time in minutes for all the topics within a namespace.
setSubscriptionExpirationTimeAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the subscription expiration time in minutes for all the topics within a namespace asynchronously.
setSubscriptionTypesEnabled(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Sets the subscriptionTypesEnabled policy for a given namespace, overriding broker settings.
setSubscriptionTypesEnabled(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set is enable sub types.
setSubscriptionTypesEnabled(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setSubscriptionTypesEnabledAsync(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Sets the subscriptionTypesEnabled policy for a given namespace, overriding broker settings.
setSubscriptionTypesEnabledAsync(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.TopicPolicies: Set is enable sub types asynchronously.
setSubscriptionTypesEnabledAsync(String, Set<SubscriptionType>) - Method in interface org.apache.pulsar.client.admin.Topics: Deprecated.
setUpdateAuthData(boolean) - Method in interface org.apache.pulsar.common.functions.UpdateOptions
setZookeeperServers(String) - Method in class org.apache.pulsar.common.conf.InternalConfigurationData: Deprecated.
shared - Enum constant in enum class org.apache.pulsar.common.policies.data.BrokerAssignment
shouldFailoverToSecondary(int) - Method in class org.apache.pulsar.common.policies.AutoFailoverPolicy
shouldFailoverToSecondary(int) - Method in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
shouldFailoverToSecondary(SortedSet<BrokerStatus>) - Method in class org.apache.pulsar.common.policies.AutoFailoverPolicy: Checks to see whether the new namespace ownership should be failed over to the secondary brokers.
shouldFailoverToSecondary(SortedSet<BrokerStatus>) - Method in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
shutDownBrokerGracefully(int, boolean) - Method in interface org.apache.pulsar.client.admin.Brokers: Shutdown current broker gracefully.
sink() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin: Deprecated.
in favor of PulsarAdmin.sinks()
Sink - Interface in org.apache.pulsar.client.admin: Deprecated.
in favor of Sinks
SINK - Enum constant in enum class org.apache.pulsar.packages.management.core.common.PackageType
SinkConfig - Class in org.apache.pulsar.common.io: Configuration of Pulsar Sink.
SinkConfig() - Constructor for class org.apache.pulsar.common.io.SinkConfig
SinkInstanceStatus() - Constructor for class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus
SinkInstanceStatusData() - Constructor for class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
sinks - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction: Permissions for sinks ops.
sinks() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Sinks - Interface in org.apache.pulsar.client.admin: Admin interface for Sink management.
SinkStatus - Class in org.apache.pulsar.common.policies.data: Status of Pulsar Sink.
SinkStatus() - Constructor for class org.apache.pulsar.common.policies.data.SinkStatus
SinkStatus.SinkInstanceStatus - Class in org.apache.pulsar.common.policies.data: Status of a Sink instance.
SinkStatus.SinkInstanceStatus.SinkInstanceStatusData - Class in org.apache.pulsar.common.policies.data: Status data of a Sink instance.
size - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
skipAllMessages(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Skip all messages on a topic subscription.
skipAllMessagesAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Skip all messages on a topic subscription asynchronously.
skipMessages(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Skip messages on a topic subscription.
skipMessagesAsync(String, String, long) - Method in interface org.apache.pulsar.client.admin.Topics: Skip messages on a topic subscription asynchronously.
smallCacheSize - Variable in class org.apache.pulsar.common.stats.AllocatorStats
smallSubpages - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolArenaStats
source() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin: Deprecated.
in favor of PulsarAdmin.sources()
Source - Interface in org.apache.pulsar.client.admin: Deprecated.
in favor of Sources
SOURCE - Enum constant in enum class org.apache.pulsar.packages.management.core.common.PackageType
SourceConfig - Class in org.apache.pulsar.common.io: Pulsar source configuration.
SourceConfig() - Constructor for class org.apache.pulsar.common.io.SourceConfig
SourceInstanceStatus() - Constructor for class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus
SourceInstanceStatusData() - Constructor for class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
sources - Enum constant in enum class org.apache.pulsar.common.policies.data.AuthAction: Permissions for sources ops.
sources() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Sources - Interface in org.apache.pulsar.client.admin: Admin interface for Source management.
SourceStatus - Class in org.apache.pulsar.common.policies.data: Source status.
SourceStatus() - Constructor for class org.apache.pulsar.common.policies.data.SourceStatus
SourceStatus.SourceInstanceStatus - Class in org.apache.pulsar.common.policies.data: Source instance status.
SourceStatus.SourceInstanceStatus.SourceInstanceStatusData - Class in org.apache.pulsar.common.policies.data: Source instance status data.
splitNamespaceBundle(String, String, boolean, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Split namespace bundle.
splitNamespaceBundleAsync(String, String, boolean, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Split namespace bundle asynchronously.
sslProvider(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: The name of the security provider used for SSL connections.
startFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Start all function instances.
startFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Start function instance.
startFunctionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Start all function instances asynchronously.
startFunctionAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Start function instance asynchronously.
startPosition - Variable in class org.apache.pulsar.common.policies.data.TransactionInBufferStats: The start position of this transaction in transaction buffer.
startSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Start all sink instances.
startSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Start sink instance.
startSinkAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Start all sink instances asynchronously.
startSinkAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Start sink instance asynchronously.
startSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Start all source instances.
startSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Start source instance.
startSourceAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Start all source instances asynchronously.
startSourceAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Start source instance asynchronously.
state - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
state - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The state of this ledger for writing.
state - Variable in class org.apache.pulsar.common.policies.data.TransactionBufferStats: The state of this transaction buffer.
state - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats: The state of this transaction metadataStore.
state - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorStatus: The state of this transaction metadataStore.
state - Variable in class org.apache.pulsar.common.policies.data.TransactionPendingAckStats: The state of this pending ack.
status - Variable in class org.apache.pulsar.client.admin.LongRunningProcessStatus
status - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus
status - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus
status - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus
status - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata: The status of this transaction.
stopFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Stop all function instances.
stopFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Stop function instance.
stopFunctionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Stop all function instances asynchronously.
stopFunctionAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Stop function instance asynchronously.
stopSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Stop all sink instances.
stopSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Stop sink instance.
stopSinkAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Stop all sink instances asynchronously.
stopSinkAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Stop sink instance asynchronously.
stopSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Stop all source instances.
stopSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Stop source instance.
stopSourceAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Stop all source instances asynchronously.
stopSourceAsync(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Stop source instance asynchronously.
SubscribeRate - Class in org.apache.pulsar.common.policies.data: Information about subscription rate.
SubscribeRate() - Constructor for class org.apache.pulsar.common.policies.data.SubscribeRate
SubscribeRate(int, int) - Constructor for class org.apache.pulsar.common.policies.data.SubscribeRate
subscribeThrottlingRatePerConsumer - Variable in class org.apache.pulsar.common.policies.data.SubscribeRate
subscription_auth_mode - Variable in class org.apache.pulsar.common.policies.data.Policies
subscription_expiration_time_minutes - Variable in class org.apache.pulsar.common.policies.data.Policies
subscription_types_enabled - Variable in class org.apache.pulsar.common.policies.data.Policies
subscriptionAuthentication(Map<String, Set<String>>) - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies.Builder
SubscriptionAuthMode - Enum Class in org.apache.pulsar.common.policies.data: Subscription authorization for Pulsar policies.
subscriptionDispatchRate - Variable in class org.apache.pulsar.common.policies.data.Policies
subscriptionHavePendingRead - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
subscriptionHavePendingReplayRead - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
SubscriptionStats - Interface in org.apache.pulsar.common.policies.data: Statistics about subscription.
substract(ResourceQuota) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota: Substract quota.
success() - Static method in class org.apache.pulsar.common.policies.data.ValidateResult
SUCCESS - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status

T

TenantInfo - Interface in org.apache.pulsar.common.policies.data
TenantInfo.Builder - Interface in org.apache.pulsar.common.policies.data
tenants() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Tenants - Interface in org.apache.pulsar.client.admin: Admin interface for tenants management.
terminatePartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics: Terminate the partitioned topic and prevent any more messages being published on it.
terminatePartitionedTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Terminate the partitioned topic and prevent any more messages being published on it.
terminateTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics: Terminate the topic and prevent any more messages being published on it.
terminateTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Terminate the topic and prevent any more messages being published on it.
testCompatibility(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas: Judge schema compatibility topic.
testCompatibility(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas: Judge schema compatibility topic.
testCompatibilityAsync(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas: Judge schema compatibility topic asynchronously.
testCompatibilityAsync(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas: Judge schema compatibility topic asynchronously.
tickTime(long) - Method in interface org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies.Builder
tickTime(long) - Method in class org.apache.pulsar.common.policies.data.impl.DelayedDeliveryPoliciesImpl.DelayedDeliveryPoliciesImplBuilder
TIERED_STORAGE_FIRST - Enum constant in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority: For offloaded messages, readers will try to read from offloaded storage first, even they are still exist in bookkeeper.
timeoutAt - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata: The timeout of this transaction.
TimeoutException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.TimeoutException
tlsAllowInsecureConnection(boolean) - Method in interface org.apache.pulsar.common.policies.data.ClusterData.Builder
tlsCiphers(Set<String>) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: A list of cipher suites.
tlsProtocols(Set<String>) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: The SSL protocol used to generate the SSLContext.
tlsTrustCertsFilePath(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Set the path to the trusted TLS certificate file.
tlsTrustStorePassword(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: The store password for the key store file.
tlsTrustStorePath(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: The location of the trust store file.
tlsTrustStoreType(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: The file format of the trust store file.
topicAuthentication(Map<String, Map<String, Set<AuthAction>>>) - Method in interface org.apache.pulsar.common.policies.data.AuthPolicies.Builder
topicDispatchRate - Variable in class org.apache.pulsar.common.policies.data.Policies
TopicDomain - Enum Class in org.apache.pulsar.common.naming: Enumeration showing if a topic is persistent.
topicPolicies() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin: Get the topic policies management object.
topicPolicies(boolean) - Method in interface org.apache.pulsar.client.admin.PulsarAdmin: Get the local/global topic policies management object.
TopicPolicies - Interface in org.apache.pulsar.client.admin: Admin interface for topic policies management.
topics - Variable in class org.apache.pulsar.policies.data.loadbalancer.NamespaceBundleStats
topics() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Topics - Interface in org.apache.pulsar.client.admin: Admin interface for Topics management.
Topics.QueryParam - Enum Class in org.apache.pulsar.client.admin
TopicStats - Interface in org.apache.pulsar.common.policies.data: Statistics for a Pulsar topic.
topicType(String) - Method in interface org.apache.pulsar.common.policies.data.AutoTopicCreationOverride.Builder
topicType(String) - Method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl.AutoTopicCreationOverrideImplBuilder
TopicType - Enum Class in org.apache.pulsar.common.policies.data: Topic types -- partitioned or non-partitioned.
TopicVersion - Enum Class in org.apache.pulsar.common.naming
toString() - Method in enum class org.apache.pulsar.common.naming.TopicDomain
toString() - Method in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
toString() - Method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority
toString() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
toString() - Method in enum class org.apache.pulsar.common.policies.data.TopicType
toString() - Method in class org.apache.pulsar.common.stats.Metrics
toString() - Method in enum class org.apache.pulsar.packages.management.core.common.PackageType
totalNonContiguousDeletedMessagesRange - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
totalSize - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The total storage size of all messages (in bytes).
TransactionBufferStats - Class in org.apache.pulsar.common.policies.data
TransactionBufferStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionBufferStats
TransactionCoordinatorInternalStats - Class in org.apache.pulsar.common.policies.data: Transaction coordinator internal stats.
TransactionCoordinatorInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionCoordinatorInternalStats
TransactionCoordinatorStats - Class in org.apache.pulsar.common.policies.data: Transaction coordinator stats.
TransactionCoordinatorStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionCoordinatorStats
TransactionCoordinatorStatus - Class in org.apache.pulsar.common.policies.data: Transaction coordinator status.
TransactionCoordinatorStatus() - Constructor for class org.apache.pulsar.common.policies.data.TransactionCoordinatorStatus
TransactionInBufferStats - Class in org.apache.pulsar.common.policies.data
TransactionInBufferStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionInBufferStats
TransactionInPendingAckStats - Class in org.apache.pulsar.common.policies.data
TransactionInPendingAckStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionInPendingAckStats
transactionLogStats - Variable in class org.apache.pulsar.common.policies.data.TransactionCoordinatorInternalStats: The transaction coordinator log stats.
TransactionLogStats - Class in org.apache.pulsar.common.policies.data: Transaction log stats.
TransactionLogStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionLogStats
TransactionMetadata - Class in org.apache.pulsar.common.policies.data
TransactionMetadata() - Constructor for class org.apache.pulsar.common.policies.data.TransactionMetadata
TransactionPendingAckInternalStats - Class in org.apache.pulsar.common.policies.data: Transaction pending ack internal stats.
TransactionPendingAckInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionPendingAckInternalStats
TransactionPendingAckStats - Class in org.apache.pulsar.common.policies.data
TransactionPendingAckStats() - Constructor for class org.apache.pulsar.common.policies.data.TransactionPendingAckStats
transactions() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Transactions - Interface in org.apache.pulsar.client.admin
triggerCompaction(String) - Method in interface org.apache.pulsar.client.admin.Topics: Trigger compaction to run for a topic.
triggerCompactionAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Trigger compaction to run for a topic asynchronously.
triggerFunction(String, String, String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Triggers the function by writing to the input topic.
triggerFunctionAsync(String, String, String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Triggers the function by writing to the input topic asynchronously.
triggerOffload(String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics: Trigger offloading messages in topic to longterm storage.
triggerOffloadAsync(String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics: Trigger offloading messages in topic to longterm storage asynchronously.
truncate(String) - Method in interface org.apache.pulsar.client.admin.Topics: Truncate a topic.
truncateAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Truncate a topic asynchronously.
txnId - Variable in class org.apache.pulsar.common.policies.data.TransactionMetadata: The txnId of this transaction.

U

UNDEFINED - Enum constant in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Undefined.
underReplicated - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.LedgerInfo
unload(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unload a namespace from the current serving broker.
unload(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Unload a topic.
unload(String) - Method in interface org.apache.pulsar.client.admin.Topics: Unload a topic.
unloadAsync(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unload a namespace from the current serving broker asynchronously.
unloadAsync(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

Unload a topic asynchronously.
unloadAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Unload a topic asynchronously.
unloadNamespaceBundle(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unload namespace bundle.
unloadNamespaceBundleAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unload namespace bundle asynchronously.
unsubscribeNamespace(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unsubscribe the given subscription on all topics on a namespace.
unsubscribeNamespaceAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unsubscribe the given subscription on all topics on a namespace asynchronously.
unsubscribeNamespaceBundle(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unsubscribe the given subscription on all topics on a namespace bundle.
unsubscribeNamespaceBundleAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unsubscribe the given subscription on all topics on a namespace bundle asynchronously.
updateBookie(String, String, BookieInfo) - Method in class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
updateBookieRackInfo(String, String, BookieInfo) - Method in interface org.apache.pulsar.client.admin.Bookies: Updates the rack placement information for a specific bookie in the cluster.
updateBookieRackInfoAsync(String, String, BookieInfo) - Method in interface org.apache.pulsar.client.admin.Bookies: Updates the rack placement information for a specific bookie in the cluster asynchronously.
updateCluster(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters: Update the configuration for a cluster.
updateClusterAsync(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters: Update the configuration for a cluster asynchronously.
updateDynamicConfiguration(String, String) - Method in interface org.apache.pulsar.client.admin.Brokers: Update a dynamic configuration value into ZooKeeper.
updateDynamicConfigurationAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Brokers: Update a dynamic configuration value into ZooKeeper asynchronously.
updateFailureDomain(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters: Update a domain into cluster.
updateFailureDomainAsync(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters: Update a domain into cluster asynchronously.
updateFunction(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function.
updateFunction(FunctionConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function.
updateFunctionAsync(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function asynchronously.
updateFunctionAsync(FunctionConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function asynchronously.
updateFunctionWithUrl(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function.
updateFunctionWithUrl(FunctionConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function.
updateFunctionWithUrlAsync(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function asynchronously.
updateFunctionWithUrlAsync(FunctionConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function asynchronously.
updateMetadata(String, PackageMetadata) - Method in interface org.apache.pulsar.client.admin.Packages: Update a package metadata information.
updateMetadataAsync(String, PackageMetadata) - Method in interface org.apache.pulsar.client.admin.Packages: Update a package metadata information asynchronously.
updateNamespaceIsolationPolicy(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters: Update a namespace isolation policy for a cluster.
updateNamespaceIsolationPolicyAsync(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters: Update a namespace isolation policy for a cluster asynchronously.
UpdateOptions - Interface in org.apache.pulsar.common.functions
updatePartitionedTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Update number of partitions of a non-global partitioned topic.
updatePartitionedTopic(String, int, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Update number of partitions of a non-global partitioned topic.
updatePartitionedTopic(String, int, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Update number of partitions of a non-global partitioned topic.
updatePartitionedTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Update number of partitions of a non-global partitioned topic asynchronously.
updatePartitionedTopicAsync(String, int, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Update number of partitions of a non-global partitioned topic asynchronously.
updatePartitionedTopicAsync(String, int, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Update number of partitions of a non-global partitioned topic asynchronously.
updatePeerClusterNames(String, LinkedHashSet<String>) - Method in interface org.apache.pulsar.client.admin.Clusters: Update peer cluster names.
updatePeerClusterNamesAsync(String, LinkedHashSet<String>) - Method in interface org.apache.pulsar.client.admin.Clusters: Update peer cluster names asynchronously.
updateProperty(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Properties: Deprecated.

Update the admins for a property.
updateResourceGroup(String, ResourceGroup) - Method in interface org.apache.pulsar.client.admin.ResourceGroups: Update the configuration for a ResourceGroup.
updateResourceGroupAsync(String, ResourceGroup) - Method in interface org.apache.pulsar.client.admin.ResourceGroups: Update the configuration for a ResourceGroup.
updateSink(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink.
updateSink(SinkConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink.
updateSinkAsync(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink asynchronously.
updateSinkAsync(SinkConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink asynchronously.
updateSinkWithUrl(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink.
updateSinkWithUrl(SinkConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink.
updateSinkWithUrlAsync(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink asynchronously.
updateSinkWithUrlAsync(SinkConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink asynchronously.
updateSource(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source.
updateSource(SourceConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source.
updateSourceAsync(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source asynchronously.
updateSourceAsync(SourceConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source asynchronously.
updateSourceWithUrl(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source.
updateSourceWithUrl(SourceConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source.
updateSourceWithUrlAsync(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source asynchronously.
updateSourceWithUrlAsync(SourceConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source asynchronously.
updateSubscriptionProperties(String, String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics: Update Subscription Properties on a topic subscription.
updateSubscriptionPropertiesAsync(String, String, Map<String, String>) - Method in interface org.apache.pulsar.client.admin.Topics: Update Subscription Properties on a topic subscription.
updateTenant(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants: Update the admins for a tenant.
updateTenantAsync(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants: Update the admins for a tenant asynchronously.
upload(PackageMetadata, String, String) - Method in interface org.apache.pulsar.client.admin.Packages: Upload a package to the package management service.
uploadAsync(PackageMetadata, String, String) - Method in interface org.apache.pulsar.client.admin.Packages: Upload a package to the package management service asynchronously.
uploadFunction(String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Upload Data.
uploadFunctionAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Upload Data asynchronously.
usage - Variable in class org.apache.pulsar.common.stats.AllocatorStats.PoolChunkStats
usage - Variable in class org.apache.pulsar.policies.data.loadbalancer.ResourceUsage
usage_threshold - Variable in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
useKeyStoreTls(boolean) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: If Tls is enabled, whether use KeyStore type as tls configuration parameter.

V

V1 - Enum constant in enum class org.apache.pulsar.common.naming.TopicVersion
V2 - Enum constant in enum class org.apache.pulsar.common.naming.TopicVersion
validate() - Method in interface org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
validate() - Method in interface org.apache.pulsar.common.policies.data.NamespaceIsolationData
validateOverride(AutoTopicCreationOverride) - Static method in class org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl
ValidateResult - Class in org.apache.pulsar.common.policies.data
value - Variable in enum class org.apache.pulsar.client.admin.Topics.QueryParam
value() - Method in enum class org.apache.pulsar.common.naming.TopicDomain
value() - Method in enum class org.apache.pulsar.packages.management.core.common.PackageType
valueOf(String) - Static method in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.client.admin.Topics.QueryParam: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.functions.FunctionConfig.Runtime: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.naming.TopicDomain: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.naming.TopicVersion: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.AuthAction: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.AutoFailoverPolicyType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.BacklogQuota.BacklogQuotaType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.BrokerAssignment: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.InactiveTopicDeleteMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.Policies.BundleType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.SubscriptionAuthMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.common.policies.data.TopicType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.pulsar.packages.management.core.common.PackageType: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.client.admin.Topics.QueryParam: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.functions.FunctionConfig.ProcessingGuarantees: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.functions.FunctionConfig.Runtime: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.naming.TopicDomain: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.naming.TopicVersion: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.AuthAction: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.AutoFailoverPolicyType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.BacklogQuota.BacklogQuotaType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.BrokerAssignment: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.InactiveTopicDeleteMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.OffloadedReadPriority: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.Policies.BundleType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.SubscriptionAuthMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.common.policies.data.TopicType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.pulsar.packages.management.core.common.PackageType: Returns an array containing the constants of this enum class, in the order they are declared.

W

waitingCursorsCount - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats: The number of cursors that are "caught up" and waiting for a new message to be published.
waitingReadOp - Variable in class org.apache.pulsar.common.policies.data.ManagedLedgerInternalStats.CursorStats
WINDOW_CONFIG_KEY - Static variable in class org.apache.pulsar.common.functions.WindowConfig
WindowConfig - Class in org.apache.pulsar.common.functions: Configuration of a windowing function.
WindowConfig() - Constructor for class org.apache.pulsar.common.functions.WindowConfig
worker() - Method in interface org.apache.pulsar.client.admin.PulsarAdmin
Worker - Interface in org.apache.pulsar.client.admin: Admin interface for worker stats management.
WorkerFunctionInstanceStats - Class in org.apache.pulsar.common.policies.data: Data class holding statistics about a function.
WorkerFunctionInstanceStats() - Constructor for class org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats
workerId - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
workerId - Variable in class org.apache.pulsar.common.policies.data.SinkStatus.SinkInstanceStatus.SinkInstanceStatusData
workerId - Variable in class org.apache.pulsar.common.policies.data.SourceStatus.SourceInstanceStatus.SourceInstanceStatusData
WorkerInfo - Class in org.apache.pulsar.common.functions: Worker information.
WorkerInfo() - Constructor for class org.apache.pulsar.common.functions.WorkerInfo

A B C D E F G H I J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form