com.hazelcast.instance

Class Node

java.lang.Object

com.hazelcast.instance.Node

@PrivateApi
public class Node
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Node.NodeShutdownHookThread

Field Summary

Fields

Modifier and Type	Field and Description
Address	address
ClientEngineImpl	clientEngine
ClusterServiceImpl	clusterService
Config	config
ConnectionManager	connectionManager
DiscoveryService	discoveryService
HazelcastInstanceImpl	hazelcastInstance
LoggingServiceImpl	loggingService
MulticastService	multicastService
NodeEngineImpl	nodeEngine
InternalPartitionServiceImpl	partitionService
SecurityContext	securityContext
TextCommandServiceImpl	textCommandService

Constructor Summary

Constructors

Constructor and Description
Node(HazelcastInstanceImpl hazelcastInstance, Config staticConfig, NodeContext nodeContext)

Method Summary

Modifier and Type	Method and Description
void	changeNodeStateToActive()
void	changeNodeStateToPassive()
ConfigCheck	createConfigCheck()
DiscoveryService	createDiscoveryService(DiscoveryConfig discoveryConfig, Member localMember)
JoinRequest	createJoinRequest(boolean withCredentials)
SplitBrainJoinMessage	createSplitBrainJoinMessage()
BuildInfo	getBuildInfo()
ClusterServiceImpl	getClusterService()
Config	getConfig()
ClassLoader	getConfigClassLoader()
ConnectionManager	getConnectionManager()
DiscoveryService	getDiscoveryService()
Joiner	getJoiner()
MemberImpl	getLocalMember()
ILogger	getLogger(Class clazz)
ILogger	getLogger(String name)
ManagementCenterService	getManagementCenterService()
Address	getMasterAddress()
NodeEngineImpl	getNodeEngine()
NodeExtension	getNodeExtension()
InternalPartitionService	getPartitionService()
HazelcastProperties	getProperties()
SecurityService	getSecurityService()
InternalSerializationService	getSerializationService()
NodeState	getState() Returns the node state.
TextCommandService	getTextCommandService()
Address	getThisAddress()
String	getThisUuid()
MemberVersion	getVersion() Returns the codebase version of the node.
boolean	isLiteMember()
boolean	isMaster()
boolean	isRunning() Indicates that node is not shutting down or it has not already shut down
void	join()
void	reset() Resets the internal cluster-state of the Node to be able to make it ready to join a new cluster.
void	shutdown(boolean terminate)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

hazelcastInstance

public final HazelcastInstanceImpl hazelcastInstance

config

public final Config config

nodeEngine

public final NodeEngineImpl nodeEngine

clientEngine

public final ClientEngineImpl clientEngine

partitionService

public final InternalPartitionServiceImpl partitionService

clusterService

public final ClusterServiceImpl clusterService

multicastService

public final MulticastService multicastService

discoveryService

public final DiscoveryService discoveryService

textCommandService

public final TextCommandServiceImpl textCommandService

loggingService

public final LoggingServiceImpl loggingService

connectionManager

public final ConnectionManager connectionManager

address

public final Address address

securityContext

public final SecurityContext securityContext

Constructor Detail

Node

public Node(HazelcastInstanceImpl hazelcastInstance,
            Config staticConfig,
            NodeContext nodeContext)

Method Detail

createDiscoveryService

public DiscoveryService createDiscoveryService(DiscoveryConfig discoveryConfig,
                                               Member localMember)

getManagementCenterService

public ManagementCenterService getManagementCenterService()

getSerializationService

public InternalSerializationService getSerializationService()

getClusterService

public ClusterServiceImpl getClusterService()

getPartitionService

public InternalPartitionService getPartitionService()

getMasterAddress

public Address getMasterAddress()

getThisAddress

public Address getThisAddress()

getLocalMember

public MemberImpl getLocalMember()

isMaster

public boolean isMaster()

getSecurityService

public SecurityService getSecurityService()

shutdown

public void shutdown(boolean terminate)

isRunning

public boolean isRunning()

Indicates that node is not shutting down or it has not already shut down

Returns:

true if node is not shutting down or it has not already shut down

changeNodeStateToActive

public void changeNodeStateToActive()

changeNodeStateToPassive

public void changeNodeStateToPassive()

reset

public void reset()

Resets the internal cluster-state of the Node to be able to make it ready to join a new cluster. After this method is called, a new join process can be triggered by calling join().

This method is called during merge process after a split-brain is detected.

getLogger

public ILogger getLogger(String name)

getLogger

public ILogger getLogger(Class clazz)

getProperties

public HazelcastProperties getProperties()

getTextCommandService

public TextCommandService getTextCommandService()

getConnectionManager

public ConnectionManager getConnectionManager()

getConfigClassLoader

public ClassLoader getConfigClassLoader()

getNodeEngine

public NodeEngineImpl getNodeEngine()

getNodeExtension

public NodeExtension getNodeExtension()

getDiscoveryService

public DiscoveryService getDiscoveryService()

createSplitBrainJoinMessage

public SplitBrainJoinMessage createSplitBrainJoinMessage()

createJoinRequest

public JoinRequest createJoinRequest(boolean withCredentials)

createConfigCheck

public ConfigCheck createConfigCheck()

join

public void join()

getJoiner

public Joiner getJoiner()

getThisUuid

public String getThisUuid()

getConfig

public Config getConfig()

getState

public NodeState getState()

Returns the node state.

Returns:

current state of the node

getVersion

public MemberVersion getVersion()

Returns the codebase version of the node.

Returns:

codebase version of the node

isLiteMember

public boolean isLiteMember()

toString

public String toString()

Overrides:

toString in class Object

getBuildInfo

public BuildInfo getBuildInfo()