public final class ClusterManager extends BaseManager implements ConnectionListener
Modifier and Type | Class and Description |
---|---|
class |
ClusterManager.AsyncRemotelyBooleanOp |
static class |
ClusterManager.AuthenticationFailureProcessable |
static class |
ClusterManager.MasterConfirmation |
class |
ClusterManager.NoneMemberAsyncRemotelyBooleanOp |
BaseManager.ConnectionAwareOp, BaseManager.ResponseQueueCall, BaseManager.ResponsiveOperationHandler, BaseManager.ReturnResponseProcess, BaseManager.TargetAwareOp
BATCH_OPS_EXECUTOR_NAME, dataMemberCount, INTERNAL_OPS_EXECUTOR_NAME, localIdGen, logger, lsMembers, mapCalls, mapMembers, maxOperationLimit, maxOperationTimeout, node, qServiceThreadPacketCache, redoGiveUpThreshold, redoLogThreshold, redoWaitMillis, responsePollTimeout, systemLogService, thisAddress, thisMember
Constructor and Description |
---|
ClusterManager(Node node) |
addRemoteCall, checkServiceThread, createRemotelyProcessablePacket, createSimpleMapEntry, enqueueAndReturn, enqueueAndWait, enqueueAndWait, getInstanceType, getMasterAddress, getMembers, getNextMemberAfter, getNextMemberAfter, getNode, getPacketProcessor, getRemoteCall, getThisAddress, handleInterruptedException, handleResponse, isActive, isLiteMember, isMaster, isMigrating, logRedo, obtainPacket, obtainPacket, registerPacketProcessor, releasePacket, removeRemoteCall, rethrowException, returnRedoResponse, returnResponse, returnResponse, send, send, sendEvents, sendOrReleasePacket, sendOrReleasePacket, sendProcessableTo, sendProcessableTo, sendProcessableToAll, sendResponse, sendResponse, sendResponseFailure
public ClusterManager(Node node)
public boolean shouldTryMerge()
public JoinInfo checkJoin(Connection conn)
public void appendState(StringBuffer sbState)
public final void heartBeater()
public void sendClusterMergeToOthers(Address newTargetAddress)
public void handleMaster(Master master)
public void handleAddRemoveConnection(AddOrRemoveConnection connection)
public void disconnectExistingCalls(Address deadAddress)
public void onRestart()
public boolean checkAuthorization(String groupName, String groupPassword, Address target)
public void finalizeJoin()
public boolean sendJoinRequest(Address toAddress, boolean withCredentials)
public void registerScheduledAction(ScheduledAction scheduledAction)
public void deregisterScheduledAction(ScheduledAction scheduledAction)
public void checkScheduledActions()
public void invalidateScheduledActionsFor(Address endpoint, Set<Integer> threadIds)
public void connectionAdded(Connection connection)
connectionAdded
in interface ConnectionListener
public void connectionRemoved(Connection connection)
connectionRemoved
in interface ConnectionListener
public Member addMember(MemberImpl member)
public Member addMember(boolean checkServiceThread, MemberImpl member)
public void removeMember(MemberImpl member)
protected MemberImpl createMember(Address address, NodeType nodeType, String nodeUuid, String ipV6ScopeId)
public MemberImpl getMember(Address address)
public final MemberImpl addMember(Address address, NodeType nodeType, String nodeUuid)
public void stop()
Copyright © 2013 Hazelcast, Inc.. All rights reserved.