| Package | Description |
|---|---|
| com.tangosol.coherence.dslquery.internal | |
| com.tangosol.net |
Contains basic cluster interfaces and factories.
|
| com.tangosol.net.events.partition |
Contains classes related to PartitionedService events within the Coherence
Live Event Model.
|
| com.tangosol.net.management |
Contains classes related to the Coherence Management Framework.
|
| com.tangosol.net.partition |
Contains interfaces and classes related to partitioned services.
|
| com.tangosol.net.proxy |
Contains interfaces and classes related to proxy services.
|
| com.tangosol.persistence |
Contains classes and helpers for implementing various types of persistence.
|
| com.tangosol.util |
Contains various generic utilities.
|
| Modifier and Type | Method and Description |
|---|---|
String |
PersistenceToolsHelper.getServiceMBean(String sServiceName,
Member member)
Return the Service MBean name.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<Member,T> |
SimpleServiceLoadBalancer.m_mapLoad
A Map of ServiceLoad objects keyed by their associated Member.
|
protected SortedMap<T,List<Member>> |
SimpleServiceLoadBalancer.m_mapMember
A SortedMap of List of Member objects keyed by their associated
ServiceLoad.
|
| Modifier and Type | Method and Description |
|---|---|
Member |
PartitionedService.getBackupOwner(int nPartition,
int nBackup)
Determine the backup owner of the specified partition.
|
Member |
Service.MemberJoinAction.getJoiningMember()
Return the Member that is attempting to join the service.
|
Member |
PartitionedService.getKeyOwner(Object oKey)
Determine the primary owner of the specified key, as determined by the
combination of the KeyPartitioningStrategy and the
PartitionAssignmentStrategy.
|
Member |
OperationalContext.getLocalMember()
Return a Member object representing this process.
|
protected Member |
AbstractServiceLoadBalancer.getLocalMember()
Return the Member object representing the local cluster member.
|
Member |
Cluster.getLocalMember()
Returns a Member object representing the local (i.e. this JVM)
member of the cluster.
|
Member |
NameService.RequestContext.getMember()
Get the client
Member that sent the request. |
Member |
MemberEvent.getMember()
Return the Member associated with this event.
|
Member |
Cluster.getOldestMember()
Returns a Member object representing the senior cluster member.
|
Member |
ServiceInfo.getOldestMember()
Return the "most senior" Member that is running this Service.
|
Member |
PartitionedService.getOwnershipSenior()
Return the senior ownership-enabled member in the service.
|
Member |
PartitionedService.getPartitionOwner(int nPartition)
Determine the primary owner of the specified partition.
|
Member |
ServiceInfo.getServiceMember(int nId)
Return the Member with the specified mini-id that is running
this Service.
|
| Modifier and Type | Method and Description |
|---|---|
List<Member> |
ServiceLoadBalancer.getMemberList(Member client)
Called by the Service when a new client connects to obtain an
ordered list of Members to which the new client should be redirected.
|
List<Member> |
SimpleServiceLoadBalancer.getMemberList(Member client)
Called by the Service when a new client connects to obtain an
ordered list of Members to which the new client should be redirected.
|
Set<Member> |
PartitionedService.getOwnershipEnabledMembers()
Return a Set of Member objects, one for each Member that has registered
this PartitionedService and is partition ownership-enabled.
|
protected Map<String,Set<Member>> |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.groupMembersByRole(Set<Member> setMembers)
Group the specified set of Members by their roles.
|
| Modifier and Type | Method and Description |
|---|---|
List<Member> |
ServiceLoadBalancer.getMemberList(Member client)
Called by the Service when a new client connects to obtain an
ordered list of Members to which the new client should be redirected.
|
List<Member> |
SimpleServiceLoadBalancer.getMemberList(Member client)
Called by the Service when a new client connects to obtain an
ordered list of Members to which the new client should be redirected.
|
PartitionSet |
PartitionedService.getOwnedPartitions(Member member)
Determine the PartitionSet that is currently owned by a cluster Member.
|
String |
ServiceInfo.getServiceVersion(Member member)
Return a String with Service version for the specified
service Member.
|
protected boolean |
AbstractServiceLoadBalancer.isLocalMember(Member member)
Check whether the specified Member object represents the local member
of the cluster.
|
void |
InvocationObserver.memberCompleted(Member member,
Object oResult)
This method is called by the
InvocationService to inform the
InvocationObserver that a member has finished running the
Invocable object; the result of the invocation, if any, is
provided to the InvocationObserver. |
void |
InvocationObserver.memberFailed(Member member,
Throwable eFailure)
This method is called by the
InvocationService to inform the
InvocationObserver that a member has thrown an exception while
running the Invocable object. |
void |
InvocationObserver.memberLeft(Member member)
This method is called by the
InvocationService to inform the
InvocationObserver that a member that the Invocable object was
intended for execution upon has left the service (or the cluster). |
void |
ServiceLoadBalancer.update(Member member,
T load)
Update the load balancing strategy in response to a change in a
Service utilization.
|
void |
SimpleServiceLoadBalancer.update(Member member,
T load)
Update the load balancing strategy in response to a change in a
Service utilization.
|
| Modifier and Type | Method and Description |
|---|---|
protected static int |
ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy.calculateMinimumNodeCount(Set<Member> setMembers)
Given a set of Member objects, calculate the minimum number of nodes
on a single machine.
|
protected boolean |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.checkMachineQuorum(int cQuorum,
Set<Member> setMembers,
Set<Member> setTimedOut,
Set<Member> setHealthy,
Set<Member> setAnnouncing)
Check whether the machine quorum for the specified role will be
satisfied if the set of suspect members is disconnected from the
cluster, given the sets of "healthy" and "announcing" members.
|
protected boolean |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.checkMachineQuorum(int cQuorum,
Set<Member> setMembers,
Set<Member> setTimedOut,
Set<Member> setHealthy,
Set<Member> setAnnouncing)
Check whether the machine quorum for the specified role will be
satisfied if the set of suspect members is disconnected from the
cluster, given the sets of "healthy" and "announcing" members.
|
protected boolean |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.checkMachineQuorum(int cQuorum,
Set<Member> setMembers,
Set<Member> setTimedOut,
Set<Member> setHealthy,
Set<Member> setAnnouncing)
Check whether the machine quorum for the specified role will be
satisfied if the set of suspect members is disconnected from the
cluster, given the sets of "healthy" and "announcing" members.
|
protected boolean |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.checkMachineQuorum(int cQuorum,
Set<Member> setMembers,
Set<Member> setTimedOut,
Set<Member> setHealthy,
Set<Member> setAnnouncing)
Check whether the machine quorum for the specified role will be
satisfied if the set of suspect members is disconnected from the
cluster, given the sets of "healthy" and "announcing" members.
|
protected boolean |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.checkSiteQuorum(int cQuorum,
Set<Member> setMembers,
Set<Member> setTimedOut,
Set<Member> setHealthy,
Set<Member> setAnnouncing)
Check whether the site quorum for the specified role will be
satisfied if the set of suspect members is disconnected from the
cluster, given the sets of "healthy" and "announcing" members.
|
protected boolean |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.checkSiteQuorum(int cQuorum,
Set<Member> setMembers,
Set<Member> setTimedOut,
Set<Member> setHealthy,
Set<Member> setAnnouncing)
Check whether the site quorum for the specified role will be
satisfied if the set of suspect members is disconnected from the
cluster, given the sets of "healthy" and "announcing" members.
|
protected boolean |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.checkSiteQuorum(int cQuorum,
Set<Member> setMembers,
Set<Member> setTimedOut,
Set<Member> setHealthy,
Set<Member> setAnnouncing)
Check whether the site quorum for the specified role will be
satisfied if the set of suspect members is disconnected from the
cluster, given the sets of "healthy" and "announcing" members.
|
protected boolean |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.checkSiteQuorum(int cQuorum,
Set<Member> setMembers,
Set<Member> setTimedOut,
Set<Member> setHealthy,
Set<Member> setAnnouncing)
Check whether the site quorum for the specified role will be
satisfied if the set of suspect members is disconnected from the
cluster, given the sets of "healthy" and "announcing" members.
|
protected Map<String,Set<Member>> |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.groupMembersByRole(Set<Member> setMembers)
Group the specified set of Members by their roles.
|
| Constructor and Description |
|---|
MemberEvent(Object oSource,
int nId,
Member member)
Constructs a new MemberEvent.
|
| Modifier and Type | Method and Description |
|---|---|
Member |
TransferEvent.getLocalMember()
Return the local
Member associated with this transfer
operation. |
Member |
TransferEvent.getRemoteMember()
Return the remote
Member associated with this transfer
operation. |
| Modifier and Type | Method and Description |
|---|---|
String |
Registry.ensureGlobalName(String sName,
Member member)
Convert the passed MBean name to a global name for a given cluster Member
if necessary.
|
| Modifier and Type | Field and Description |
|---|---|
protected Member[] |
SimpleAssignmentStrategy.AnalysisContext.m_aOwnershipMembers
An array of the ownership members to include in the distribution,
arranged in arbitrary order.
|
protected Member |
PartitionEvent.m_memberFrom
The "from" member for events that represent transfer from a member.
|
protected Member |
PartitionEvent.m_memberTo
The "to" member for events that represent transfer to a member.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<Member,PartitionSet[]> |
SimpleAssignmentStrategy.AnalysisContext.m_mapOwnedPartitions
The map of member ownership information for this analysis context.
|
| Modifier and Type | Method and Description |
|---|---|
Member |
PartitionEvent.getFromMember()
Determine the member that held the partitions prior to the action
represented by this event.
|
Member |
DistributionManager.getMember(int nMemberId)
Return the ownership-enabled service member with the specified
mini-id, or null if the member does not exist.
|
protected Member |
SimpleAssignmentStrategy.getMember(int nMemberId)
Return the PartitionedService Member with the specified mini-id.
|
protected Member[] |
SimpleAssignmentStrategy.AnalysisContext.getOwnershipMembersList()
Return an array containing the members across which to distribute the
partition ownership, arranged in arbitrary order.
|
Member |
PartitionEvent.getToMember()
Determine the member that holds the partitions after the action
represented by this event.
|
| Modifier and Type | Method and Description |
|---|---|
protected Map<Member,PartitionSet[]> |
SimpleAssignmentStrategy.collectScheduledDistributions()
Collect the scheduled partition distributions, grouped by the primary owner
and storage index.
|
Set<Member> |
DistributionManager.getOwnershipLeavingMembers()
Return the set of ownership-enabled members in the partitioned
service that are in the process of leaving.
|
Set<Member> |
DistributionManager.getOwnershipMembers()
Return the set of ownership-enabled members in the partitioned service.
|
protected Set<Member> |
SimpleAssignmentStrategy.AnalysisContext.getOwnershipMembers()
Return the set of members across which to distribute the partition
ownership.
|
| Modifier and Type | Method and Description |
|---|---|
protected int |
SimpleAssignmentStrategy.doBalancePrimary(SimpleAssignmentStrategy.AnalysisContext ctx,
Member memberFrom,
PartitionSet parts,
Member[] aMembersTarget)
Do balancing transfers for primary distribution.
|
protected int |
SimpleAssignmentStrategy.doBalancePrimary(SimpleAssignmentStrategy.AnalysisContext ctx,
Member memberFrom,
PartitionSet parts,
Member[] aMembersTarget)
Do balancing transfers for primary distribution.
|
protected int |
SimpleAssignmentStrategy.AnalysisContext.StrengthComparator.getDistance(Member member)
Return the "distance" of the specified member from the reference
ownership.
|
protected int |
SimpleAssignmentStrategy.AnalysisContext.StrengthComparator.getDistance(Member member1,
Member member2)
Return the "distance" between the specified members.
|
protected int |
SimpleAssignmentStrategy.AnalysisContext.getMemberLoad(Member member,
boolean fPrimary)
Return the (primary or backup) partition load of the specified member.
|
PartitionSet |
DistributionManager.getOwnedPartitions(Member member,
int iStore)
Return the set of partitions for which the specified member owns the
specified storage index (replica).
|
PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.getOwnedPartitions(Member member,
int iStore)
Return the set of partitions for which the specified member owns (or
has been assigned by this analysis to own) the specified storage
index.
|
boolean |
SimpleAssignmentStrategy.AnalysisContext.isInitialDistribution(Member memberCoordinator)
Check if the distribution is in the initial state, when the coordinator
owns all the partitions and there are no backups.
|
protected boolean |
SimpleAssignmentStrategy.AnalysisContext.isMemberLeaving(Member member)
Return true iff the specified member is in the process of leaving.
|
protected boolean |
SimpleAssignmentStrategy.AnalysisContext.isStrong(Member member1,
Member member2)
Return true iff the specified members are mutually "strong", as
defined by the backup strength.
|
protected boolean |
SimpleAssignmentStrategy.BackupStrength.isStrong(Member member1,
Member member2)
Return true iff the specified members are mutually "strong".
|
protected boolean |
SimpleAssignmentStrategy.AnalysisContext.isStrong(Member member,
Ownership owners)
Return true iff the specified member is "strong" with respect to the
specified ownership, as defined by the backup strength.
|
protected boolean |
SimpleAssignmentStrategy.AnalysisContext.isTransferStrong(int iPartition,
int iStore,
Member member)
Return true iff the specified partition transfer would result in a
"strong" ownership, as defined by the current BackupStrength.
|
protected void |
SimpleAssignmentStrategy.AnalysisContext.primeDistribution(Member member1,
Member member2)
Set the context to pretend to be the "two servers" membership.
|
protected void |
SimpleAssignmentStrategy.AnalysisContext.transitionPartition(int iPartition,
int iStore,
Member memberFrom,
Member memberTo)
Update the analysis context to reflect the suggested transfer of the
specified number of primary partitions between the specified members.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PartitionAssignmentStrategy.analyzeOrphans(Map<Member,PartitionSet> mapConstraints)
Analyze and suggest the assignment of orphaned partitions (partitions
without an active primary or backup owner) subject to the specified
constraints.
|
void |
SimpleAssignmentStrategy.analyzeOrphans(Map<Member,PartitionSet> mapConstraints)
Analyze and suggest the assignment of orphaned partitions (partitions
without an active primary or backup owner) subject to the specified
constraints.
|
| Constructor and Description |
|---|
PartitionEvent(PartitionedService svc,
int nId,
PartitionSet setPartitions,
Member memberFrom,
Member memberTo)
Construct a partition event.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RemoteMember
A RemoteMember is a special
Member implementation that carries
the remote IP/port information of a member that isn't in the cluster. |
| Modifier and Type | Method and Description |
|---|---|
List<Member> |
DefaultProxyServiceLoadBalancer.getMemberList(Member client) |
| Modifier and Type | Method and Description |
|---|---|
List<Member> |
DefaultProxyServiceLoadBalancer.getMemberList(Member client) |
void |
DefaultProxyServiceLoadBalancer.update(Member member,
ProxyServiceLoad load) |
| Modifier and Type | Field and Description |
|---|---|
protected Map<Member,String[]> |
GUIDHelper.GUIDResolver.f_mapGUID
The Map of registered GUIDs, keyed by member.
|
protected Map<Member,PartitionSet> |
GUIDHelper.GUIDResolver.m_mapResolved
The resolved map of members to the associated set of partitions.
|
| Modifier and Type | Method and Description |
|---|---|
Map<Member,PartitionSet> |
GUIDHelper.GUIDResolver.resolve()
Resolve the registered GUIDs and return a map associating each member
to the set of partitions that it had registered as having the newest
GUID for.
|
| Modifier and Type | Method and Description |
|---|---|
static String |
GUIDHelper.generateGUID(int nPartition,
long lVersion,
long ldt,
Member member)
Generate and return a new GUID for the specified partition.
|
void |
GUIDHelper.GUIDResolver.registerGUIDs(Member member,
String[] asGUID)
Register the specified list of GUIDs from the specified member.
|
| Modifier and Type | Method and Description |
|---|---|
protected static String[] |
GUIDHelper.resolveNewest(Map<Member,String[]> mapGUID,
Set<String> setPrevGUIDs,
int cPartitions)
Return an array of the newest GUID for each partition, indexed by the
partition-id and collect previous GUIDs into the provided set.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NullImplementation.NullPartitionAssignmentStrategy.analyzeOrphans(Map<Member,PartitionSet> mapConstraints)
Analyze and suggest the assignment of orphaned partitions (partitions
without an active primary or backup owner) subject to the specified
constraints.
|