Uses of Class
org.apache.pulsar.common.policies.data.BrokerStatus

Packages that use BrokerStatus

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

Uses of BrokerStatus in org.apache.pulsar.common.policies

Methods in org.apache.pulsar.common.policies that return types with arguments of type BrokerStatus

Modifier and Type	Method and Description
SortedSet<BrokerStatus>	NamespaceIsolationPolicy.getAvailablePrimaryBrokers(SortedSet<BrokerStatus> primaryCandidates) According to the namespace isolation policy, find the allowed available primary brokers

Methods in org.apache.pulsar.common.policies with parameters of type BrokerStatus

Modifier and Type	Method and Description
abstract boolean	AutoFailoverPolicy.isBrokerAvailable(BrokerStatus brokerStatus) Determine whether a broker is considered available or not
boolean	NamespaceIsolationPolicy.isPrimaryBrokerAvailable(BrokerStatus brkStatus)

Method parameters in org.apache.pulsar.common.policies with type arguments of type BrokerStatus

Modifier and Type	Method and Description
SortedSet<BrokerStatus>	NamespaceIsolationPolicy.getAvailablePrimaryBrokers(SortedSet<BrokerStatus> primaryCandidates) According to the namespace isolation policy, find the allowed available primary brokers
boolean	NamespaceIsolationPolicy.shouldFailover(SortedSet<BrokerStatus> primaryCandidates) Check to see whether the primary brokers can still handle a new namespace or has to failover
abstract boolean	AutoFailoverPolicy.shouldFailoverToSecondary(SortedSet<BrokerStatus> brokerStatus) Checks to see whether the new namespace ownership should be failed over to the secondary brokers
boolean	NamespaceIsolationPolicy.shouldFallback(SortedSet<BrokerStatus> primaryBrokers) Check to see whether the namespace ownership should fallback to the primary brokers

Uses of BrokerStatus in org.apache.pulsar.common.policies.data

Methods in org.apache.pulsar.common.policies.data with parameters of type BrokerStatus

Modifier and Type	Method and Description
int	BrokerStatus.compareTo(BrokerStatus other)

Uses of BrokerStatus in org.apache.pulsar.common.policies.impl

Methods in org.apache.pulsar.common.policies.impl that return types with arguments of type BrokerStatus

Modifier and Type	Method and Description
SortedSet<BrokerStatus>	NamespaceIsolationPolicyImpl.getAvailablePrimaryBrokers(SortedSet<BrokerStatus> primaryCandidates)

Methods in org.apache.pulsar.common.policies.impl with parameters of type BrokerStatus

Modifier and Type	Method and Description
void	NamespaceIsolationPolicies.assignBroker(NamespaceName nsname, BrokerStatus brkStatus, SortedSet<BrokerStatus> primaryCandidates, SortedSet<BrokerStatus> secondaryCandidates, SortedSet<BrokerStatus> sharedCandidates)
boolean	MinAvailablePolicy.isBrokerAvailable(BrokerStatus brokerStatus)
boolean	NamespaceIsolationPolicyImpl.isPrimaryBrokerAvailable(BrokerStatus brkStatus)

Method parameters in org.apache.pulsar.common.policies.impl with type arguments of type BrokerStatus

Modifier and Type	Method and Description
void	NamespaceIsolationPolicies.assignBroker(NamespaceName nsname, BrokerStatus brkStatus, SortedSet<BrokerStatus> primaryCandidates, SortedSet<BrokerStatus> secondaryCandidates, SortedSet<BrokerStatus> sharedCandidates)
void	NamespaceIsolationPolicies.assignBroker(NamespaceName nsname, BrokerStatus brkStatus, SortedSet<BrokerStatus> primaryCandidates, SortedSet<BrokerStatus> secondaryCandidates, SortedSet<BrokerStatus> sharedCandidates)
void	NamespaceIsolationPolicies.assignBroker(NamespaceName nsname, BrokerStatus brkStatus, SortedSet<BrokerStatus> primaryCandidates, SortedSet<BrokerStatus> secondaryCandidates, SortedSet<BrokerStatus> sharedCandidates)
SortedSet<BrokerStatus>	NamespaceIsolationPolicyImpl.getAvailablePrimaryBrokers(SortedSet<BrokerStatus> primaryCandidates)
boolean	NamespaceIsolationPolicyImpl.shouldFailover(SortedSet<BrokerStatus> brokerStatus)
boolean	MinAvailablePolicy.shouldFailoverToSecondary(SortedSet<BrokerStatus> primaryCandidates)
boolean	NamespaceIsolationPolicyImpl.shouldFallback(SortedSet<BrokerStatus> primaryBrokers)