Package | Description |
---|---|
com.tangosol.coherence.commonj |
Contains Coherence-based WorkManager implementation classes.
|
com.tangosol.coherence.dslquery.internal | |
com.tangosol.coherence.servlet |
Contains classes related to the HTTP Session Replication Module.
|
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 | Field and Description |
---|---|
protected Member |
WorkManager.WorkHolder.m_member
The server Member that is to run the Work.
|
protected Member |
WorkManager.RemoteWorkManager.m_memberPinned
The service Member this RemoteWorkManager is pinned to.
|
Modifier and Type | Method and Description |
---|---|
protected Member |
WorkManager.chooseServer()
Choose a Member to run a next Work at.
|
Member |
WorkManager.AbstractWork.getMember()
Return a Work originator's Member object.
|
Member |
WorkManager.WorkHolder.getTargetMember()
Return the Member that the corresponding Work is to be executed at.
|
Modifier and Type | Method and Description |
---|---|
Map<Member,Map<Long,WorkManager.ScheduleWork>> |
WorkManager.getAcceptedWork()
Return a catalog of accepted ScheduleWork tasks as known by the server side keyed by the origin Member where the value is a map of ScheduleWork tasks keyed by the WorkId.
|
Set<Member> |
WorkManager.getServers()
Return a set of Members that run the same Invocation service as this WorkManager in a "server" capacity.
|
Modifier and Type | Method and Description |
---|---|
void |
WorkManager.disableServer(Member member)
Remove a Member from a list of active server nodes and terminate all work posted to that server.
|
void |
WorkManager.WorkObserver.memberCompleted(Member member, Object oResult)
This method is called when a Member has finished running the ScheduleWork agent.
|
void |
WorkManager.WorkObserver.memberFailed(Member member, Throwable eFailure)
This method is called when a Member has thrown an exception while running the Invocable object.
|
void |
WorkManager.WorkObserver.memberLeft(Member member)
This method is called when a Member that the Invocable} object was intended for execution upon has left the service (or the cluster).
|
protected commonj.work.WorkItem |
WorkManager.schedule(commonj.work.Work work, commonj.work.WorkListener workListener, Member member)
Accepts a Work instance for processing at the specified Member.
|
protected commonj.work.WorkItem |
WorkManager.RemoteWorkManager.schedule(commonj.work.Work work, commonj.work.WorkListener workListener, Member member)
Accepts a Work instance for processing at the specified Member.
|
Constructor and Description |
---|
CollectMembershipInfo(Member memberServer)
Construct the task for a given member server (could be null for a client).
|
RemoteWorkManager(Member memberPinned) |
WorkHolder(long lWorkId, commonj.work.WorkListener listener, InvocationService service, Member member)
Construct a WorkHolder for a Work with a given work id that is scheduled to be executed on a specified service.
|
Modifier and Type | Method and Description |
---|---|
String |
PersistenceToolsHelper.getServiceMBean(String sServiceName, Member member)
Return the Service MBean name.
|
Modifier and Type | Method and Description |
---|---|
protected Member |
AbstractHttpSessionCollection.getSessionOwnershipInfo(String sId)
Determine which cluster member (if any) holds the lock for the given session ID.
|
Modifier and Type | Method and Description |
---|---|
void |
ExitObserver.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 |
ExitObserver.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 |
ExitObserver.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). |
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.
|
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 |
OperationalContext.getLocalMember()
Return a Member object representing this process.
|
Member |
MemberEvent.getMember()
Return the Member associated with this event.
|
Member |
NameService.RequestContext.getMember()
Get the client
Member that sent the request. |
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.
|
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.
|
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 |
---|---|
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.
|