org.shoal.ha.mapper
Class DefaultKeyMapper

java.lang.Object
  org.shoal.ha.mapper.DefaultKeyMapper

All Implemented Interfaces:

GroupMemberEventListener, KeyMapper

public class DefaultKeyMapper
extends java.lang.Object
implements KeyMapper, GroupMemberEventListener

Author:

Mahesh Kannan

Constructor Summary

DefaultKeyMapper(java.lang.String myName, java.lang.String groupName)

Method Summary

java.lang.String[]	findReplicaInstance(java.lang.String groupName, java.lang.Object key1, java.lang.String keyMappingInfo)
java.lang.String	getMappedInstance(java.lang.String groupName, java.lang.Object key1)
protected java.lang.String[]	getMembers()
protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock	getReadLock()
protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock	getWriteLock()
void	onViewChange(java.lang.String memberName, java.util.Collection<java.lang.String> readOnlyCurrentAliveAndReadyMembers, java.util.Collection<java.lang.String> readOnlyPreviousAliveAndReadyMembers, boolean isJoinEvent)
void	printMemberStates(java.lang.String message)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultKeyMapper

public DefaultKeyMapper(java.lang.String myName,
                        java.lang.String groupName)

Method Detail

getReadLock

protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock getReadLock()

getWriteLock

protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock getWriteLock()

getMembers

protected java.lang.String[] getMembers()

getMappedInstance

public java.lang.String getMappedInstance(java.lang.String groupName,
                                          java.lang.Object key1)

Specified by:

getMappedInstance in interface KeyMapper

findReplicaInstance

public java.lang.String[] findReplicaInstance(java.lang.String groupName,
                                              java.lang.Object key1,
                                              java.lang.String keyMappingInfo)

Specified by:

findReplicaInstance in interface KeyMapper

onViewChange

public void onViewChange(java.lang.String memberName,
                         java.util.Collection<java.lang.String> readOnlyCurrentAliveAndReadyMembers,
                         java.util.Collection<java.lang.String> readOnlyPreviousAliveAndReadyMembers,
                         boolean isJoinEvent)

Specified by:

onViewChange in interface GroupMemberEventListener

printMemberStates

public void printMemberStates(java.lang.String message)