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

Class MinAvailablePolicy

java.lang.Object

org.apache.pulsar.common.policies.AutoFailoverPolicy

org.apache.pulsar.common.policies.impl.MinAvailablePolicy

public class MinAvailablePolicy
extends AutoFailoverPolicy

Implementation of min available policy.

Field Summary

Fields

Modifier and Type	Field	Description
int	min_limit
int	usage_threshold

Constructor Summary

Constructors

Constructor	Description
MinAvailablePolicy(AutoFailoverPolicyData policyData)

Method Summary

Modifier and Type	Method	Description
boolean	isBrokerAvailable(BrokerStatus brokerStatus)	Determine whether a broker is considered available or not.
boolean	shouldFailoverToSecondary(int totalPrimaryCandidates)
boolean	shouldFailoverToSecondary(SortedSet<BrokerStatus> primaryCandidates)	Checks to see whether the new namespace ownership should be failed over to the secondary brokers.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

min_limit

public int min_limit

usage_threshold

public int usage_threshold

Constructor Details

MinAvailablePolicy

public MinAvailablePolicy(AutoFailoverPolicyData policyData)

Method Details

isBrokerAvailable

public boolean isBrokerAvailable(BrokerStatus brokerStatus)

Description copied from class: AutoFailoverPolicy

Determine whether a broker is considered available or not.

Specified by:

isBrokerAvailable in class AutoFailoverPolicy

Parameters:

brokerStatus -

Returns:

shouldFailoverToSecondary

public boolean shouldFailoverToSecondary(SortedSet<BrokerStatus> primaryCandidates)

Description copied from class: AutoFailoverPolicy

Checks to see whether the new namespace ownership should be failed over to the secondary brokers.

Specified by:

shouldFailoverToSecondary in class AutoFailoverPolicy

Parameters:

primaryCandidates -

Returns:

shouldFailoverToSecondary

public boolean shouldFailoverToSecondary(int totalPrimaryCandidates)

Specified by:

shouldFailoverToSecondary in class AutoFailoverPolicy