Index (Pulsar Client Admin Original 2.5.1 API)

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

A

addAuthHeaders(WebTarget, RequestBuilder) - Method in class org.apache.pulsar.client.admin.internal.ComponentResource
allowTlsInsecureConnection(boolean) - Method in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
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)
apply(ClientRequest) - Method in class org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector
apply(ClientRequest, AsyncConnectorCallback) - Method in class org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector
asyncDeleteRequest(WebTarget) - Method in class org.apache.pulsar.client.admin.internal.BaseResource
asyncGetRequest(WebTarget, InvocationCallback<T>) - Method in class org.apache.pulsar.client.admin.internal.BaseResource
AsyncHttpConnector - Class in org.apache.pulsar.client.admin.internal.http
AsyncHttpConnector(int, int, int, ClientConfigurationData) - Constructor for class org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector
AsyncHttpConnector(Client, ClientConfigurationData) - Constructor for class org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector
AsyncHttpConnectorProvider - Class in org.apache.pulsar.client.admin.internal.http
AsyncHttpConnectorProvider(ClientConfigurationData) - Constructor for class org.apache.pulsar.client.admin.internal.http.AsyncHttpConnectorProvider
asyncPostRequest(WebTarget, Entity<T>) - Method in class org.apache.pulsar.client.admin.internal.BaseResource
asyncPutRequest(WebTarget, Entity<T>) - Method in class org.apache.pulsar.client.admin.internal.BaseResource
auth - Variable in class org.apache.pulsar.client.admin.internal.BaseResource
auth - Variable in class org.apache.pulsar.client.admin.PulsarAdmin
authentication(String, String) - Method in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
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 class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
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 class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
authentication(Authentication) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Set the authentication provider to use in the Pulsar admin instance.

B

BaseResource - Class in org.apache.pulsar.client.admin.internal
BaseResource(Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.BaseResource
bookies() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Bookies - Interface in org.apache.pulsar.client.admin: Admin interface for bookies rack placement management.
BookiesImpl - Class in org.apache.pulsar.client.admin.internal
BookiesImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.BookiesImpl
brokers() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Brokers - Interface in org.apache.pulsar.client.admin: Admin interface for brokers management.
BrokersImpl - Class in org.apache.pulsar.client.admin.internal
BrokersImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.BrokersImpl
brokerStats() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
BrokerStats - Interface in org.apache.pulsar.client.admin: Admin interface for brokers management.
BrokerStatsImpl - Class in org.apache.pulsar.client.admin.internal: Pulsar Admin API client.
BrokerStatsImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.BrokerStatsImpl
build() - Method in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
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.

C

clearNamespaceBacklog(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
clearNamespaceBacklog(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for all topics on a namespace
clearNamespaceBacklogForSubscription(String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
clearNamespaceBundleBacklog(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for all topics on a namespace bundle
clearNamespaceBundleBacklogAsync(String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
clearNamespaceBundleBacklogAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for all topics on a namespace bundle asynchronously
clearNamespaceBundleBacklogForSubscription(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
clearNamespaceBundleBacklogForSubscription(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for a given subscription on all topics on a namespace bundle
clearNamespaceBundleBacklogForSubscriptionAsync(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
clearNamespaceBundleBacklogForSubscriptionAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear backlog for a given subscription on all topics on a namespace bundle asynchronously
clearOffloadDeleteLag(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
clearOffloadDeleteLag(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Clear the offload deletion lag for a namespace.
clone() - Method in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
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.internal.http.AsyncHttpConnector
close() - Method in class org.apache.pulsar.client.admin.PulsarAdmin: Close the Pulsar admin client to release all the resources
clusters() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Clusters - Interface in org.apache.pulsar.client.admin: Admin interface for clusters management.
ClustersImpl - Class in org.apache.pulsar.client.admin.internal
ClustersImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.ClustersImpl
compactionStatus(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
compactionStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics: Check the status of an ongoing compaction for a topic.
ComponentResource - Class in org.apache.pulsar.client.admin.internal
ComponentResource(Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.ComponentResource
conf - Variable in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
ConflictException(ClientErrorException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConflictException
ConnectException(String, Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConnectException
ConnectException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ConnectException
connectionTimeout(int, TimeUnit) - Method in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
connectionTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: This sets the connection time out for the pulsar admin client
createCluster(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters: Create a new cluster.
createCluster(String, ClusterData) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
createFailureDomain(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters: Create a domain into cluster
createFailureDomain(String, String, FailureDomain) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
createFunction(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Create a new function.
createFunction(FunctionConfig, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
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.
createFunctionWithUrl(FunctionConfig, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
createMissedPartitions(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
createMissedPartitions(String) - Method in interface org.apache.pulsar.client.admin.Topics: Create missed partitions for partitioned topic.
createMissedPartitionsAsync(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
createMissedPartitionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Create missed partitions for partitioned topic asynchronously.
createNamespace(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
createNamespace(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace.
createNamespace(String, int) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
createNamespace(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace.
createNamespace(String, Set<String>) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
createNamespace(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace.
createNamespace(String, BundlesData) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
createNamespace(String, BundlesData) - Method in interface org.apache.pulsar.client.admin.Namespaces: Create a new namespace.
createNamespace(String, Policies) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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
createNamespaceIsolationPolicy(String, String, NamespaceIsolationData) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
createNonPartitionedTopic(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
createNonPartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics: Create a non-partitioned topic.
createNonPartitionedTopicAsync(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
createNonPartitionedTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Create a non-partitioned topic asynchronously.
createPartitionedTopic(String, int) - Method in class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
createPartitionedTopic(String, int) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
createPartitionedTopicAsync(String, int) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TenantsImpl
createProperty(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Properties: Deprecated.

Create a new property.
createSchema(String, PostSchemaPayload) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
createSchema(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas: Create a schema for a given topic.
createSchema(String, SchemaInfo) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
createSchema(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas: Create a schema for a given topic with the provided schema info.
createSink(SinkConfig, String) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
createSink(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Create a new sink.
createSinkWithUrl(SinkConfig, String) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
createSinkWithUrl(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Create a new sink by providing url from which fun-pkg can be downloaded.
createSource(SourceConfig, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
createSource(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Create a new source.
createSourceWithUrl(SourceConfig, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
createSourceWithUrl(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Create a new source by providing url from which fun-pkg can be downloaded.
createSubscription(String, String, MessageId) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TenantsImpl
createTenant(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Tenants: Create a new tenant.

D

DEFAULT_CONNECT_TIMEOUT_SECONDS - Static variable in class org.apache.pulsar.client.admin.PulsarAdmin
DEFAULT_READ_TIMEOUT_SECONDS - Static variable in class org.apache.pulsar.client.admin.PulsarAdmin
DEFAULT_REQUEST_TIMEOUT_SECONDS - Static variable in class org.apache.pulsar.client.admin.PulsarAdmin
delete(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
delete(String) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a topic.
delete(String, boolean) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
delete(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a topic.
deleteAsync(String, boolean) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
deleteAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a topic asynchronously.
deleteBookieAffinityGroup(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
deleteBookieAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete bookie affinity group configured for a namespace.
deleteBookieRackInfo(String) - Method in interface org.apache.pulsar.client.admin.Bookies: Remove rack placement information for a specific bookie in the cluster
deleteBookieRackInfo(String) - Method in class org.apache.pulsar.client.admin.internal.BookiesImpl
deleteCluster(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Delete an existing cluster
deleteCluster(String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
deleteDynamicConfiguration(String) - Method in interface org.apache.pulsar.client.admin.Brokers: It deletes dynamic configuration value in to Zk.
deleteDynamicConfiguration(String) - Method in class org.apache.pulsar.client.admin.internal.BrokersImpl
deleteFailureDomain(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Delete a domain in cluster
deleteFailureDomain(String, String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
deleteFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Delete an existing function
deleteFunction(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
deleteNamespace(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
deleteNamespace(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing namespace.
deleteNamespaceAntiAffinityGroup(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
deleteNamespaceAntiAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete anti-affinity group name for a namespace.
deleteNamespaceBundle(String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
deleteNamespaceBundle(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing bundle in a namespace.
deleteNamespaceBundleAsync(String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
deleteNamespaceBundleAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Delete an existing bundle in a namespace asynchronously.
deleteNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Delete a namespace isolation policy for a cluster
deleteNamespaceIsolationPolicy(String, String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
deletePartitionedTopic(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
deletePartitionedTopic(String) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a partitioned topic.
deletePartitionedTopic(String, boolean) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
deletePartitionedTopic(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a partitioned topic.
deletePartitionedTopicAsync(String, boolean) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
deletePartitionedTopicAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a partitioned topic asynchronously.
deleteProperty(String) - Method in class org.apache.pulsar.client.admin.internal.TenantsImpl
deleteProperty(String) - Method in interface org.apache.pulsar.client.admin.Properties: Deprecated.

Delete an existing property.
deleteSchema(String) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
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 class org.apache.pulsar.client.admin.internal.SinksImpl
deleteSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Delete an existing sink
deleteSource(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
deleteSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Delete an existing source
deleteSubscription(String, String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
deleteSubscription(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a subscription.
deleteSubscriptionAsync(String, String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
deleteSubscriptionAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Delete a subscription asynchronously.
deleteTenant(String) - Method in class org.apache.pulsar.client.admin.internal.TenantsImpl
deleteTenant(String) - Method in interface org.apache.pulsar.client.admin.Tenants: Delete an existing tenant.
downloadFunction(String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Download Function Code.
downloadFunction(String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
downloadFunction(String, String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Download Function Code.
downloadFunction(String, String, String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl

E

enableTlsHostnameVerification(boolean) - Method in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
enableTlsHostnameVerification(boolean) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: It allows to validate hostname verification when client connects to broker over TLS.
ERROR - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
expireMessages(String, String, long) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
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

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
functions() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Functions - Interface in org.apache.pulsar.client.admin: Admin interface for function management.
FunctionsImpl - Class in org.apache.pulsar.client.admin.internal
FunctionsImpl(WebTarget, Authentication, AsyncHttpClient, long) - Constructor for class org.apache.pulsar.client.admin.internal.FunctionsImpl

G

getActiveBrokers(String) - Method in interface org.apache.pulsar.client.admin.Brokers: Get the list of active brokers in the cluster.
getActiveBrokers(String) - Method in class org.apache.pulsar.client.admin.internal.BrokersImpl
getAllDynamicConfigurations() - Method in interface org.apache.pulsar.client.admin.Brokers: Get values of all overridden dynamic-configs
getAllDynamicConfigurations() - Method in class org.apache.pulsar.client.admin.internal.BrokersImpl
getAllocatorStats(String) - Method in interface org.apache.pulsar.client.admin.BrokerStats
getAllocatorStats(String) - Method in class org.apache.pulsar.client.admin.internal.BrokerStatsImpl
getAllSchemas(String) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
getAllSchemas(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Get all version schemas topic.
getAntiAffinityNamespaces(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getAntiAffinityNamespaces(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get all namespaces that grouped with given anti-affinity group
getApiException(Throwable) - Method in class org.apache.pulsar.client.admin.internal.BaseResource
getApiException(Response) - Method in class org.apache.pulsar.client.admin.internal.BaseResource
getAssignments() - Method in class org.apache.pulsar.client.admin.internal.WorkerImpl
getAssignments() - Method in interface org.apache.pulsar.client.admin.Worker: Get the function assignment among the cluster
getBacklogQuotaMap(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getBacklogQuotaMap(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get backlog quota map on a namespace.
getBookieAffinityGroup(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getBookieAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get bookie affinity group configured for a namespace.
getBookieRackInfo(String) - Method in interface org.apache.pulsar.client.admin.Bookies: Gets the rack placement information for a specific bookie in the cluster
getBookieRackInfo(String) - Method in class org.apache.pulsar.client.admin.internal.BookiesImpl
getBookiesRackInfo() - Method in interface org.apache.pulsar.client.admin.Bookies: Gets the rack placement information for all the bookies in the cluster
getBookiesRackInfo() - Method in class org.apache.pulsar.client.admin.internal.BookiesImpl
getBrokerResourceAvailability(String) - Method in class org.apache.pulsar.client.admin.internal.BrokerStatsImpl
getBrokersWithNamespaceIsolationPolicy(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Returns list of active brokers with namespace-isolation policies attached to it.
getBrokersWithNamespaceIsolationPolicy(String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
getBrokerWithNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Returns active broker with namespace-isolation policies attached to it.
getBrokerWithNamespaceIsolationPolicy(String, String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
getBuiltInSinks() - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
getBuiltInSinks() - Method in interface org.apache.pulsar.client.admin.Sinks: Fetches a list of supported Pulsar IO sinks currently running in cluster mode
getBuiltInSources() - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
getBuiltInSources() - Method in interface org.apache.pulsar.client.admin.Sources: Fetches a list of supported Pulsar IO sources currently running in cluster mode
getBundleRange(String) - Method in class org.apache.pulsar.client.admin.internal.LookupImpl
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
getCluster() - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
getCluster() - Method in class org.apache.pulsar.client.admin.internal.WorkerImpl
getCluster() - Method in interface org.apache.pulsar.client.admin.Worker: Get List of all workers belonging to this cluster
getCluster(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get the configuration data for the specified cluster.
getCluster(String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
getClusterLeader() - Method in class org.apache.pulsar.client.admin.internal.WorkerImpl
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.
getClusters() - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
getCompactionThreshold(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getCompactionThreshold(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the compactionThreshold for a namespace.
getConnector(int, int, int) - Method in class org.apache.pulsar.client.admin.internal.http.AsyncHttpConnectorProvider
getConnector(Client, Configuration) - Method in class org.apache.pulsar.client.admin.internal.http.AsyncHttpConnectorProvider
getConnectorsList() - Method in interface org.apache.pulsar.client.admin.Functions: Deprecated.
getConnectorsList() - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
getContext(Class<?>) - Method in class org.apache.pulsar.client.admin.internal.JacksonConfigurator
getDefaultResourceQuota() - Method in class org.apache.pulsar.client.admin.internal.ResourceQuotasImpl
getDefaultResourceQuota() - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Get default resource quota for new resource bundles.
getDelayedDelivery(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getDelayedDelivery(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the delayed delivery messages for all topics within a namespace.
getDispatchRate(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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)
getDynamicConfigurationNames() - Method in interface org.apache.pulsar.client.admin.Brokers: Get list of updatable configuration name
getDynamicConfigurationNames() - Method in class org.apache.pulsar.client.admin.internal.BrokersImpl
getFailureDomain(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get the domain registered into a cluster
getFailureDomain(String, String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
getFailureDomains(String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get all registered domains in cluster
getFailureDomains(String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
getFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Get the configuration for the specified function.
getFunction(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
getFunctions(String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Get the list of functions.
getFunctions(String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
getFunctionsStats() - Method in class org.apache.pulsar.client.admin.internal.WorkerImpl
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.
getFunctionState(String, String, String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
getFunctionStats(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current stats of a function.
getFunctionStats(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
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, int) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
getFunctionStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current status of a function.
getFunctionStatus(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
getFunctionStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Gets the current status of a function instance.
getFunctionStatus(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
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.
getInternalConfigurationData() - Method in class org.apache.pulsar.client.admin.internal.BrokersImpl
getInternalInfo(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
getInternalStats(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
getInternalStatsAsync(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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.
getIsAllowAutoUpdateSchema(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getIsAllowAutoUpdateSchema(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get whether allow auto update schema
getLastMessageId(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
getLastMessageId(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the last commit message Id of a topic
getLastMessageIdAsync(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
getList(String) - Method in class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
getList(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
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 class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
getListInBundle(String, String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
getListInBundleAsync(String, String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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.
getLoadReport() - Method in interface org.apache.pulsar.client.admin.BrokerStats
getLoadReport() - Method in class org.apache.pulsar.client.admin.internal.BrokerStatsImpl
getMaxConsumersPerSubscription(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getMaxConsumersPerSubscription(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxConsumersPerSubscription for a namespace.
getMaxConsumersPerTopic(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getMaxConsumersPerTopic(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the maxProducersPerTopic for a namespace.
getMaxProducersPerTopic(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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
getMBeans() - Method in class org.apache.pulsar.client.admin.internal.BrokerStatsImpl
getMetrics() - Method in interface org.apache.pulsar.client.admin.BrokerStats: Returns Monitoring metrics
getMetrics() - Method in class org.apache.pulsar.client.admin.internal.BrokerStatsImpl
getMetrics() - Method in class org.apache.pulsar.client.admin.internal.WorkerImpl
getMetrics() - Method in interface org.apache.pulsar.client.admin.Worker: Get worker metrics.
getName() - Method in class org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector
getNamespaceAntiAffinityGroup(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getNamespaceAntiAffinityGroup(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get anti-affinity group name for a namespace
getNamespaceBundleResourceQuota(String, String) - Method in class org.apache.pulsar.client.admin.internal.ResourceQuotasImpl
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
getNamespaceIsolationPolicies(String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
getNamespaceIsolationPolicy(String, String) - Method in interface org.apache.pulsar.client.admin.Clusters: Get a single namespace isolation policy for a cluster
getNamespaceIsolationPolicy(String, String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
getNamespaceMessageTTL(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getNamespaceMessageTTL(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the message TTL for a namespace.
getNamespaceReplicationClusters(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getNamespaceReplicationClusters(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the replication clusters for a namespace.
getNamespaces(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getNamespaces(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the list of namespaces.
getNamespaces(String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getNamespaces(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Deprecated.
getOffloadDeleteLagMs(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getOffloadDeleteLagMs(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the offload deletion lag for a namespace, in milliseconds.
getOffloadPolicies(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getOffloadPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the offload configuration for a namespace.
getOffloadThreshold(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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
getOwnedNamespaces(String, String) - Method in class org.apache.pulsar.client.admin.internal.BrokersImpl
getPartitionedInternalStats(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
getPartitionedInternalStats(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the stats for the partitioned topic
getPartitionedInternalStatsAsync(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
getPartitionedInternalStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the stats-internal for the partitioned topic asynchronously
getPartitionedStats(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getPartitionedStats(String, boolean, boolean) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
getPartitionedStats(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Get the stats for the partitioned topic
getPartitionedStatsAsync(String, boolean) - Method in interface org.apache.pulsar.client.admin.Topics
getPartitionedStatsAsync(String, boolean, boolean) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
getPartitionedStatsAsync(String, boolean, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Get the stats for the partitioned topic asynchronously
getPartitionedTopicList(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
getPartitionedTopicList(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of partitioned topics under a namespace.
getPartitionedTopicMetadata(String) - Method in class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
getPartitionedTopicMetadata(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
getPartitionedTopicMetadataAsync(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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(String) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
getPendingBookieOpsStats() - Method in interface org.apache.pulsar.client.admin.BrokerStats
getPendingBookieOpsStats() - Method in class org.apache.pulsar.client.admin.internal.BrokerStatsImpl
getPermissions(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getPermissions(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
getPersistence(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the persistence configuration for a namespace.
getPolicies(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getPolicies(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get policies for a namespace.
getProperties() - Method in class org.apache.pulsar.client.admin.internal.TenantsImpl
getProperties() - Method in interface org.apache.pulsar.client.admin.Properties: Deprecated.

Get the list of properties.
getPropertyAdmin(String) - Method in class org.apache.pulsar.client.admin.internal.TenantsImpl
getPropertyAdmin(String) - Method in interface org.apache.pulsar.client.admin.Properties: Deprecated.

Get the config of the property.
getPublishRate(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getPublishRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get message-publish-rate (topics under this namespace can publish this many messages per second)
getReplicationConfigVersion(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getReplicationConfigVersion(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the replication configuration version for a given namespace
getReplicatorDispatchRate(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getReplicatorDispatchRate(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get replicator-message-dispatch-rate (Replicators under this namespace can dispatch this many messages per second)
getRetention(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getRetention(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the retention configuration for a namespace.
getRuntimeConfigurations() - Method in interface org.apache.pulsar.client.admin.Brokers: Get values of runtime configuration
getRuntimeConfigurations() - Method in class org.apache.pulsar.client.admin.internal.BrokersImpl
getSchemaAutoUpdateCompatibilityStrategy(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getSchemaAutoUpdateCompatibilityStrategy(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Deprecated.
getSchemaCompatibilityStrategy(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getSchemaCompatibilityStrategy(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed.
getSchemaInfo(String) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
getSchemaInfo(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Retrieve the latest schema of a topic.
getSchemaInfo(String, long) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
getSchemaInfo(String, long) - Method in interface org.apache.pulsar.client.admin.Schemas: Retrieve the schema of a topic at a given version.
getSchemaInfoWithVersion(String) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
getSchemaInfoWithVersion(String) - Method in interface org.apache.pulsar.client.admin.Schemas: Retrieve the latest schema with verison of a topic.
getSchemaValidationEnforced(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getSchemaValidationEnforced(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get schema validation enforced for namespace.
getServiceUrl() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
getSink(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
getSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Get the configuration for the specified sink.
getSinks() - Method in interface org.apache.pulsar.client.admin.Functions: Deprecated.
getSinks() - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
getSinkStatus(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
getSinkStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Gets the current status of a sink.
getSinkStatus(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
getSinkStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Gets the current status of a sink instance.
getSource(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
getSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Get the configuration for the specified source.
getSources() - Method in interface org.apache.pulsar.client.admin.Functions: Deprecated.
getSources() - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
getSourceStatus(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
getSourceStatus(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Gets the current status of a source.
getSourceStatus(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
getSourceStatus(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Gets the current status of a source instance.
getStats(String) - Method in class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
getStats(String) - Method in interface org.apache.pulsar.client.admin.NonPersistentTopics: Deprecated.

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

Get the stats for the topic asynchronously.
getStatsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics
getStatsAsync(String, boolean) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
getStatsAsync(String, boolean) - 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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
getSubscriptions(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of subscriptions.
getSubscriptionsAsync(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
getSubscriptionsAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Get the list of subscriptions asynchronously.
getTenantInfo(String) - Method in class org.apache.pulsar.client.admin.internal.TenantsImpl
getTenantInfo(String) - Method in interface org.apache.pulsar.client.admin.Tenants: Get the config of the tenant.
getTenants() - Method in class org.apache.pulsar.client.admin.internal.TenantsImpl
getTenants() - Method in interface org.apache.pulsar.client.admin.Tenants: Get the list of tenants.
GettingAuthenticationDataException(String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.GettingAuthenticationDataException
GettingAuthenticationDataException(Throwable) - 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() - Method in class org.apache.pulsar.client.admin.internal.BrokerStatsImpl
getTopics(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
getTopics(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Get the list of topics.
getVersionBySchema(String, PostSchemaPayload) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
getVersionBySchema(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas: Find schema version topic.
getVersionBySchema(String, SchemaInfo) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
getVersionBySchema(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas: Find schema version topic.
getWebTarget() - Method in class org.apache.pulsar.client.admin.internal.TenantsImpl
grantPermission(String, String, Set<AuthAction>) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
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

healthcheck() - Method in interface org.apache.pulsar.client.admin.Brokers: Run a healthcheck on the broker.
healthcheck() - Method in class org.apache.pulsar.client.admin.internal.BrokersImpl
HttpErrorException(Exception) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.HttpErrorException
HttpErrorException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.HttpErrorException

J

JacksonConfigurator - Class in org.apache.pulsar.client.admin.internal: Provides custom configuration for jackson.
JacksonConfigurator() - Constructor for class org.apache.pulsar.client.admin.internal.JacksonConfigurator

L

lastError - Variable in class org.apache.pulsar.client.admin.LongRunningProcessStatus
listSinks(String, String) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
listSinks(String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Get the list of sinks.
listSources(String, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
listSources(String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Get the list of sources.
LongRunningProcessStatus - Class in org.apache.pulsar.client.admin: Status of long running process.
LongRunningProcessStatus() - Constructor for class org.apache.pulsar.client.admin.LongRunningProcessStatus
LongRunningProcessStatus.Status - Enum Class in org.apache.pulsar.client.admin
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.
LookupImpl - Class in org.apache.pulsar.client.admin.internal
LookupImpl(WebTarget, Authentication, boolean, long) - Constructor for class org.apache.pulsar.client.admin.internal.LookupImpl
lookups() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
lookupTopic(String) - Method in class org.apache.pulsar.client.admin.internal.LookupImpl
lookupTopic(String) - Method in interface org.apache.pulsar.client.admin.Lookup: Lookup a topic

N

namespaces() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Namespaces - Interface in org.apache.pulsar.client.admin: Admin interface for namespaces management
NamespacesImpl - Class in org.apache.pulsar.client.admin.internal
NamespacesImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.NamespacesImpl
nonPersistentTopics() - Method in class org.apache.pulsar.client.admin.PulsarAdmin: Deprecated.
Since 2.0. See PulsarAdmin.topics()
NonPersistentTopics - Interface in org.apache.pulsar.client.admin: Deprecated.
since 2.0. See Topics
NonPersistentTopicsImpl - Class in org.apache.pulsar.client.admin.internal
NonPersistentTopicsImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
NOT_RUN - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status
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

O

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 class org.apache.pulsar.client.admin.internal.TopicsImpl
offloadStatus(String) - Method in interface org.apache.pulsar.client.admin.Topics: Check the status of an ongoing offloading operation for a topic.
org.apache.pulsar.client.admin - package org.apache.pulsar.client.admin
org.apache.pulsar.client.admin.internal - package org.apache.pulsar.client.admin.internal
org.apache.pulsar.client.admin.internal.http - package org.apache.pulsar.client.admin.internal.http

P

peekMessages(String, String, int) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
peekMessagesAsync(String, String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Peek messages from a topic subscription asynchronously
PreconditionFailedException(ClientErrorException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.PreconditionFailedException
properties() - Method in class org.apache.pulsar.client.admin.PulsarAdmin: Deprecated.
since 2.0. See PulsarAdmin.tenants()
Properties - Interface in org.apache.pulsar.client.admin: Deprecated.
see Tenants from PulsarAdmin.tenants()
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(String, ClientConfigurationData, int, TimeUnit, int, TimeUnit, int, TimeUnit) - Constructor for class org.apache.pulsar.client.admin.PulsarAdmin
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.
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.
PulsarAdminBuilder - Interface in org.apache.pulsar.client.admin: Builder class for a PulsarAdmin instance.
PulsarAdminBuilderImpl - Class in org.apache.pulsar.client.admin.internal
PulsarAdminBuilderImpl() - Constructor for class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
PulsarAdminException - Exception in org.apache.pulsar.client.admin
PulsarAdminException(String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
PulsarAdminException(String, Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
PulsarAdminException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException
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.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
PulsarAdminException.TimeoutException - Exception in org.apache.pulsar.client.admin
putFunctionState(String, String, String, FunctionState) - Method in interface org.apache.pulsar.client.admin.Functions: Puts the given state associated with a Pulsar Function.
putFunctionState(String, String, String, FunctionState) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl

R

readTimeout(int, TimeUnit) - Method in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
readTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: This sets the server response read time out for the pulsar admin client for any request.
readTimeoutMs - Variable in class org.apache.pulsar.client.admin.internal.BaseResource
reloadBuiltInSinks() - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
reloadBuiltInSinks() - Method in interface org.apache.pulsar.client.admin.Sinks: Reload the available built-in connectors, include Source and Sink
reloadBuiltInSources() - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
reloadBuiltInSources() - Method in interface org.apache.pulsar.client.admin.Sources: Reload the available built-in connectors, include Source and Sink
removeBacklogQuota(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
removeBacklogQuota(String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Remove a backlog quota policy from a namespace.
request(WebTarget) - Method in class org.apache.pulsar.client.admin.internal.BaseResource
requestAsync(WebTarget) - Method in class org.apache.pulsar.client.admin.internal.BaseResource
requestTimeout(int, TimeUnit) - Method in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
requestTimeout(int, TimeUnit) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: This sets the server request time out for the pulsar admin client for any request.
resetCursor(String, String, long) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.ResourceQuotasImpl
resetNamespaceBundleResourceQuota(String, String) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Reset resource quota for a namespace bundle to default value.
resourceQuotas() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
ResourceQuotas - Interface in org.apache.pulsar.client.admin
ResourceQuotasImpl - Class in org.apache.pulsar.client.admin.internal
ResourceQuotasImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.ResourceQuotasImpl
restartFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Restart all function instances
restartFunction(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
restartFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Restart function instance
restartFunction(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
restartSink(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
restartSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Restart all sink instances
restartSink(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
restartSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Restart sink instance
restartSource(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
restartSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Restart all source instances
restartSource(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
restartSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Restart source instance
revokePermissionOnSubscription(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
revokePermissions(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Revoke permissions on a topic.
revokePermissionsOnNamespace(String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status

S

schemas() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Schemas - Interface in org.apache.pulsar.client.admin: Admin interface on interacting with schemas.
SchemasImpl - Class in org.apache.pulsar.client.admin.internal
SchemasImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.SchemasImpl
ServerSideErrorException(ServerErrorException) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ServerSideErrorException
ServerSideErrorException(ServerErrorException, String) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.ServerSideErrorException
serviceHttpUrl(String) - Method in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
serviceHttpUrl(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Set the Pulsar service HTTP URL for the admin endpoint (eg.
setBacklogQuota(String, BacklogQuota) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setBacklogQuota(String, BacklogQuota) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set a backlog quota for all the topics on a namespace.
setBookieAffinityGroup(String, BookieAffinityGroupData) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setBookieAffinityGroup(String, BookieAffinityGroupData) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set bookie affinity group for a namespace to isolate namespace write to bookies that are part of given affinity group.
setCompactionThreshold(String, long) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setCompactionThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the compactionThreshold for a namespace.
setDeduplicationStatus(String, boolean) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.ResourceQuotasImpl
setDefaultResourceQuota(ResourceQuota) - Method in interface org.apache.pulsar.client.admin.ResourceQuotas: Set default resource quota for new namespace bundles.
setDelayedDeliveryMessages(String, DelayedDeliveryPolicies) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setDelayedDeliveryMessages(String, DelayedDeliveryPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the delayed delivery messages for all topics within a namespace.
setDispatchRate(String, DispatchRate) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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)
setEncryptionRequiredStatus(String, boolean) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setEncryptionRequiredStatus(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the encryption required status for all topics within a namespace.
setIsAllowAutoUpdateSchema(String, boolean) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setIsAllowAutoUpdateSchema(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: The flag is when producer bring a new schema and the schema pass compatibility check whether allow schema auto registered
setMaxConsumersPerSubscription(String, int) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setMaxConsumersPerSubscription(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxConsumersPerSubscription for a namespace.
setMaxConsumersPerTopic(String, int) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setMaxConsumersPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxConsumersPerTopic for a namespace.
setMaxProducersPerTopic(String, int) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setMaxProducersPerTopic(String, int) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set maxProducersPerTopic for a namespace.
setNamespaceAntiAffinityGroup(String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.ResourceQuotasImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
setNamespaceReplicationClusters(String, Set<String>) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the replication clusters for a namespace.
setOffloadDeleteLag(String, long, TimeUnit) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setOffloadDeleteLag(String, long, TimeUnit) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the offload deletion lag for a namespace.
setOffloadPolicies(String, OffloadPolicies) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setOffloadPolicies(String, OffloadPolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the offload configuration for all the topics in a namespace.
setOffloadThreshold(String, long) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setOffloadThreshold(String, long) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the offloadThreshold for a namespace.
setPersistence(String, PersistencePolicies) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setPersistence(String, PersistencePolicies) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the persistence configuration for all the topics on a namespace.
setPublishRate(String, PublishRate) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setPublishRate(String, PublishRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set message-publish-rate (topics under this namespace can publish this many messages per second)
setReplicatorDispatchRate(String, DispatchRate) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setReplicatorDispatchRate(String, DispatchRate) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set replicator-message-dispatch-rate (Replicators under this namespace can dispatch this many messages per second)
setRetention(String, RetentionPolicies) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
setSchemaAutoUpdateCompatibilityStrategy(String, SchemaAutoUpdateCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.Namespaces: Deprecated.
setSchemaCompatibilityStrategy(String, SchemaCompatibilityStrategy) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setSchemaCompatibilityStrategy(String, SchemaCompatibilityStrategy) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set the strategy used to check the a new schema provided by a producer is compatible with the current schema before it is installed.
setSchemaValidationEnforced(String, boolean) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
setSchemaValidationEnforced(String, boolean) - Method in interface org.apache.pulsar.client.admin.Namespaces: Set schema validation enforced for namespace.
setSubscribeRate(String, SubscribeRate) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
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)
sink() - Method in class org.apache.pulsar.client.admin.PulsarAdmin: Deprecated.
in favor of PulsarAdmin.sinks
Sink - Interface in org.apache.pulsar.client.admin: Deprecated.
in favor of Sinks
sinks() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Sinks - Interface in org.apache.pulsar.client.admin: Admin interface for Sink management.
SinksImpl - Class in org.apache.pulsar.client.admin.internal
SinksImpl(WebTarget, Authentication, AsyncHttpClient, long) - Constructor for class org.apache.pulsar.client.admin.internal.SinksImpl
skipAllMessages(String, String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
skipAllMessages(String, String) - Method in interface org.apache.pulsar.client.admin.Topics: Skip all messages on a topic subscription.
skipAllMessagesAsync(String, String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
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: Deprecated.
in favor of PulsarAdmin.sources()
Source - Interface in org.apache.pulsar.client.admin: Deprecated.
in favor of Sources
sources() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Sources - Interface in org.apache.pulsar.client.admin: Admin interface for Source management.
SourcesImpl - Class in org.apache.pulsar.client.admin.internal
SourcesImpl(WebTarget, Authentication, AsyncHttpClient, long) - Constructor for class org.apache.pulsar.client.admin.internal.SourcesImpl
splitNamespaceBundle(String, String, boolean, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
splitNamespaceBundle(String, String, boolean, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Split namespace bundle
startFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Start all function instances
startFunction(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
startFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Start function instance
startFunction(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
startSink(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
startSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Start all sink instances
startSink(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
startSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Start sink instance
startSource(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
startSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Start all source instances
startSource(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
startSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Start source instance
status - Variable in class org.apache.pulsar.client.admin.LongRunningProcessStatus
stopFunction(String, String, String) - Method in interface org.apache.pulsar.client.admin.Functions: Stop all function instances
stopFunction(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
stopFunction(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Functions: Stop function instance
stopFunction(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
stopSink(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
stopSink(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Stop all sink instances
stopSink(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
stopSink(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sinks: Stop sink instance
stopSource(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
stopSource(String, String, String) - Method in interface org.apache.pulsar.client.admin.Sources: Stop all source instances
stopSource(String, String, String, int) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
stopSource(String, String, String, int) - Method in interface org.apache.pulsar.client.admin.Sources: Stop source instance
SUCCESS - Enum constant in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status

T

tenants() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Tenants - Interface in org.apache.pulsar.client.admin: Admin interface for tenants management
TenantsImpl - Class in org.apache.pulsar.client.admin.internal
TenantsImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.TenantsImpl
terminateTopicAsync(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
terminateTopicAsync(String) - Method in interface org.apache.pulsar.client.admin.Topics: Terminate the topic and prevent any more messages being published on it.
testCompatibility(String, PostSchemaPayload) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
testCompatibility(String, PostSchemaPayload) - Method in interface org.apache.pulsar.client.admin.Schemas: Judge schema compatibility topic.
testCompatibility(String, SchemaInfo) - Method in class org.apache.pulsar.client.admin.internal.SchemasImpl
testCompatibility(String, SchemaInfo) - Method in interface org.apache.pulsar.client.admin.Schemas: Judge schema compatibility topic.
TimeoutException(Throwable) - Constructor for exception org.apache.pulsar.client.admin.PulsarAdminException.TimeoutException
tlsTrustCertsFilePath(String) - Method in class org.apache.pulsar.client.admin.internal.PulsarAdminBuilderImpl
tlsTrustCertsFilePath(String) - Method in interface org.apache.pulsar.client.admin.PulsarAdminBuilder: Set the path to the trusted TLS certificate file
topics() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Topics - Interface in org.apache.pulsar.client.admin
TopicsImpl - Class in org.apache.pulsar.client.admin.internal
TopicsImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.TopicsImpl
triggerCompaction(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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.
triggerFunction(String, String, String, String, String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
triggerOffload(String, MessageId) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
triggerOffload(String, MessageId) - Method in interface org.apache.pulsar.client.admin.Topics: Trigger offloading messages in topic to longterm storage.

U

unload(String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
unload(String) - Method in class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
unload(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.NonPersistentTopicsImpl
unloadAsync(String) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
unloadNamespaceBundle(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unload namespace bundle
unloadNamespaceBundleAsync(String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
unloadNamespaceBundleAsync(String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unload namespace bundle asynchronously
unsubscribeNamespace(String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
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 class org.apache.pulsar.client.admin.internal.NamespacesImpl
unsubscribeNamespaceBundle(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unsubscribes the given subscription on all topics on a namespace bundle
unsubscribeNamespaceBundleAsync(String, String, String) - Method in class org.apache.pulsar.client.admin.internal.NamespacesImpl
unsubscribeNamespaceBundleAsync(String, String, String) - Method in interface org.apache.pulsar.client.admin.Namespaces: Unsubscribes the given subscription on all topics on a namespace bundle asynchronously
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
updateBookieRackInfo(String, String, BookieInfo) - Method in class org.apache.pulsar.client.admin.internal.BookiesImpl
updateCluster(String, ClusterData) - Method in interface org.apache.pulsar.client.admin.Clusters: Update the configuration for a cluster.
updateCluster(String, ClusterData) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
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
updateDynamicConfiguration(String, String) - Method in class org.apache.pulsar.client.admin.internal.BrokersImpl
updateFailureDomain(String, String, FailureDomain) - Method in interface org.apache.pulsar.client.admin.Clusters: Update a domain into cluster
updateFailureDomain(String, String, FailureDomain) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
updateFunction(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function.
updateFunction(FunctionConfig, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
updateFunction(FunctionConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function.
updateFunction(FunctionConfig, String, UpdateOptions) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
updateFunctionWithUrl(FunctionConfig, String) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function.
updateFunctionWithUrl(FunctionConfig, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
updateFunctionWithUrl(FunctionConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Functions: Update the configuration for a function.
updateFunctionWithUrl(FunctionConfig, String, UpdateOptions) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl
updateNamespaceIsolationPolicy(String, String, NamespaceIsolationData) - Method in interface org.apache.pulsar.client.admin.Clusters: Update a namespace isolation policy for a cluster
updateNamespaceIsolationPolicy(String, String, NamespaceIsolationData) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
updatePartitionedTopic(String, int) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
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 class org.apache.pulsar.client.admin.internal.TopicsImpl
updatePartitionedTopicAsync(String, int) - Method in interface org.apache.pulsar.client.admin.Topics: Update number of partitions of a non-global partitioned topic asynchronously.
updatePartitionedTopicAsync(String, int, boolean) - Method in class org.apache.pulsar.client.admin.internal.TopicsImpl
updatePartitionedTopicAsync(String, int, boolean) - Method in interface org.apache.pulsar.client.admin.Topics: Update number of partitions of a non-global partitioned topic asynchronously.
updatePeerClusterNames(String, LinkedHashSet<String>) - Method in interface org.apache.pulsar.client.admin.Clusters: Update peer cluster names.
updatePeerClusterNames(String, LinkedHashSet<String>) - Method in class org.apache.pulsar.client.admin.internal.ClustersImpl
updateProperty(String, TenantInfo) - Method in class org.apache.pulsar.client.admin.internal.TenantsImpl
updateProperty(String, TenantInfo) - Method in interface org.apache.pulsar.client.admin.Properties: Deprecated.

Update the admins for a property.
updateSink(SinkConfig, String) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
updateSink(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink.
updateSink(SinkConfig, String, UpdateOptions) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
updateSink(SinkConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink.
updateSinkWithUrl(SinkConfig, String) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
updateSinkWithUrl(SinkConfig, String) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink.
updateSinkWithUrl(SinkConfig, String, UpdateOptions) - Method in class org.apache.pulsar.client.admin.internal.SinksImpl
updateSinkWithUrl(SinkConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sinks: Update the configuration for a sink.
updateSource(SourceConfig, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
updateSource(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source.
updateSource(SourceConfig, String, UpdateOptions) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
updateSource(SourceConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source.
updateSourceWithUrl(SourceConfig, String) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
updateSourceWithUrl(SourceConfig, String) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source.
updateSourceWithUrl(SourceConfig, String, UpdateOptions) - Method in class org.apache.pulsar.client.admin.internal.SourcesImpl
updateSourceWithUrl(SourceConfig, String, UpdateOptions) - Method in interface org.apache.pulsar.client.admin.Sources: Update the configuration for a source.
updateTenant(String, TenantInfo) - Method in class org.apache.pulsar.client.admin.internal.TenantsImpl
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.
uploadFunction(String, String) - Method in class org.apache.pulsar.client.admin.internal.FunctionsImpl

V

valueOf(String) - Static method in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.apache.pulsar.client.admin.LongRunningProcessStatus.Status: Returns an array containing the constants of this enum class, in the order they are declared.

W

worker() - Method in class org.apache.pulsar.client.admin.PulsarAdmin
Worker - Interface in org.apache.pulsar.client.admin: Admin interface for worker stats management.
WorkerImpl - Class in org.apache.pulsar.client.admin.internal
WorkerImpl(WebTarget, Authentication, long) - Constructor for class org.apache.pulsar.client.admin.internal.WorkerImpl

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