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 Member-to-member address only.
ClientEngine	clientEngine
ClusterServiceImpl	clusterService
DynamicConfigurationAwareConfig	config
DiscoveryService	discoveryService
HazelcastInstanceImpl	hazelcastInstance
LoggingServiceImpl	loggingService
MulticastService	multicastService
NetworkingService	networkingService
NodeEngineImpl	nodeEngine
InternalPartitionServiceImpl	partitionService
SecurityContext	securityContext
TextCommandService	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, List<DiscoveryStrategyConfig> aliasedDiscoveryConfigs, Member localMember)
JoinRequest	createJoinRequest(boolean withCredentials)
SplitBrainJoinMessage	createSplitBrainJoinMessage()
BuildInfo	getBuildInfo()
ClientEngine	getClientEngine()
ClusterServiceImpl	getClusterService()
Config	getConfig()
ClassLoader	getConfigClassLoader()
DiscoveryService	getDiscoveryService()
EndpointManager	getEndpointManager()
<T extends Connection> EndpointManager<T>	getEndpointManager(EndpointQualifier qualifier)
Joiner	getJoiner()
MemberImpl	getLocalMember()
ILogger	getLogger(Class clazz)
ILogger	getLogger(String name)
LoggingService	getLoggingService()
ManagementCenterService	getManagementCenterService()
Address	getMasterAddress()
NetworkingService	getNetworkingService()
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.
boolean	setShuttingDown()
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 DynamicConfigurationAwareConfig config

nodeEngine

public final NodeEngineImpl nodeEngine

clientEngine

public final ClientEngine clientEngine

partitionService

public final InternalPartitionServiceImpl partitionService

clusterService

public final ClusterServiceImpl clusterService

multicastService

public final MulticastService multicastService

discoveryService

public final DiscoveryService discoveryService

textCommandService

public final TextCommandService textCommandService

loggingService

public final LoggingServiceImpl loggingService

networkingService

public final NetworkingService networkingService

address

public final Address address

Member-to-member address only. When the Node is configured with multiple endpoints, this address still represents ProtocolType.MEMBER For accessing a full address-map, see AddressPicker.getPublicAddressMap()

securityContext

public final SecurityContext securityContext

Constructor Detail

Node

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

Method Detail

createDiscoveryService

public DiscoveryService createDiscoveryService(DiscoveryConfig discoveryConfig,
                                               List<DiscoveryStrategyConfig> aliasedDiscoveryConfigs,
                                               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)

setShuttingDown

public boolean setShuttingDown()

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.

getLoggingService

public LoggingService getLoggingService()

getLogger

public ILogger getLogger(String name)

getLogger

public ILogger getLogger(Class clazz)

getProperties

public HazelcastProperties getProperties()

getTextCommandService

public TextCommandService getTextCommandService()

getNetworkingService

public NetworkingService getNetworkingService()

getEndpointManager

public EndpointManager getEndpointManager()

getEndpointManager

public <T extends Connection> EndpointManager<T> getEndpointManager(EndpointQualifier qualifier)

getConfigClassLoader

public ClassLoader getConfigClassLoader()

getNodeEngine

public NodeEngineImpl getNodeEngine()

getClientEngine

public ClientEngine getClientEngine()

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()