Skip navigation links
A B C D E F G H I L M N O P R S T U V W 

A

activeConsumerName - Variable in class org.apache.pulsar.common.policies.data.SubscriptionStats
The name of the consumer that is active for single active consumer subscriptions i.e.
add(ConsumerStats) - Method in class org.apache.pulsar.common.policies.data.ConsumerStats
 
add(NonPersistentPublisherStats) - Method in class org.apache.pulsar.common.policies.data.NonPersistentPublisherStats
 
add(NonPersistentReplicatorStats) - Method in class org.apache.pulsar.common.policies.data.NonPersistentReplicatorStats
 
add(NonPersistentSubscriptionStats) - Method in class org.apache.pulsar.common.policies.data.NonPersistentSubscriptionStats
 
add(NonPersistentTopicStats) - Method in class org.apache.pulsar.common.policies.data.NonPersistentTopicStats
 
add(PublisherStats) - Method in class org.apache.pulsar.common.policies.data.PublisherStats
 
add(ReplicatorStats) - Method in class org.apache.pulsar.common.policies.data.ReplicatorStats
 
add(ResourceQuota) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Add quota.
add(SubscriptionStats) - Method in class org.apache.pulsar.common.policies.data.SubscriptionStats
 
add(TopicStats) - Method in class org.apache.pulsar.common.policies.data.TopicStats
 
addCursorDetails(String, long, long) - Method in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
 
addInstance(FunctionStats.FunctionInstanceStats) - Method in class org.apache.pulsar.common.policies.data.FunctionStats
 
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
 
addLedgerDetails(long, long, long, long) - Method in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
 
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)
antiAffinityGroup - Variable in class org.apache.pulsar.common.policies.data.Policies
 
assignBroker(NamespaceName, BrokerStatus, SortedSet<BrokerStatus>, SortedSet<BrokerStatus>, SortedSet<BrokerStatus>) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies
 
auth - Variable in class org.apache.pulsar.client.admin.PulsarAdmin
 
auth_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
 
AuthAction - Enum 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.
AuthPolicies - Class in org.apache.pulsar.common.policies.data
 
AuthPolicies() - Constructor for class org.apache.pulsar.common.policies.data.AuthPolicies
 
auto_failover_policy - Variable in class org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
AutoFailoverPolicy - Class in org.apache.pulsar.common.policies
 
AutoFailoverPolicy() - Constructor for class org.apache.pulsar.common.policies.AutoFailoverPolicy
 
AutoFailoverPolicyData - Class in org.apache.pulsar.common.policies.data
 
AutoFailoverPolicyData() - Constructor for class org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
 
AutoFailoverPolicyFactory - Class in org.apache.pulsar.common.policies.impl
 
AutoFailoverPolicyFactory() - Constructor for class org.apache.pulsar.common.policies.impl.AutoFailoverPolicyFactory
 
AutoFailoverPolicyType - Enum in org.apache.pulsar.common.policies.data
 
availablePermits - Variable in class org.apache.pulsar.common.policies.data.ConsumerStats
Number of available message permits for the consumer
averageLatency - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
averageMsgSize - Variable in class org.apache.pulsar.common.policies.data.PublisherStats
Average message size published by this publisher
averageMsgSize - Variable in class org.apache.pulsar.common.policies.data.TopicStats
Average size of published messages.
avgProcessLatency - Variable in class org.apache.pulsar.common.policies.data.FunctionStats
Average process latency for function
avgProcessLatency - Variable in class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats.FunctionInstanceStatsDataBase
Average process latency for function for instance

B

backlog_quota_map - Variable in class org.apache.pulsar.common.policies.data.Policies
 
BacklogQuota - Class in org.apache.pulsar.common.policies.data
Unit of a backlog quota configuration for a scoped resource in a Pulsar instance.
BacklogQuota() - Constructor for class org.apache.pulsar.common.policies.data.BacklogQuota
 
BacklogQuota(long, BacklogQuota.RetentionPolicy) - Constructor for class org.apache.pulsar.common.policies.data.BacklogQuota
 
BacklogQuota.BacklogQuotaType - Enum in org.apache.pulsar.common.policies.data
Identifier to a backlog quota configuration (an instance of BacklogQuota).
BacklogQuota.RetentionPolicy - Enum in org.apache.pulsar.common.policies.data
Enumeration type determines how to retain backlog against the resource shortages.
blockedConsumerOnUnackedMsgs - Variable in class org.apache.pulsar.common.policies.data.ConsumerStats
Flag to verify if consumer is blocked due to reaching threshold of unacked messages
blockedSubscriptionOnUnackedMsgs - Variable in class org.apache.pulsar.common.policies.data.SubscriptionStats
Flag to verify if subscription is blocked due to reaching threshold of unacked messages
BookieInfo - Class in org.apache.pulsar.common.policies.data
 
BookieInfo() - Constructor for class org.apache.pulsar.common.policies.data.BookieInfo
 
Bookies - Interface in org.apache.pulsar.client.admin
Admin interface for bookies rack placement management.
bookies() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
BookiesRackConfiguration - Class in org.apache.pulsar.common.policies.data
 
BookiesRackConfiguration() - Constructor for class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
 
boundaries - Variable in class org.apache.pulsar.common.policies.data.BundlesData
 
broker_assignment - Variable in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
 
BrokerAssignment - Enum in org.apache.pulsar.common.policies.data
 
brokerName - Variable in class org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
 
brokerName - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
Broker host where this stat was generated
BrokerNamespaceIsolationData - Class in org.apache.pulsar.common.policies.data
 
BrokerNamespaceIsolationData() - Constructor for class org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
 
Brokers - Interface in org.apache.pulsar.client.admin
Admin interface for brokers management.
brokers() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
brokers - Variable in class org.apache.pulsar.common.policies.data.FailureDomain
 
BrokerStats - Interface in org.apache.pulsar.client.admin
Admin interface for brokers management.
brokerStats() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
BrokerStatus - Class in org.apache.pulsar.common.policies.data
 
BrokerStatus(String, boolean, int) - Constructor for class org.apache.pulsar.common.policies.data.BrokerStatus
 
build() - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
 
builder() - Static method in class org.apache.pulsar.client.admin.PulsarAdmin
Creates a builder to construct an instance of PulsarAdmin.
bundles - Variable in class org.apache.pulsar.common.policies.data.LocalPolicies
 
bundles - Variable in class org.apache.pulsar.common.policies.data.Policies
 
BundlesData - Class in org.apache.pulsar.common.policies.data
 
BundlesData() - Constructor for class org.apache.pulsar.common.policies.data.BundlesData
 
BundlesData(List<String>) - Constructor for class org.apache.pulsar.common.policies.data.BundlesData
 
BundlesData(int) - Constructor for class org.apache.pulsar.common.policies.data.BundlesData
 

C

calculateOverall() - Method in class org.apache.pulsar.common.policies.data.FunctionStats
 
clearNamespaceBacklog(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for all topics on a namespace
clearNamespaceBacklogForSubscription(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for a given subscription on all topics on a namespace
clearNamespaceBundleBacklog(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear backlog for all topics on a namespace bundle
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
clearOffloadDeleteLag(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Clear the offload deletion lag for a namespace.
clone() - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Create a copy of the current client builder.
close() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Close the Pulsar admin client to release all the resources
ClusterData - Class in org.apache.pulsar.common.policies.data
 
ClusterData() - Constructor for class org.apache.pulsar.common.policies.data.ClusterData
 
ClusterData(String) - Constructor for class org.apache.pulsar.common.policies.data.ClusterData
 
ClusterData(String, String) - Constructor for class org.apache.pulsar.common.policies.data.ClusterData
 
ClusterData(String, String, String, String) - Constructor for class org.apache.pulsar.common.policies.data.ClusterData
 
clusterDispatchRate - Variable in class org.apache.pulsar.common.policies.data.Policies
 
Clusters - Interface in org.apache.pulsar.client.admin
Admin interface for clusters management.
clusters() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
clusterSubscribeRate - Variable in class org.apache.pulsar.common.policies.data.Policies
 
compaction_threshold - Variable in class org.apache.pulsar.common.policies.data.Policies
 
compactionStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics
Check the status of an ongoing compaction for a topic.
compareTo(BrokerStatus) - Method in class org.apache.pulsar.common.policies.data.BrokerStatus
 
ConflictException(ClientErrorException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConflictException
 
connected - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
is the replication-subscriber up and running to replicate to remote cluster
ConnectException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConnectException
 
ConnectException(String, Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConnectException
 
consumerName - Variable in class org.apache.pulsar.common.policies.data.ConsumerStats
Name of the consumer
consumers - Variable in class org.apache.pulsar.common.policies.data.SubscriptionStats
List of connected consumers on this subscription w/ their stats
ConsumerStats - Class in org.apache.pulsar.common.policies.data
 
ConsumerStats() - Constructor for class org.apache.pulsar.common.policies.data.ConsumerStats
 
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.
createFailureDomain(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters
Create a domain into cluster
createFunction(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Create a new function.
createFunctionWithUrl(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Create a new function by providing url from which fun-pkg can be downloaded.
createNamespace(String, int) - 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) - 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, Policies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Create a new namespace.
createNamespaceIsolationPolicy(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters
Create a namespace isolation policy for a cluster
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.
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.
createProperty(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Properties
Deprecated.
Create a new property.
createSchema(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas
Create a schema for a given topic.
createSink(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sink
Create a new sink.
createSinkWithUrl(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sink
Create a new sink by providing url from which fun-pkg can be downloaded.
createSource(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Source
Create a new source.
createSourceWithUrl(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Source
Create a new source by providing url from which fun-pkg can be downloaded.
createSubscription(String, String, MessageId) - 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
createTenant(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants
Create a new tenant.
currentLedgerEntries - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
currentLedgerSize - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
cursorBacklog - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats.CursorDetails
 
cursorDetails - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
cursor ledger ids and backlog
CursorDetails(long, long) - Constructor for class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats.CursorDetails
 
cursorLedger - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
cursorLedgerId - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats.CursorDetails
 
cursorLedgerLastEntry - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
cursors - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
CursorStats() - Constructor for class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 

D

dataLedgerDetails - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
data ledger ids
decode(String) - Static method in class org.apache.pulsar.common.policies.data.FunctionStats
 
decode(String) - Static method in class org.apache.pulsar.common.policies.data.FunctionStatus
 
decode(String) - Static method in class org.apache.pulsar.common.policies.data.SinkStatus
 
decode(String) - Static method in class org.apache.pulsar.common.policies.data.SourceStatus
 
deduplicationEnabled - Variable in class org.apache.pulsar.common.policies.data.Policies
 
deduplicationStatus - Variable in class org.apache.pulsar.common.policies.data.TopicStats
 
defaultBundle() - Static method in class org.apache.pulsar.common.policies.data.Policies
 
delete(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a topic.
delete(String) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a topic.
deleteAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a topic asynchronously.
deleteBookieRackInfo(String) - Method in interface org.apache.pulsar.client.admin.Bookies
Remove rack placement information for a specific bookie in the cluster
deleteCluster(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Delete an existing cluster
deleted - Variable in class org.apache.pulsar.common.policies.data.Policies
 
deleteFailureDomain(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Delete a domain in cluster
deleteFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Delete an existing function
deleteNamespace(String) - 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.
deleteNamespaceBundle(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Delete an existing bundle in a namespace.
deleteNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Delete a namespace isolation policy for a cluster
deletePartitionedTopic(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a partitioned topic.
deletePartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a partitioned topic.
deletePartitionedTopicAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
Delete a partitioned topic asynchronously.
deletePolicy(String) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies
Delete a policy
deleteProperty(String) - Method in interface org.apache.pulsar.client.admin.Properties
Deprecated.
Delete an existing property.
deleteSchema(String) - Method in interface org.apache.pulsar.client.admin.Schemas
Delete the schema associated with a given topic.
deleteSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sink
Delete an existing sink
deleteSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Source
Delete an existing source
deleteSubscription(String, String) - 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.
deleteTenant(String) - Method in interface org.apache.pulsar.client.admin.Tenants
Delete an existing tenant.
destination_auth - Variable in class org.apache.pulsar.common.policies.data.AuthPolicies
 
DispatchRate - Class in org.apache.pulsar.common.policies.data
 
DispatchRate() - Constructor for class org.apache.pulsar.common.policies.data.DispatchRate
 
DispatchRate(int, long, int) - Constructor for class org.apache.pulsar.common.policies.data.DispatchRate
 
dispatchThrottlingRateInByte - Variable in class org.apache.pulsar.common.policies.data.DispatchRate
 
dispatchThrottlingRateInMsg - Variable in class org.apache.pulsar.common.policies.data.DispatchRate
 
downloadFunction(String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Download Function Code.

E

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.PersistentOfflineTopicStats.LedgerDetails
 
entries - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.LedgerInfo
 
entriesAddedCounter - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.AuthPolicies
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.BacklogQuota
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.BundlesData
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.DispatchRate
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.FailureDomain
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.LocalPolicies
 
equals(Object) - Method in class org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
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.ResourceQuota
 
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.policies.impl.MinAvailablePolicy
 
equals(Object) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
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
 
ErrorData - Class in org.apache.pulsar.common.policies.data
 
ErrorData() - Constructor for class org.apache.pulsar.common.policies.data.ErrorData
 
ErrorData(String) - Constructor for class org.apache.pulsar.common.policies.data.ErrorData
 
ExceptionInformation - Class in org.apache.pulsar.common.policies.data
 
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
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
expireMessagesForAllSubscriptions(String, long) - Method in interface org.apache.pulsar.client.admin.Topics
Expire all messages older than given N (expireTimeInSeconds) 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 (expireTimeInSeconds) seconds for all subscriptions of the persistent-topic asynchronously

F

FailureDomain - Class in org.apache.pulsar.common.policies.data
 
FailureDomain() - Constructor for class org.apache.pulsar.common.policies.data.FailureDomain
 
findPrimaryBrokers(List<URL>, NamespaceName) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
findPrimaryBrokers(List<URL>, NamespaceName) - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
Get the list of primary brokers for the namespace according to the policy
findSecondaryBrokers(List<URL>, NamespaceName) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
findSecondaryBrokers(List<URL>, NamespaceName) - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
Get the list of secondary brokers for the namespace according to the policy
FIRST_BOUNDARY - Static variable in class org.apache.pulsar.common.policies.data.Policies
 
firstUnoffloadedMessage - Variable in class org.apache.pulsar.client.admin.OffloadProcessStatus
 
forError(String) - Static method in class org.apache.pulsar.client.admin.LongRunningProcessStatus
 
forError(String) - Static method in class 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 class org.apache.pulsar.client.admin.OffloadProcessStatus
 
forSuccess(MessageIdImpl) - Static method in class org.apache.pulsar.client.admin.OffloadProcessStatus
 
fromString(String) - Static method in enum org.apache.pulsar.common.policies.data.AutoFailoverPolicyType
 
FunctionInstanceStats() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats
 
FunctionInstanceStatsData() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats.FunctionInstanceStatsData
 
FunctionInstanceStatsDataBase() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats.FunctionInstanceStatsDataBase
 
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 - Interface in org.apache.pulsar.client.admin
Admin interface for function management.
functions() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
FunctionStats - Class in org.apache.pulsar.common.policies.data
 
FunctionStats() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStats
 
FunctionStats.FunctionInstanceStats - Class in org.apache.pulsar.common.policies.data
 
FunctionStats.FunctionInstanceStats.FunctionInstanceStatsData - Class in org.apache.pulsar.common.policies.data
 
FunctionStats.FunctionInstanceStats.FunctionInstanceStatsDataBase - Class in org.apache.pulsar.common.policies.data
 
FunctionStatus - Class in org.apache.pulsar.common.policies.data
 
FunctionStatus() - Constructor for class org.apache.pulsar.common.policies.data.FunctionStatus
 
FunctionStatus.FunctionInstanceStatus - Class in org.apache.pulsar.common.policies.data
 
FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData - Class in org.apache.pulsar.common.policies.data
 

G

getActiveBrokers(String) - Method in interface org.apache.pulsar.client.admin.Brokers
Get the list of active brokers in the cluster.
getAddress() - Method in class org.apache.pulsar.common.policies.data.ConsumerStats
 
getAddress() - Method in class org.apache.pulsar.common.policies.data.PublisherStats
 
getAdminRoles() - Method in class org.apache.pulsar.common.policies.data.TenantInfo
 
getAllDynamicConfigurations() - Method in interface org.apache.pulsar.client.admin.Brokers
Get values of all overridden dynamic-configs
getAllocatorStats(String) - Method in interface org.apache.pulsar.client.admin.BrokerStats
 
getAllowedClusters() - Method in class org.apache.pulsar.common.policies.data.TenantInfo
 
getAntiAffinityNamespaces(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get all namespaces that grouped with given anti-affinity group
getAssignments() - Method in interface org.apache.pulsar.client.admin.Worker
Get the function assignment among the cluster
getAvailablePrimaryBrokers(SortedSet<BrokerStatus>) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
getAvailablePrimaryBrokers(SortedSet<BrokerStatus>) - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
According to the namespace isolation policy, find the allowed available primary brokers
getBacklogQuotaMap(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get backlog quota map on a namespace.
getBandwidthIn() - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Get inbound bandwidth quota
getBandwidthOut() - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Get outbound bandwidth quota
getBookie(String) - Method in class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
 
getBookieRackInfo(String) - Method in interface org.apache.pulsar.client.admin.Bookies
Gets the rack placement information for a specific bookie in the cluster
getBookiesRackInfo() - Method in interface org.apache.pulsar.client.admin.Bookies
Gets the rack placement information for all the bookies in the cluster
getBookkeeperAckQuorum() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
getBookkeeperEnsemble() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
getBookkeeperWriteQuorum() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
getBoundaries() - Method in class org.apache.pulsar.common.policies.data.BundlesData
 
getBrokerAddress() - Method in class org.apache.pulsar.common.policies.data.BrokerStatus
 
getBrokers() - Method in class org.apache.pulsar.common.policies.data.FailureDomain
 
getBrokerServiceUrl() - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
getBrokerServiceUrlTls() - Method in class 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.
getBrokerWithNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Returns active broker with namespace-isolation policies attached to it.
getBuiltInSinks() - Method in interface org.apache.pulsar.client.admin.Sink
Fetches a list of supported Pulsar IO sinks currently running in cluster mode
getBuiltInSources() - Method in interface org.apache.pulsar.client.admin.Source
Fetches a list of supported Pulsar IO sources currently running in cluster mode
getBundleRange(String) - Method in interface org.apache.pulsar.client.admin.Lookup
Get a bundle range of a topic
getClientConfigData() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
getClientVersion() - Method in class org.apache.pulsar.common.policies.data.ConsumerStats
 
getClientVersion() - Method in class org.apache.pulsar.common.policies.data.PublisherStats
 
getCluster(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get the configuration data for the specified cluster.
getCluster() - Method in interface org.apache.pulsar.client.admin.Worker
Get List of all workers belonging to this cluster
getClusterLeader() - Method in interface org.apache.pulsar.client.admin.Worker
Get the worker who is the leader of the cluster
getClusters() - Method in interface org.apache.pulsar.client.admin.Clusters
Get the list of clusters.
getCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the compactionThreshold for a namespace.
getConnectedSince() - Method in class org.apache.pulsar.common.policies.data.ConsumerStats
 
getConnectedSince() - Method in class org.apache.pulsar.common.policies.data.PublisherStats
 
getConnectorsList() - Method in interface org.apache.pulsar.client.admin.Functions
Fetches a list of supported Pulsar IO connectors currently running in cluster mode
getDefaultResourceQuota() - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Get default resource quota for new resource bundles.
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)
getDynamic() - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Get dynamic setting
getDynamicConfigurationNames() - Method in interface org.apache.pulsar.client.admin.Brokers
Get list of updatable configuration name
getFailureDomain(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get the domain registered into a cluster
getFailureDomains(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get all registered domains in cluster
getFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Get the configuration for the specified function.
getFunctions(String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Get the list of functions.
getFunctionsStats() - Method in interface org.apache.pulsar.client.admin.Worker
Get all functions stats on a worker
getFunctionState(String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Fetch the current state associated with a Pulsar Function.
getFunctionStats(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Gets the current stats of a function instance.
getFunctionStats(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Gets the current stats of a function.
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.
getHttpError() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException
 
getInternalConfigurationData() - Method in interface org.apache.pulsar.client.admin.Brokers
Get the internal configuration data.
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.
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.
getLastMessageId(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the last commit message Id of a topic
getLimit() - Method in class org.apache.pulsar.common.policies.data.BacklogQuota
Gets quota limit in bytes
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 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.
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 class org.apache.pulsar.common.policies.data.BrokerStatus
 
getLoadReport() - Method in interface org.apache.pulsar.client.admin.BrokerStats
 
getManagedLedgerMaxMarkDeleteRate() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
getMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxConsumersPerSubscription for a namespace.
getMaxConsumersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxProducersPerTopic for a namespace.
getMaxProducersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the maxProducersPerTopic for a namespace.
getMBeans() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Requests JSON string server mbean dump
getMemory() - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Get memory quota
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.
getMsgRateIn() - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Get incoming message rate quota
getMsgRateOut() - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Get outgoing message rate quota
getNamespaceAntiAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get anti-affinity group name for a namespace
getNamespaceBundleResourceQuota(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Get resource quota of a namespace bundle.
getNamespaceIsolationPolicies(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get the namespace isolation policies of a cluster
getNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get a single namespace isolation policy for a cluster
getNamespaceMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the message TTL for a namespace.
getNamespaceReplicationClusters(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the replication clusters for a namespace.
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.
getNumBundles() - Method in class org.apache.pulsar.common.policies.data.BundlesData
 
getOffloadDeleteLagMs(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the offload deletion lag for a namespace, in milliseconds.
getOffloadThreshold(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the offloadThreshold for a namespace.
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
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
Get the stats for the partitioned topic
getPartitionedStatsAsync(String, 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.
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.
getPeerClusterNames(String) - Method in interface org.apache.pulsar.client.admin.Clusters
Get peer-cluster names
getPeerClusterNames() - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
getPendingBookieOpsStats() - Method in interface org.apache.pulsar.client.admin.BrokerStats
 
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.
getPersistence(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the persistence configuration for a namespace.
getPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get policies for a namespace.
getPolicies() - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies
Get the full policy map
getPolicy() - Method in class org.apache.pulsar.common.policies.data.BacklogQuota
 
getPolicyByName(String) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies
Access method to get the namespace isolation policy by the policy name
getPolicyByNamespace(NamespaceName) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies
Get the namespace isolation policy for the specified namespace
getPrimaryBrokers() - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
getPrimaryBrokers() - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
Get the list of regex for the set of primary brokers
getProducerName() - Method in class org.apache.pulsar.common.policies.data.PublisherStats
 
getProperties() - Method in interface org.apache.pulsar.client.admin.Properties
Deprecated.
Get the list of properties.
getPropertyAdmin(String) - Method in interface org.apache.pulsar.client.admin.Properties
Deprecated.
Get the config of the property.
getPublishers() - Method in class org.apache.pulsar.common.policies.data.NonPersistentTopicStats
 
getReplication() - Method in class org.apache.pulsar.common.policies.data.NonPersistentTopicStats
 
getReplicationConfigVersion(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the replication configuration version for a given namespace
getRetention(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the retention configuration for a namespace.
getRetentionSizeInMB() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
 
getRetentionTimeInMinutes() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
 
getSchemaAutoUpdateCompatibilityStrategy(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.
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.
getSecondaryBrokers() - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
getSecondaryBrokers() - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
Get the list of regex for the set of secondary brokers
getServiceUrl() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
getServiceUrl() - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
getServiceUrlTls() - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
getSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sink
Get the configuration for the specified sink.
getSinks() - Method in interface org.apache.pulsar.client.admin.Functions
Fetches a list of supported Pulsar IO sinks currently running in cluster mode
getSinkStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sink
Gets the current status of a sink.
getSinkStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sink
Gets the current status of a sink instance.
getSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Source
Get the configuration for the specified source.
getSources() - Method in interface org.apache.pulsar.client.admin.Functions
Fetches a list of supported Pulsar IO sources currently running in cluster mode
getSourceStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Source
Gets the current status of a source.
getSourceStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Source
Gets the current status of a source instance.
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
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
Get the stats for the topic asynchronously.
getStatusCode() - Method in exception org.apache.pulsar.client.admin.PulsarAdminException
 
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)
getSubscriptionDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get subscription-message-dispatch-rate (subscriptions under this namespace can dispatch this many messages per second)
getSubscriptions(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of subscriptions.
getSubscriptions() - Method in class org.apache.pulsar.common.policies.data.NonPersistentTopicStats
 
getSubscriptionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Get the list of subscriptions asynchronously.
getTenantInfo(String) - Method in interface org.apache.pulsar.client.admin.Tenants
Get the config of the tenant.
getTenants() - Method in interface org.apache.pulsar.client.admin.Tenants
Get the list of tenants.
GettingAuthenticationDataException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.GettingAuthenticationDataException
 
GettingAuthenticationDataException(String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.GettingAuthenticationDataException
 
getTopics() - Method in interface org.apache.pulsar.client.admin.BrokerStats
Returns JSON string topics stats
getTopics(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Get the list of topics.
grantPermission(String, String, Set<AuthAction>) - Method in interface org.apache.pulsar.client.admin.Topics
Grant permission on a topic.
grantPermissionOnNamespace(String, String, Set<AuthAction>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Grant permission on a namespace.
grantPermissionOnSubscription(String, String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Grant permission to role to access subscription's admin-api.

H

hashCode() - Method in class org.apache.pulsar.common.policies.data.BacklogQuota
 
hashCode() - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
hashCode() - Method in class org.apache.pulsar.common.policies.data.DispatchRate
 
hashCode() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
 
hashCode() - Method in class org.apache.pulsar.common.policies.data.SubscribeRate
 
healthcheck() - Method in interface org.apache.pulsar.client.admin.Brokers
Run a healthcheck on the broker.
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

inboundConnectedSince - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
Timestamp of incoming connection establishment time
inboundConnection - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
Address of incoming replication connection
individuallyDeletedMessages - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
instanceId - Variable in class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats
Instance Id of function instance
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.FunctionStats
 
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
 
is_active - Variable in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
 
is_controlled - Variable in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
 
isActive() - Method in class org.apache.pulsar.common.policies.data.BrokerStatus
 
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
 
isPrimaryBroker(String) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
isPrimaryBroker(String) - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
Check to see whether the specific host is a primary broker
isPrimaryBrokerAvailable(BrokerStatus) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
isPrimaryBrokerAvailable(BrokerStatus) - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
 
isSecondaryBroker(String) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
isSecondaryBroker(String) - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
Check to see whether the specific host is a secondary broker
isSharedBroker(String) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies
Check to see whether a broker is in the shared broker pool or not
isValid() - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Check if this is a valid quota definition

L

LAST_BOUNDARY - Static variable in class org.apache.pulsar.common.policies.data.Policies
 
lastConfirmedEntry - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
lastError - Variable in class org.apache.pulsar.client.admin.LongRunningProcessStatus
 
lastInvocation - Variable in class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats.FunctionInstanceStatsData
Timestamp of when the function was last invoked for instance
lastInvocation - Variable in class org.apache.pulsar.common.policies.data.FunctionStats
Timestamp of when the function was last invoked by any instance
lastInvocationTime - Variable in class org.apache.pulsar.common.policies.data.FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData
 
lastLedgerCreatedTimestamp - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
lastLedgerCreationFailureTimestamp - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
lastLedgerSwitchTimestamp - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.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
 
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
 
LedgerDetails(long, long, long, long) - Constructor for class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats.LedgerDetails
 
ledgerId - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats.LedgerDetails
 
ledgerId - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.LedgerInfo
 
LedgerInfo() - Constructor for class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.LedgerInfo
 
ledgers - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
listSinks(String, String) - Method in interface org.apache.pulsar.client.admin.Sink
Get the list of sinks.
listSources(String, String) - Method in interface org.apache.pulsar.client.admin.Source
Get the list of sources.
LocalPolicies - Class in org.apache.pulsar.common.policies.data
 
LocalPolicies() - Constructor for class org.apache.pulsar.common.policies.data.LocalPolicies
 
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 in org.apache.pulsar.client.admin
 
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.
lookups() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
lookupTopic(String) - Method in interface org.apache.pulsar.client.admin.Lookup
Lookup a topic

M

markDeletePosition - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.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
 
message_ttl_in_seconds - Variable in class org.apache.pulsar.common.policies.data.Policies
 
messageBacklog - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
Total backlog
messagesConsumedCounter - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
metadata - Variable in class org.apache.pulsar.common.policies.data.ConsumerStats
Metadata (key/value strings) associated with this consumer
metadata - Variable in class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
 
metadata - Variable in class org.apache.pulsar.common.policies.data.PartitionedTopicStats
 
metadata - Variable in class org.apache.pulsar.common.policies.data.PublisherStats
Metadata (key/value strings) associated with this publisher
metrics - Variable in class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats
 
metrics - Variable in class org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats
 
min_limit - Variable in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
MinAvailablePolicy - Class in org.apache.pulsar.common.policies.impl
 
MinAvailablePolicy(AutoFailoverPolicyData) - Constructor for class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
msgBacklog - Variable in class org.apache.pulsar.common.policies.data.SubscriptionStats
Number of messages in the subscription backlog
msgDropRate - Variable in class 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
msgDropRate - Variable in class org.apache.pulsar.common.policies.data.NonPersistentReplicatorStats
for non-persistent topic: broker drops msg for replicator if replicator connection is not writable
msgDropRate - Variable in class 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
msgDropRate - Variable in class 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
msgRateExpired - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
Total rate of messages expired.
msgRateExpired - Variable in class org.apache.pulsar.common.policies.data.SubscriptionStats
Total rate of messages expired on this subscription.
msgRateIn - Variable in class org.apache.pulsar.common.policies.data.PublisherStats
Total rate of messages published by this publisher.
msgRateIn - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
Total rate of messages received from the remote cluster.
msgRateIn - Variable in class org.apache.pulsar.common.policies.data.TopicStats
Total rate of messages published on the topic.
msgRateOut - Variable in class org.apache.pulsar.common.policies.data.ConsumerStats
Total rate of messages delivered to the consumer.
msgRateOut - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
Total rate of messages delivered to the replication-subscriber.
msgRateOut - Variable in class org.apache.pulsar.common.policies.data.SubscriptionStats
Total rate of messages delivered on this subscription.
msgRateOut - Variable in class org.apache.pulsar.common.policies.data.TopicStats
Total rate of messages dispatched for the topic.
msgRateRedeliver - Variable in class org.apache.pulsar.common.policies.data.ConsumerStats
Total rate of messages redelivered by this consumer.
msgRateRedeliver - Variable in class org.apache.pulsar.common.policies.data.SubscriptionStats
Total rate of messages redelivered on this subscription.
msgThroughputIn - Variable in class org.apache.pulsar.common.policies.data.PublisherStats
Total throughput of messages published by this publisher.
msgThroughputIn - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
Total throughput received from the remote cluster.
msgThroughputIn - Variable in class org.apache.pulsar.common.policies.data.TopicStats
Total throughput of messages published on the topic.
msgThroughputOut - Variable in class org.apache.pulsar.common.policies.data.ConsumerStats
Total throughput delivered to the consumer.
msgThroughputOut - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
Total throughput delivered to the replication-subscriber.
msgThroughputOut - Variable in class org.apache.pulsar.common.policies.data.SubscriptionStats
Total throughput delivered on this subscription.
msgThroughputOut - Variable in class org.apache.pulsar.common.policies.data.TopicStats
Total throughput of messages dispatched for the topic.

N

name - Variable in class org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats
fully qualified function instance name
namespace_auth - Variable in class org.apache.pulsar.common.policies.data.AuthPolicies
 
NamespaceIsolationData - Class in org.apache.pulsar.common.policies.data
 
NamespaceIsolationData() - Constructor for class org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
NamespaceIsolationPolicies - Class in org.apache.pulsar.common.policies.impl
 
NamespaceIsolationPolicies() - Constructor for class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies
 
NamespaceIsolationPolicies(Map<String, NamespaceIsolationData>) - Constructor for class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies
 
NamespaceIsolationPolicy - Interface in org.apache.pulsar.common.policies
 
NamespaceIsolationPolicyImpl - Class in org.apache.pulsar.common.policies.impl
 
NamespaceIsolationPolicyImpl(NamespaceIsolationData) - Constructor for class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
NamespaceOwnershipStatus - Class in org.apache.pulsar.common.policies.data
 
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 - Variable in class org.apache.pulsar.common.policies.data.BrokerNamespaceIsolationData
 
Namespaces - Interface in org.apache.pulsar.client.admin
Admin interface for namespaces management
namespaces() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
namespaces - Variable in class org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
NonPersistentPublisherStats - Class in org.apache.pulsar.common.policies.data
 
NonPersistentPublisherStats() - Constructor for class org.apache.pulsar.common.policies.data.NonPersistentPublisherStats
 
NonPersistentReplicatorStats - Class in org.apache.pulsar.common.policies.data
 
NonPersistentReplicatorStats() - Constructor for class org.apache.pulsar.common.policies.data.NonPersistentReplicatorStats
 
NonPersistentSubscriptionStats - Class in org.apache.pulsar.common.policies.data
 
NonPersistentSubscriptionStats() - Constructor for class org.apache.pulsar.common.policies.data.NonPersistentSubscriptionStats
 
NonPersistentTopics - Interface in org.apache.pulsar.client.admin
Deprecated.
since 2.0. See Topics
nonPersistentTopics() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
Since 2.0. See PulsarAdmin.topics()
NonPersistentTopicStats - Class in org.apache.pulsar.common.policies.data
 
NonPersistentTopicStats() - Constructor for class org.apache.pulsar.common.policies.data.NonPersistentTopicStats
 
NotAllowedException(ClientErrorException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.NotAllowedException
 
NotAuthorizedException(ClientErrorException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.NotAuthorizedException
 
NotFoundException(ClientErrorException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.NotFoundException
 
numberOfEntries - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
numberOfEntriesSinceFirstNotAckedMessage - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
numBundles - Variable in class org.apache.pulsar.common.policies.data.BundlesData
 
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
 
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
 
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
 
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

offload_deletion_lag_ms - 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.PersistentTopicInternalStats.LedgerInfo
 
OffloadProcessStatus - Class in org.apache.pulsar.client.admin
Status of offload process.
OffloadProcessStatus() - Constructor for class org.apache.pulsar.client.admin.OffloadProcessStatus
 
offloadStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics
Check the status of an ongoing offloading operation for a topic.
oneMin - Variable in class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats.FunctionInstanceStatsData
 
oneMin - Variable in class org.apache.pulsar.common.policies.data.FunctionStats
 
org.apache.pulsar.client.admin - package org.apache.pulsar.client.admin
 
org.apache.pulsar.common.policies - package org.apache.pulsar.common.policies
 
org.apache.pulsar.common.policies.data - package org.apache.pulsar.common.policies.data
 
org.apache.pulsar.common.policies.impl - package org.apache.pulsar.common.policies.impl
 
outboundConnectedSince - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
Timestamp of outbound connection establishment time
outboundConnection - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
Address of outbound replication connection

P

parameters - Variable in class org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
 
PartitionedTopicInternalStats - Class in org.apache.pulsar.common.policies.data
 
PartitionedTopicInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
 
PartitionedTopicInternalStats(PartitionedTopicMetadata) - Constructor for class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
 
PartitionedTopicStats - Class in org.apache.pulsar.common.policies.data
 
PartitionedTopicStats() - Constructor for class org.apache.pulsar.common.policies.data.PartitionedTopicStats
 
PartitionedTopicStats(PartitionedTopicMetadata) - Constructor for class org.apache.pulsar.common.policies.data.PartitionedTopicStats
 
partitions - Variable in class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
 
partitions - Variable in class org.apache.pulsar.common.policies.data.PartitionedTopicStats
 
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
pendingAddEntriesCount - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
pendingReadOps - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
persistence - Variable in class org.apache.pulsar.common.policies.data.Policies
 
PersistencePolicies - Class in org.apache.pulsar.common.policies.data
 
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
 
PersistentOfflineTopicStats - Class in org.apache.pulsar.common.policies.data
This object is populated using meta data in zookeeper without actually bringing the topic online
PersistentOfflineTopicStats(String, String) - Constructor for class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
 
PersistentOfflineTopicStats.CursorDetails - Class in org.apache.pulsar.common.policies.data
 
PersistentOfflineTopicStats.LedgerDetails - Class in org.apache.pulsar.common.policies.data
 
PersistentTopicInternalStats - Class in org.apache.pulsar.common.policies.data
 
PersistentTopicInternalStats() - Constructor for class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
PersistentTopicInternalStats.CursorStats - Class in org.apache.pulsar.common.policies.data
 
PersistentTopicInternalStats.LedgerInfo - Class in org.apache.pulsar.common.policies.data
 
PersistentTopics - Interface in org.apache.pulsar.client.admin
Deprecated.
persistentTopics() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
Since 2.0. See PulsarAdmin.topics()
PersistentTopicStats - Class in org.apache.pulsar.common.policies.data
Maintain compatibility with previous class name
PersistentTopicStats() - Constructor for class org.apache.pulsar.common.policies.data.PersistentTopicStats
 
Policies - Class in org.apache.pulsar.common.policies.data
 
Policies() - Constructor for class org.apache.pulsar.common.policies.data.Policies
 
policy_type - Variable in class org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
 
PreconditionFailedException(ClientErrorException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.PreconditionFailedException
 
primary - Variable in class org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
processedSuccessfullyTotal - Variable in class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats.FunctionInstanceStatsDataBase
Total number of records successfully processed by user function for instance
processedSuccessfullyTotal - Variable in class org.apache.pulsar.common.policies.data.FunctionStats
Overall total number of records successfully processed by user function
producerId - Variable in class org.apache.pulsar.common.policies.data.PublisherStats
Id of this publisher
Properties - Interface in org.apache.pulsar.client.admin
Deprecated.
properties() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
since 2.0. See PulsarAdmin.tenants()
properties - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
publishers - Variable in class org.apache.pulsar.common.policies.data.NonPersistentTopicStats
List of connected publishers on this topic w/ their stats
publishers - Variable in class org.apache.pulsar.common.policies.data.TopicStats
List of connected publishers on this topic w/ their stats
PublisherStats - Class in org.apache.pulsar.common.policies.data
 
PublisherStats() - Constructor for class org.apache.pulsar.common.policies.data.PublisherStats
 
PulsarAdmin - Class in org.apache.pulsar.client.admin
Pulsar client admin API client.
PulsarAdmin(String, ClientConfigurationData) - Constructor for class org.apache.pulsar.client.admin.PulsarAdmin
 
PulsarAdmin(URL, ClientConfiguration) - Constructor for class org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
Since 2.0. Use PulsarAdmin.builder() to construct a new PulsarAdmin instance.
PulsarAdmin(URL, Authentication) - Constructor for class org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
Since 2.0. Use PulsarAdmin.builder() to construct a new PulsarAdmin instance.
PulsarAdmin(URL, String, String) - Constructor for class org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
Since 2.0. Use PulsarAdmin.builder() to construct a new PulsarAdmin instance.
PulsarAdmin(URL, String, Map<String, String>) - Constructor for class org.apache.pulsar.client.admin.PulsarAdmin
Deprecated.
Since 2.0. Use PulsarAdmin.builder() to construct a new PulsarAdmin instance.
PulsarAdminBuilder - Interface in org.apache.pulsar.client.admin
Builder class for a PulsarAdmin instance.
PulsarAdminException - Exception in org.apache.pulsar.client.admin
 
PulsarAdminException(ClientErrorException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException(ClientErrorException, String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException(ServerErrorException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException(ServerErrorException, String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException(WebApplicationException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException(String, Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
 
PulsarAdminException.ConflictException - Exception in org.apache.pulsar.client.admin
 
PulsarAdminException.ConnectException - Exception in org.apache.pulsar.client.admin
 
PulsarAdminException.GettingAuthenticationDataException - Exception in org.apache.pulsar.client.admin
 
PulsarAdminException.HttpErrorException - Exception in org.apache.pulsar.client.admin
 
PulsarAdminException.NotAllowedException - Exception in org.apache.pulsar.client.admin
 
PulsarAdminException.NotAuthorizedException - Exception in org.apache.pulsar.client.admin
 
PulsarAdminException.NotFoundException - Exception in org.apache.pulsar.client.admin
 
PulsarAdminException.PreconditionFailedException - Exception in org.apache.pulsar.client.admin
 
PulsarAdminException.ServerSideErrorException - Exception in org.apache.pulsar.client.admin
 

R

ratePeriodInSecond - Variable in class org.apache.pulsar.common.policies.data.DispatchRate
 
ratePeriodInSecond - Variable in class org.apache.pulsar.common.policies.data.SubscribeRate
 
readPosition - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
reason - Variable in class org.apache.pulsar.common.policies.data.ErrorData
 
receivedTotal - Variable in class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats.FunctionInstanceStatsDataBase
Total number of records function received from source for instance
receivedTotal - Variable in class org.apache.pulsar.common.policies.data.FunctionStats
Overall total number of records function received from source
removeBacklogQuota(String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Remove a backlog quota policy from a namespace.
removeBookie(String) - Method in class org.apache.pulsar.common.policies.data.BookiesRackConfiguration
 
replication - Variable in class org.apache.pulsar.common.policies.data.NonPersistentTopicStats
Map of replication statistics by remote cluster context
replication - Variable in class org.apache.pulsar.common.policies.data.TopicStats
Map of replication statistics by remote cluster context
replication_clusters - Variable in class org.apache.pulsar.common.policies.data.Policies
 
replicationBacklog - Variable in class org.apache.pulsar.common.policies.data.ReplicatorStats
Number of messages pending to be replicated to remote cluster
replicationDelayInSeconds - Variable in class 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
ReplicatorStats - Class in org.apache.pulsar.common.policies.data
 
ReplicatorStats() - Constructor for class org.apache.pulsar.common.policies.data.ReplicatorStats
 
reset() - Method in class org.apache.pulsar.common.policies.data.NonPersistentSubscriptionStats
 
reset() - Method in class org.apache.pulsar.common.policies.data.NonPersistentTopicStats
 
reset() - Method in class org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats
 
reset() - Method in class org.apache.pulsar.common.policies.data.PartitionedTopicStats
 
reset() - Method in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
 
reset() - Method in class org.apache.pulsar.common.policies.data.SubscriptionStats
 
reset() - Method in class org.apache.pulsar.common.policies.data.TopicStats
 
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
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
resetNamespaceBundleResourceQuota(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Reset resource quota for a namespace bundle to default value.
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 class org.apache.pulsar.client.admin.PulsarAdmin
 
ResourceQuotas - Interface in org.apache.pulsar.client.admin
 
restartFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Restart function instance
restartFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Restart all function instances
restartSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sink
Restart sink instance
restartSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sink
Restart all sink instances
restartSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Source
Restart source instance
restartSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Source
Restart all source instances
retention_policies - Variable in class org.apache.pulsar.common.policies.data.Policies
 
RetentionPolicies - Class in org.apache.pulsar.common.policies.data
 
RetentionPolicies() - Constructor for class org.apache.pulsar.common.policies.data.RetentionPolicies
 
RetentionPolicies(int, int) - Constructor for class org.apache.pulsar.common.policies.data.RetentionPolicies
 
revokePermissionOnSubscription(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Revoke permissions on a subscription's admin-api access.
revokePermissions(String, String) - Method in interface org.apache.pulsar.client.admin.Topics
Revoke permissions on a topic.
revokePermissionsOnNamespace(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Revoke permissions on a namespace.
root - Variable in class org.apache.pulsar.client.admin.PulsarAdmin
 
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
 

S

schema_auto_update_compatibility_strategy - Variable in class org.apache.pulsar.common.policies.data.Policies
 
SchemaAutoUpdateCompatibilityStrategy - Enum in org.apache.pulsar.common.policies.data
Strategy to use when checking an auto-updated schema for compatibility to the current schema.
schemas() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
Schemas - Interface in org.apache.pulsar.client.admin
Admin interface on interacting with schemas.
secondary - Variable in class org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
ServerSideErrorException(ServerErrorException, String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ServerSideErrorException
 
ServerSideErrorException(ServerErrorException) - 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.
setActive(boolean) - Method in class org.apache.pulsar.common.policies.data.BrokerStatus
 
setAddress(String) - Method in class org.apache.pulsar.common.policies.data.ConsumerStats
 
setAddress(String) - Method in class org.apache.pulsar.common.policies.data.PublisherStats
 
setAdminRoles(Set<String>) - Method in class org.apache.pulsar.common.policies.data.TenantInfo
 
setAllowedClusters(Set<String>) - Method in class org.apache.pulsar.common.policies.data.TenantInfo
 
setBacklogQuota(String, BacklogQuota) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set a backlog quota for all the topics on a namespace.
setBandwidthIn(double) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Set inbound bandwidth quota
setBandwidthOut(double) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Set outbound bandwidth quota
setBoundaries(List<String>) - Method in class org.apache.pulsar.common.policies.data.BundlesData
 
setBrokers(Set<String>) - Method in class org.apache.pulsar.common.policies.data.FailureDomain
 
setBrokerServiceUrl(String) - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
setBrokerServiceUrlTls(String) - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
setClientVersion(String) - Method in class org.apache.pulsar.common.policies.data.ConsumerStats
 
setClientVersion(String) - Method in class org.apache.pulsar.common.policies.data.PublisherStats
 
setCompactionThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the compactionThreshold for a namespace.
setConnectedSince(String) - Method in class org.apache.pulsar.common.policies.data.ConsumerStats
 
setConnectedSince(String) - Method in class org.apache.pulsar.common.policies.data.PublisherStats
 
setDeduplicationStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the deduplication status for all topics within a namespace.
setDefaultResourceQuota(ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Set default resource quota for new namespace bundles.
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)
setDynamic(boolean) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Set dynamic to true/false
setEncryptionRequiredStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the encryption required status for all topics within a namespace.
setLimit(long) - Method in class org.apache.pulsar.common.policies.data.BacklogQuota
Sets quota limit in bytes
setLoadFactor(int) - Method in class org.apache.pulsar.common.policies.data.BrokerStatus
 
setMaxConsumersPerSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxConsumersPerSubscription for a namespace.
setMaxConsumersPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxConsumersPerTopic for a namespace.
setMaxProducersPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set maxProducersPerTopic for a namespace.
setMemory(double) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Set memory quota
setMsgRateIn(double) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Set incoming message rate quota
setMsgRateOut(double) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Set outgoing message rate quota
setNamespaceAntiAffinityGroup(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set anti-affinity group name for a namespace
setNamespaceBundleResourceQuota(String, String, ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas
Set resource quota for a namespace bundle.
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.
setNamespaceReplicationClusters(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the replication clusters for a namespace.
setNumBundles(int) - Method in class org.apache.pulsar.common.policies.data.BundlesData
 
setOffloadDeleteLag(String, long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the offload deletion lag for a namespace.
setOffloadThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the offloadThreshold for a namespace.
setPeerClusterNames(LinkedHashSet<String>) - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
setPersistence(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the persistence configuration for all the topics on a namespace.
setPolicy(BacklogQuota.RetentionPolicy) - Method in class org.apache.pulsar.common.policies.data.BacklogQuota
 
setPolicy(String, NamespaceIsolationData) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies
Set the policy data for a single policy
setProducerName(String) - Method in class org.apache.pulsar.common.policies.data.PublisherStats
 
setRetention(String, RetentionPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the retention configuration for all the topics on a namespace.
setSchemaAutoUpdateCompatibilityStrategy(String, SchemaAutoUpdateCompatibilityStrategy) - 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.
setServiceUrl(String) - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
setServiceUrlTls(String) - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
setStorageQuota(Policies, BacklogQuota) - Static method in class org.apache.pulsar.common.policies.data.Policies
 
setSubscribeRate(String, SubscribeRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set namespace-subscribe-rate (topics under this namespace will limit by subscribeRate)
setSubscriptionAuthMode(String, SubscriptionAuthMode) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set the given subscription auth mode on all topics on a namespace
setSubscriptionDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces
Set subscription-message-dispatch-rate (subscriptions under this namespace can dispatch this many messages per second)
shouldFailover(SortedSet<BrokerStatus>) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
shouldFailover(int) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
shouldFailover(SortedSet<BrokerStatus>) - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
Check to see whether the primary brokers can still handle a new namespace or has to failover
shouldFailover(int) - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
Check to see whether the primary brokers can still handle a new namespace or has to failover
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(int) - Method in class org.apache.pulsar.common.policies.AutoFailoverPolicy
 
shouldFailoverToSecondary(SortedSet<BrokerStatus>) - Method in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
shouldFailoverToSecondary(int) - Method in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
shouldFallback(SortedSet<BrokerStatus>) - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
shouldFallback(SortedSet<BrokerStatus>) - Method in interface org.apache.pulsar.common.policies.NamespaceIsolationPolicy
Check to see whether the namespace ownership should fallback to the primary brokers
sink() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
Sink - Interface in org.apache.pulsar.client.admin
Admin interface for Sink management.
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
 
SinkStatus - Class in org.apache.pulsar.common.policies.data
 
SinkStatus() - Constructor for class org.apache.pulsar.common.policies.data.SinkStatus
 
SinkStatus.SinkInstanceStatus - Class in org.apache.pulsar.common.policies.data
 
SinkStatus.SinkInstanceStatus.SinkInstanceStatusData - Class in org.apache.pulsar.common.policies.data
 
size - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats.LedgerDetails
 
size - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.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.
source() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
Source - Interface in org.apache.pulsar.client.admin
Admin interface for Source management.
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
 
SourceStatus - Class in org.apache.pulsar.common.policies.data
 
SourceStatus() - Constructor for class org.apache.pulsar.common.policies.data.SourceStatus
 
SourceStatus.SourceInstanceStatus - Class in org.apache.pulsar.common.policies.data
 
SourceStatus.SourceInstanceStatus.SourceInstanceStatusData - Class in org.apache.pulsar.common.policies.data
 
splitNamespaceBundle(String, String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces
Split namespace bundle
state - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
state - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
statGeneratedAt - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
timestamp when stat was generated
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
 
stopFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions
Stop function instance
stopFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Stop all function instances
stopSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sink
Stop sink instance
stopSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sink
Stop all sink instances
stopSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Source
Stop source instance
stopSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Source
Stop all source instances
storageSize - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
Space used to store the messages for the topic.
storageSize - Variable in class org.apache.pulsar.common.policies.data.TopicStats
Space used to store the messages for the topic.
SubscribeRate - Class in org.apache.pulsar.common.policies.data
 
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_auth_roles - Variable in class org.apache.pulsar.common.policies.data.AuthPolicies
 
SubscriptionAuthMode - Enum in org.apache.pulsar.common.policies.data
Subscription authorization for Pulsar policies
subscriptionDispatchRate - Variable in class org.apache.pulsar.common.policies.data.Policies
 
subscriptions - Variable in class org.apache.pulsar.common.policies.data.NonPersistentTopicStats
Map of subscriptions with their individual statistics
subscriptions - Variable in class org.apache.pulsar.common.policies.data.TopicStats
Map of subscriptions with their individual statistics
SubscriptionStats - Class in org.apache.pulsar.common.policies.data
 
SubscriptionStats() - Constructor for class org.apache.pulsar.common.policies.data.SubscriptionStats
 
substract(ResourceQuota) - Method in class org.apache.pulsar.common.policies.data.ResourceQuota
Substract quota.
systemExceptionsTotal - Variable in class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats.FunctionInstanceStatsDataBase
Total number of system exceptions thrown for instance
systemExceptionsTotal - Variable in class org.apache.pulsar.common.policies.data.FunctionStats
Overall total number of system exceptions thrown

T

TenantInfo - Class in org.apache.pulsar.common.policies.data
 
TenantInfo() - Constructor for class org.apache.pulsar.common.policies.data.TenantInfo
 
TenantInfo(Set<String>, Set<String>) - Constructor for class org.apache.pulsar.common.policies.data.TenantInfo
 
tenants() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
Tenants - Interface in org.apache.pulsar.client.admin
Admin interface for tenants management
terminateTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
Terminate the topic and prevent any more messages being published on it.
timestamp - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats.LedgerDetails
 
tlsTrustCertsFilePath(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder
Set the path to the trusted TLS certificate file
topicName - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
offline topic name
topics() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
 
Topics - Interface in org.apache.pulsar.client.admin
 
TopicStats - Class in org.apache.pulsar.common.policies.data
 
TopicStats() - Constructor for class org.apache.pulsar.common.policies.data.TopicStats
 
toString() - Method in class org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
 
toString() - Method in class org.apache.pulsar.common.policies.data.BacklogQuota
 
toString() - Method in class org.apache.pulsar.common.policies.data.BrokerStatus
 
toString() - Method in class org.apache.pulsar.common.policies.data.BundlesData
 
toString() - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
toString() - Method in class org.apache.pulsar.common.policies.data.DispatchRate
 
toString() - Method in class org.apache.pulsar.common.policies.data.FailureDomain
 
toString() - Method in class org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
toString() - Method in class org.apache.pulsar.common.policies.data.NamespaceOwnershipStatus
 
toString() - Method in class org.apache.pulsar.common.policies.data.PersistencePolicies
 
toString() - Method in class org.apache.pulsar.common.policies.data.Policies
 
toString() - Method in class org.apache.pulsar.common.policies.data.RetentionPolicies
 
toString() - Method in class org.apache.pulsar.common.policies.data.SubscribeRate
 
toString() - Method in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
toString() - Method in class org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImpl
 
totalMessages - Variable in class org.apache.pulsar.common.policies.data.PersistentOfflineTopicStats
Total number of messages
totalNonContiguousDeletedMessagesRange - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
totalSize - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
triggerCompaction(String) - Method in interface org.apache.pulsar.client.admin.Topics
Trigger compaction to run for a topic.
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.
triggerOffload(String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics
Trigger offloading messages in topic to longterm storage.
type - Variable in class org.apache.pulsar.common.policies.data.SubscriptionStats
Whether this subscription is Exclusive or Shared or Failover

U

unackedMessages - Variable in class org.apache.pulsar.common.policies.data.ConsumerStats
Number of unacknowledged messages for the consumer
unackedMessages - Variable in class org.apache.pulsar.common.policies.data.SubscriptionStats
Number of unacknowledged messages for the subscription
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.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
unsubscribeNamespace(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unsubscribes the given subscription on all topics on a namespace
unsubscribeNamespaceBundle(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces
Unsubscribes the given subscription on all topics on a namespace bundle
update(ClusterData) - Method in class org.apache.pulsar.common.policies.data.ClusterData
 
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
updateCluster(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters
Update the configuration for a cluster.
updateDynamicConfiguration(String, String) - Method in interface org.apache.pulsar.client.admin.Brokers
It updates dynamic configuration value in to Zk that triggers watch on brokers and all brokers can update ServiceConfiguration value locally
updateFailureDomain(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters
Update a domain into cluster
updateFunction(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Update the configuration for a function.
updateFunctionWithUrl(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions
Update the configuration for a function.
updateNamespaceIsolationPolicy(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters
Update a namespace isolation policy for a cluster
updatePartitionedTopic(String, int) - 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.
updatePeerClusterNames(String, LinkedHashSet<String>) - Method in interface org.apache.pulsar.client.admin.Clusters
Update peer cluster names.
updateProperty(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Properties
Deprecated.
Update the admins for a property.
updateSink(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sink
Update the configuration for a sink.
updateSinkWithUrl(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sink
Update the configuration for a sink.
updateSource(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Source
Update the configuration for a source.
updateSourceWithUrl(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Source
Update the configuration for a source.
updateTenant(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants
Update the admins for a tenant.
uploadFunction(String, String) - Method in interface org.apache.pulsar.client.admin.Functions
Upload Data.
usage_threshold - Variable in class org.apache.pulsar.common.policies.impl.MinAvailablePolicy
 
userExceptionsTotal - Variable in class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats.FunctionInstanceStatsDataBase
Total number of user exceptions thrown for instance
userExceptionsTotal - Variable in class org.apache.pulsar.common.policies.data.FunctionStats
Overall total number of user exceptions thrown
userMetrics - Variable in class org.apache.pulsar.common.policies.data.FunctionStats.FunctionInstanceStats.FunctionInstanceStatsData
Map of user defined metrics

V

validate() - Method in class org.apache.pulsar.common.policies.data.AutoFailoverPolicyData
 
validate() - Method in class org.apache.pulsar.common.policies.data.NamespaceIsolationData
 
valueOf(String) - Static method in enum org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.common.policies.data.AuthAction
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.common.policies.data.AutoFailoverPolicyType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.common.policies.data.BacklogQuota.BacklogQuotaType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.common.policies.data.BrokerAssignment
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.pulsar.common.policies.data.SubscriptionAuthMode
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.common.policies.data.AuthAction
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.common.policies.data.AutoFailoverPolicyType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.common.policies.data.BacklogQuota.BacklogQuotaType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.common.policies.data.BacklogQuota.RetentionPolicy
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.common.policies.data.BrokerAssignment
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.common.policies.data.SchemaAutoUpdateCompatibilityStrategy
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.pulsar.common.policies.data.SubscriptionAuthMode
Returns an array containing the constants of this enum type, in the order they are declared.

W

waitingCursorsCount - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats
 
waitingReadOp - Variable in class org.apache.pulsar.common.policies.data.PersistentTopicInternalStats.CursorStats
 
worker() - Method in class 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
 
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
 
A B C D E F G H I L M N O P R S T U V W 
Skip navigation links