| Package | Description |
|---|---|
| org.apache.pulsar.common.naming | |
| org.apache.pulsar.common.policies | |
| org.apache.pulsar.common.policies.impl |
| Modifier and Type | Method and Description |
|---|---|
static NamespaceName |
NamespaceName.get(String namespace) |
static NamespaceName |
NamespaceName.get(String tenant,
String namespace) |
static NamespaceName |
NamespaceName.get(String tenant,
String cluster,
String namespace) |
NamespaceName |
ServiceUnitId.getNamespaceObject()
Return the namespace object that this
ServiceUnitId belongs to |
NamespaceName |
TopicName.getNamespaceObject()
Get the namespace object that this completeTopicName belongs to
|
NamespaceName |
NamespaceName.getNamespaceObject() |
| Modifier and Type | Method and Description |
|---|---|
static TopicName |
TopicName.get(String domain,
NamespaceName namespaceName,
String topic) |
| Modifier and Type | Method and Description |
|---|---|
List<URL> |
NamespaceIsolationPolicy.findPrimaryBrokers(List<URL> availableBrokers,
NamespaceName namespace)
Get the list of primary brokers for the namespace according to the policy
|
List<URL> |
NamespaceIsolationPolicy.findSecondaryBrokers(List<URL> availableBrokers,
NamespaceName namespace)
Get the list of secondary brokers for the namespace according to the policy
|
| Modifier and Type | Method and Description |
|---|---|
void |
NamespaceIsolationPolicies.assignBroker(NamespaceName nsname,
BrokerStatus brkStatus,
SortedSet<BrokerStatus> primaryCandidates,
SortedSet<BrokerStatus> secondaryCandidates,
SortedSet<BrokerStatus> sharedCandidates) |
List<URL> |
NamespaceIsolationPolicyImpl.findPrimaryBrokers(List<URL> availableBrokers,
NamespaceName namespace) |
List<URL> |
NamespaceIsolationPolicyImpl.findSecondaryBrokers(List<URL> availableBrokers,
NamespaceName namespace) |
NamespaceIsolationPolicy |
NamespaceIsolationPolicies.getPolicyByNamespace(NamespaceName namespace)
Get the namespace isolation policy for the specified namespace
|
Copyright © 2017–2018 Apache Software Foundation. All rights reserved.