Package com.tangosol.net

Class ConfigurableQuorumPolicy

java.lang.Object

com.tangosol.util.Base

com.tangosol.net.ConfigurableQuorumPolicy

All Implemented Interfaces:

ActionPolicy

Direct Known Subclasses:

ConfigurableQuorumPolicy.ClusterQuorumPolicy, ConfigurableQuorumPolicy.MembershipQuorumPolicy

public abstract class ConfigurableQuorumPolicy
extends Base
implements ActionPolicy

ConfigurableQuorumPolicy provides a Quorum-based ActionPolicy for services based on the cluster-configuration.

Since:

Coherence 3.6

Author:

rhl 2009.05.07

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConfigurableQuorumPolicy.ClusterQuorumPolicy	ClusterQuorumPolicy defines an action policy that is applicable to the cluster.
static class	ConfigurableQuorumPolicy.MembershipQuorumPolicy	MembershipQuorumPolicy is a quorum policy that is stateless and based solely on service membership sizes.
static class	ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy	PartitionedCacheQuorumPolicy defines a configurable quorum policy that is applicable to a DistributedCacheService.
static class	ConfigurableQuorumPolicy.ProxyQuorumPolicy	ProxyQuorumPolicy defines a configurable quorum policy that is applicable to a proxy service.

Nested classes/interfaces inherited from class com.tangosol.util.Base

Base.LoggingWriter

Field Summary

Fields inherited from class com.tangosol.util.Base

DEFAULT_LOAD_FACTOR, LOG_ALWAYS, LOG_CONFIG, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConfigurableQuorumPolicy()	Create a ConfigurableQuorumPolicy.

Method Summary

Modifier and Type	Method	Description
abstract String	getStatusDescription()	Return a String that describes the current Quorum state.
static ConfigurableQuorumPolicy.ClusterQuorumPolicy	instantiateClusterPolicy(Map<String,Integer> mapQuorum)	Instantiate an action policy for the a cluster service.
static ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy	instantiatePartitionedCachePolicy(ConfigurableQuorumPolicy.MembershipQuorumPolicy.QuorumRule[] aRule, AddressProvider provider)	Instantiate an action policy for a PartitionedCache service.
static ConfigurableQuorumPolicy.ProxyQuorumPolicy	instantiateProxyPolicy(ConfigurableQuorumPolicy.MembershipQuorumPolicy.QuorumRule[] aRule)	Instantiate an action policy for the a proxy service.

Methods inherited from class com.tangosol.util.Base

azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, mod, mod, newHashMap, newHashMap, newHashSet, newHashSet, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.tangosol.net.ActionPolicy

init, isAllowed, toString

Constructor Detail

ConfigurableQuorumPolicy

protected ConfigurableQuorumPolicy()

Create a ConfigurableQuorumPolicy.

Method Detail

getStatusDescription

public abstract String getStatusDescription()

Return a String that describes the current Quorum state.

Returns:

a String describing the allowed actions in the current state

instantiatePartitionedCachePolicy

public static ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy instantiatePartitionedCachePolicy(ConfigurableQuorumPolicy.MembershipQuorumPolicy.QuorumRule[] aRule,
                                                                                                      AddressProvider provider)

Instantiate an action policy for a PartitionedCache service.

Parameters:

aRule - the quorum rule to be used for this policy

provider - the address-provider for recovery addresses

Returns:

an action policy for a PartitionedCache service

instantiateProxyPolicy

public static ConfigurableQuorumPolicy.ProxyQuorumPolicy instantiateProxyPolicy(ConfigurableQuorumPolicy.MembershipQuorumPolicy.QuorumRule[] aRule)

Instantiate an action policy for the a proxy service.

Parameters:

aRule - the quorum rule to be used for this policy

Returns:

an action policy for a Proxy service

instantiateClusterPolicy

public static ConfigurableQuorumPolicy.ClusterQuorumPolicy instantiateClusterPolicy(Map<String,Integer> mapQuorum)

Instantiate an action policy for the a cluster service.

Parameters:

mapQuorum - the map of quorum count keyed by member role.

Returns:

an action policy for the cluster