org.kaazing.gateway.server.context.resolve

Class DefaultClusterContext

java.lang.Object

org.kaazing.gateway.server.context.resolve.DefaultClusterContext

All Implemented Interfaces:

com.hazelcast.logging.LogListener, ClusterContext

public class DefaultClusterContext
extends Object
implements ClusterContext, com.hazelcast.logging.LogListener

ClusterContext for KEG

Balancer data

1. HttpBalancerService.MEMBERID_BALANCER_MAP_NAME:
   • List of balanced URIs for one member
   • Key: Cluster member id
   • Value: Map(key: balancerURI, value: acceptURIs)
2. HttpBalancerService.BALANCER_MAP_NAME
   • List of balanced URIs for whole cluster
   • Key: balanceURI
   • Value: acceptURIs

Constructor Summary

Constructors

Constructor and Description
DefaultClusterContext(String name, List<MemberId> interfaces, List<MemberId> members)
DefaultClusterContext(String name, List<MemberId> interfaces, List<MemberId> members, ClusterConnectOptionsContext connectOptions)

Method Summary

Modifier and Type	Method and Description
void	addMembershipEventListener(MembershipEventListener eventListener)
void	dispose()
List<MemberId>	getAccepts()
String	getClusterName()
CollectionsFactory	getCollectionsFactory()
ClusterConnectOptionsContext	getConnectOptions()
List<MemberId>	getConnects()
String	getInstanceKey(MemberId memberId)
MemberId	getLocalMember()
Lock	getLock(String name)
Collection<MemberId>	getMemberIds()
void	log(com.hazelcast.logging.LogEvent logEvent)
void	logClusterState()
void	logClusterStateAtInfoLevel()
void	removeMembershipEventListener(MembershipEventListener eventListener)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultClusterContext

public DefaultClusterContext(String name,
                             List<MemberId> interfaces,
                             List<MemberId> members)

DefaultClusterContext

public DefaultClusterContext(String name,
                             List<MemberId> interfaces,
                             List<MemberId> members,
                             ClusterConnectOptionsContext connectOptions)

Method Detail

start

public void start()

Specified by:

start in interface ClusterContext

dispose

public void dispose()

Specified by:

dispose in interface ClusterContext

getLocalMember

public MemberId getLocalMember()

Specified by:

getLocalMember in interface ClusterContext

getMemberIds

public Collection<MemberId> getMemberIds()

Specified by:

getMemberIds in interface ClusterContext

getInstanceKey

public String getInstanceKey(MemberId memberId)

Specified by:

getInstanceKey in interface ClusterContext

getLock

public Lock getLock(String name)

Specified by:

getLock in interface ClusterContext

addMembershipEventListener

public void addMembershipEventListener(MembershipEventListener eventListener)

Specified by:

addMembershipEventListener in interface ClusterContext

removeMembershipEventListener

public void removeMembershipEventListener(MembershipEventListener eventListener)

Specified by:

removeMembershipEventListener in interface ClusterContext

getClusterName

public String getClusterName()

Specified by:

getClusterName in interface ClusterContext

getAccepts

public List<MemberId> getAccepts()

Specified by:

getAccepts in interface ClusterContext

getConnects

public List<MemberId> getConnects()

Specified by:

getConnects in interface ClusterContext

getConnectOptions

public ClusterConnectOptionsContext getConnectOptions()

Specified by:

getConnectOptions in interface ClusterContext

logClusterState

public void logClusterState()

Specified by:

logClusterState in interface ClusterContext

logClusterStateAtInfoLevel

public void logClusterStateAtInfoLevel()

Specified by:

logClusterStateAtInfoLevel in interface ClusterContext

getCollectionsFactory

public CollectionsFactory getCollectionsFactory()

Specified by:

getCollectionsFactory in interface ClusterContext

log

public void log(com.hazelcast.logging.LogEvent logEvent)

Specified by:

log in interface com.hazelcast.logging.LogListener