public class EnterpriseNodeExtension
extends com.hazelcast.instance.DefaultNodeExtension
implements com.hazelcast.instance.NodeExtension, com.hazelcast.internal.metrics.MetricsProvider
| Constructor and Description |
|---|
EnterpriseNodeExtension(com.hazelcast.instance.Node node) |
| Modifier and Type | Method and Description |
|---|---|
void |
afterStart() |
void |
beforeJoin() |
void |
beforeShutdown() |
void |
beforeStart() |
protected void |
createAndSetPhoneHome() |
com.hazelcast.internal.networking.ChannelInitializerProvider |
createChannelInitializerProvider(com.hazelcast.nio.IOService ioService) |
com.hazelcast.internal.dynamicconfig.DynamicConfigListener |
createDynamicConfigListener() |
Map<String,Object> |
createExtensionServices() |
com.hazelcast.internal.networking.InboundHandler[] |
createInboundHandlers(com.hazelcast.instance.EndpointQualifier qualifier,
com.hazelcast.nio.tcp.TcpIpConnection connection,
com.hazelcast.nio.IOService ioService) |
com.hazelcast.internal.jmx.ManagementService |
createJMXManagementService(com.hazelcast.instance.HazelcastInstanceImpl instance) |
String |
createMemberUuid(com.hazelcast.nio.Address address) |
com.hazelcast.util.ByteArrayProcessor |
createMulticastInputProcessor(com.hazelcast.nio.IOService ioService) |
com.hazelcast.util.ByteArrayProcessor |
createMulticastOutputProcessor(com.hazelcast.nio.IOService ioService) |
com.hazelcast.internal.networking.OutboundHandler[] |
createOutboundHandlers(com.hazelcast.instance.EndpointQualifier qualifier,
com.hazelcast.nio.tcp.TcpIpConnection connection,
com.hazelcast.nio.IOService ioService) |
com.hazelcast.internal.serialization.InternalSerializationService |
createSerializationService() |
<T> T |
createService(Class<T> clazz) |
com.hazelcast.internal.ascii.TextCommandService |
createTextCommandService() |
com.hazelcast.internal.management.TimedMemberStateFactory |
createTimedMemberStateFactory(com.hazelcast.instance.HazelcastInstanceImpl instance) |
com.hazelcast.hotrestart.HotRestartService |
getHotRestartService() |
com.hazelcast.hotrestart.InternalHotRestartService |
getInternalHotRestartService() |
com.hazelcast.license.domain.License |
getLicense() |
com.hazelcast.internal.management.ManagementCenterConnectionFactory |
getManagementCenterConnectionFactory() |
com.hazelcast.memory.HazelcastMemoryManager |
getMemoryManager() |
com.hazelcast.memory.MemoryStats |
getMemoryStats() |
com.hazelcast.security.SecurityContext |
getSecurityContext() |
com.hazelcast.security.SecurityService |
getSecurityService() |
com.hazelcast.nio.MemberSocketInterceptor |
getSocketInterceptor(com.hazelcast.instance.EndpointQualifier endpointQualifier) |
boolean |
isClientFailoverSupported() |
boolean |
isFeatureEnabledForLicenseKey(com.hazelcast.license.domain.Feature feature) |
boolean |
isHotRestartEnabled() |
boolean |
isNodeVersionCompatibleWith(com.hazelcast.version.Version clusterVersion)
Check if this node's version is compatible with given cluster version.
|
boolean |
isStartCompleted() |
void |
onClusterStateChange(com.hazelcast.cluster.ClusterState newState,
boolean isTransient) |
void |
onClusterVersionChange(com.hazelcast.version.Version newVersion) |
void |
onInitialClusterState(com.hazelcast.cluster.ClusterState initialState) |
void |
onMemberListChange() |
void |
onPartitionStateChange() |
void |
onThreadStart(Thread thread) |
void |
onThreadStop(Thread thread) |
void |
printNodeInfo() |
void |
provideMetrics(com.hazelcast.internal.metrics.MetricsRegistry registry) |
boolean |
registerListener(Object listener) |
void |
registerPlugins(com.hazelcast.internal.diagnostics.Diagnostics diagnostics) |
void |
scheduleClusterVersionAutoUpgrade() |
void |
setLicenseKey(String licenseKey) |
void |
shutdown() |
void |
validateJoinRequest(com.hazelcast.internal.cluster.impl.JoinMessage joinRequest) |
afterClusterStateChange, beforeClusterStateChange, getPartitioningStrategy, sendPhoneHomepublic EnterpriseNodeExtension(com.hazelcast.instance.Node node)
public void beforeStart()
beforeStart in interface com.hazelcast.instance.NodeExtensionbeforeStart in class com.hazelcast.instance.DefaultNodeExtensionpublic void setLicenseKey(String licenseKey)
setLicenseKey in class com.hazelcast.instance.DefaultNodeExtensionpublic void beforeJoin()
beforeJoin in interface com.hazelcast.instance.NodeExtensionbeforeJoin in class com.hazelcast.instance.DefaultNodeExtensionpublic void printNodeInfo()
printNodeInfo in interface com.hazelcast.instance.NodeExtensionprintNodeInfo in class com.hazelcast.instance.DefaultNodeExtensionpublic void afterStart()
afterStart in interface com.hazelcast.instance.NodeExtensionafterStart in class com.hazelcast.instance.DefaultNodeExtensionpublic boolean isStartCompleted()
isStartCompleted in interface com.hazelcast.instance.NodeExtensionisStartCompleted in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.license.domain.License getLicense()
public com.hazelcast.internal.serialization.InternalSerializationService createSerializationService()
createSerializationService in interface com.hazelcast.instance.NodeExtensioncreateSerializationService in class com.hazelcast.instance.DefaultNodeExtensionpublic void scheduleClusterVersionAutoUpgrade()
scheduleClusterVersionAutoUpgrade in interface com.hazelcast.instance.NodeExtensionscheduleClusterVersionAutoUpgrade in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.security.SecurityContext getSecurityContext()
getSecurityContext in interface com.hazelcast.instance.NodeExtensiongetSecurityContext in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.security.SecurityService getSecurityService()
getSecurityService in interface com.hazelcast.instance.NodeExtensiongetSecurityService in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.nio.MemberSocketInterceptor getSocketInterceptor(com.hazelcast.instance.EndpointQualifier endpointQualifier)
getSocketInterceptor in interface com.hazelcast.instance.NodeExtensiongetSocketInterceptor in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.internal.networking.InboundHandler[] createInboundHandlers(com.hazelcast.instance.EndpointQualifier qualifier,
com.hazelcast.nio.tcp.TcpIpConnection connection,
com.hazelcast.nio.IOService ioService)
createInboundHandlers in interface com.hazelcast.instance.NodeExtensioncreateInboundHandlers in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.internal.networking.OutboundHandler[] createOutboundHandlers(com.hazelcast.instance.EndpointQualifier qualifier,
com.hazelcast.nio.tcp.TcpIpConnection connection,
com.hazelcast.nio.IOService ioService)
createOutboundHandlers in interface com.hazelcast.instance.NodeExtensioncreateOutboundHandlers in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.internal.networking.ChannelInitializerProvider createChannelInitializerProvider(com.hazelcast.nio.IOService ioService)
createChannelInitializerProvider in interface com.hazelcast.instance.NodeExtensioncreateChannelInitializerProvider in class com.hazelcast.instance.DefaultNodeExtensionpublic void onThreadStart(Thread thread)
onThreadStart in interface com.hazelcast.instance.NodeExtensiononThreadStart in class com.hazelcast.instance.DefaultNodeExtensionpublic void onThreadStop(Thread thread)
onThreadStop in interface com.hazelcast.instance.NodeExtensiononThreadStop in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.hotrestart.InternalHotRestartService getInternalHotRestartService()
getInternalHotRestartService in interface com.hazelcast.instance.NodeExtensiongetInternalHotRestartService in class com.hazelcast.instance.DefaultNodeExtensionpublic boolean isHotRestartEnabled()
public boolean isFeatureEnabledForLicenseKey(com.hazelcast.license.domain.Feature feature)
public void beforeShutdown()
beforeShutdown in interface com.hazelcast.instance.NodeExtensionbeforeShutdown in class com.hazelcast.instance.DefaultNodeExtensionpublic void shutdown()
shutdown in interface com.hazelcast.instance.NodeExtensionshutdown in class com.hazelcast.instance.DefaultNodeExtensionpublic <T> T createService(Class<T> clazz)
createService in interface com.hazelcast.instance.NodeExtensioncreateService in class com.hazelcast.instance.DefaultNodeExtensionpublic Map<String,Object> createExtensionServices()
createExtensionServices in interface com.hazelcast.instance.NodeExtensioncreateExtensionServices in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.memory.MemoryStats getMemoryStats()
getMemoryStats in interface com.hazelcast.instance.NodeExtensiongetMemoryStats in class com.hazelcast.instance.DefaultNodeExtensionpublic void validateJoinRequest(com.hazelcast.internal.cluster.impl.JoinMessage joinRequest)
validateJoinRequest in interface com.hazelcast.instance.NodeExtensionvalidateJoinRequest in class com.hazelcast.instance.DefaultNodeExtensionpublic boolean isNodeVersionCompatibleWith(com.hazelcast.version.Version clusterVersion)
E.g.: 3.8 does not support any emulation at all. So it's compatible with 3.8 clusters only. 3.9 will be compatible with 3.8 and 3.9 cluster -> if not overwritten in 3.9 codebase.
isNodeVersionCompatibleWith in interface com.hazelcast.instance.NodeExtensionisNodeVersionCompatibleWith in class com.hazelcast.instance.DefaultNodeExtensionclusterVersion - the cluster version to check againsttrue if compatible, otherwise false.public void onInitialClusterState(com.hazelcast.cluster.ClusterState initialState)
onInitialClusterState in interface com.hazelcast.instance.NodeExtensiononInitialClusterState in class com.hazelcast.instance.DefaultNodeExtensionpublic void onClusterStateChange(com.hazelcast.cluster.ClusterState newState,
boolean isTransient)
onClusterStateChange in interface com.hazelcast.instance.NodeExtensiononClusterStateChange in class com.hazelcast.instance.DefaultNodeExtensionpublic void onPartitionStateChange()
onPartitionStateChange in interface com.hazelcast.instance.NodeExtensiononPartitionStateChange in class com.hazelcast.instance.DefaultNodeExtensionpublic void onMemberListChange()
onMemberListChange in interface com.hazelcast.instance.NodeExtensiononMemberListChange in class com.hazelcast.instance.DefaultNodeExtensionpublic void onClusterVersionChange(com.hazelcast.version.Version newVersion)
onClusterVersionChange in interface com.hazelcast.instance.NodeExtensiononClusterVersionChange in class com.hazelcast.instance.DefaultNodeExtensionpublic boolean registerListener(Object listener)
registerListener in interface com.hazelcast.instance.NodeExtensionregisterListener in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.memory.HazelcastMemoryManager getMemoryManager()
public com.hazelcast.hotrestart.HotRestartService getHotRestartService()
getHotRestartService in interface com.hazelcast.instance.NodeExtensiongetHotRestartService in class com.hazelcast.instance.DefaultNodeExtensionpublic String createMemberUuid(com.hazelcast.nio.Address address)
createMemberUuid in interface com.hazelcast.instance.NodeExtensioncreateMemberUuid in class com.hazelcast.instance.DefaultNodeExtensionpublic void provideMetrics(com.hazelcast.internal.metrics.MetricsRegistry registry)
provideMetrics in interface com.hazelcast.internal.metrics.MetricsProviderpublic com.hazelcast.internal.management.TimedMemberStateFactory createTimedMemberStateFactory(com.hazelcast.instance.HazelcastInstanceImpl instance)
createTimedMemberStateFactory in interface com.hazelcast.instance.NodeExtensioncreateTimedMemberStateFactory in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.internal.management.ManagementCenterConnectionFactory getManagementCenterConnectionFactory()
getManagementCenterConnectionFactory in interface com.hazelcast.instance.NodeExtensiongetManagementCenterConnectionFactory in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.util.ByteArrayProcessor createMulticastInputProcessor(com.hazelcast.nio.IOService ioService)
createMulticastInputProcessor in interface com.hazelcast.instance.NodeExtensioncreateMulticastInputProcessor in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.util.ByteArrayProcessor createMulticastOutputProcessor(com.hazelcast.nio.IOService ioService)
createMulticastOutputProcessor in interface com.hazelcast.instance.NodeExtensioncreateMulticastOutputProcessor in class com.hazelcast.instance.DefaultNodeExtensionpublic void registerPlugins(com.hazelcast.internal.diagnostics.Diagnostics diagnostics)
registerPlugins in interface com.hazelcast.instance.NodeExtensionregisterPlugins in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.internal.dynamicconfig.DynamicConfigListener createDynamicConfigListener()
createDynamicConfigListener in interface com.hazelcast.instance.NodeExtensioncreateDynamicConfigListener in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.internal.jmx.ManagementService createJMXManagementService(com.hazelcast.instance.HazelcastInstanceImpl instance)
createJMXManagementService in interface com.hazelcast.instance.NodeExtensioncreateJMXManagementService in class com.hazelcast.instance.DefaultNodeExtensionpublic com.hazelcast.internal.ascii.TextCommandService createTextCommandService()
createTextCommandService in interface com.hazelcast.instance.NodeExtensioncreateTextCommandService in class com.hazelcast.instance.DefaultNodeExtensionprotected void createAndSetPhoneHome()
createAndSetPhoneHome in class com.hazelcast.instance.DefaultNodeExtensionpublic boolean isClientFailoverSupported()
isClientFailoverSupported in interface com.hazelcast.instance.NodeExtensionisClientFailoverSupported in class com.hazelcast.instance.DefaultNodeExtensionCopyright © 2020 Hazelcast, Inc.. All Rights Reserved.