com.hazelcast.kubernetes

Class HazelcastKubernetesDiscoveryStrategyFactory

java.lang.Object

com.hazelcast.kubernetes.HazelcastKubernetesDiscoveryStrategyFactory

All Implemented Interfaces:

DiscoveryStrategyFactory

public class HazelcastKubernetesDiscoveryStrategyFactory
extends Object
implements DiscoveryStrategyFactory

Just the factory to create the Kubernetes Discovery Strategy

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.spi.discovery.DiscoveryStrategyFactory

DiscoveryStrategyFactory.DiscoveryStrategyLevel

Constructor Summary

Constructors

Constructor and Description
HazelcastKubernetesDiscoveryStrategyFactory()

Method Summary

Modifier and Type	Method and Description
DiscoveryStrategyFactory.DiscoveryStrategyLevel	discoveryStrategyLevel() Level of the discovery strategy.
Collection<PropertyDefinition>	getConfigurationProperties() Returns a set of the expected configuration properties.
Class<? extends DiscoveryStrategy>	getDiscoveryStrategyType() Returns the type of the DiscoveryStrategy itself.
boolean	isAutoDetectionApplicable() In all Kubernetes environments the file "/var/run/secrets/kubernetes.io/serviceaccount/token" is injected into the container.
DiscoveryStrategy	newDiscoveryStrategy(DiscoveryNode discoveryNode, ILogger logger, Map<String,Comparable> properties) Instantiates a new instance of the DiscoveryStrategy with the given configuration properties.

Methods inherited from class java.lang.Object

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

Constructor Detail

HazelcastKubernetesDiscoveryStrategyFactory

public HazelcastKubernetesDiscoveryStrategyFactory()

Method Detail

getDiscoveryStrategyType

public Class<? extends DiscoveryStrategy> getDiscoveryStrategyType()

Description copied from interface: DiscoveryStrategyFactory

Returns the type of the DiscoveryStrategy itself.

Specified by:

getDiscoveryStrategyType in interface DiscoveryStrategyFactory

Returns:

the type of the discovery strategy

newDiscoveryStrategy

public DiscoveryStrategy newDiscoveryStrategy(DiscoveryNode discoveryNode,
                                              ILogger logger,
                                              Map<String,Comparable> properties)

Description copied from interface: DiscoveryStrategyFactory

Instantiates a new instance of the DiscoveryStrategy with the given configuration properties. The provided HazelcastInstance can be used to register instances in a service registry whenever the discovery strategy is started.

Specified by:

newDiscoveryStrategy in interface DiscoveryStrategyFactory

Parameters:

discoveryNode - the current local DiscoveryNode, representing the local connection information if running on a Hazelcast member, otherwise on Hazelcast clients always null

logger - the logger instance

properties - the properties parsed from the configuration

Returns:

a new instance of the discovery strategy

getConfigurationProperties

public Collection<PropertyDefinition> getConfigurationProperties()

Description copied from interface: DiscoveryStrategyFactory

Returns a set of the expected configuration properties. These properties contain information about the value type of the property, if it is required and a possible validator to automatically test and convert values from the XML configuration.

Specified by:

getConfigurationProperties in interface DiscoveryStrategyFactory

Returns:

a set of expected configuration properties

isAutoDetectionApplicable

public boolean isAutoDetectionApplicable()

In all Kubernetes environments the file "/var/run/secrets/kubernetes.io/serviceaccount/token" is injected into the container. That is why we can use it to verify if this code is run in the Kubernetes environment.

Note that if the Kubernetes environment is not configured correctly, this file my not exist. However, in such case, this plugin won't work anyway, so it makes perfect sense to return false.

Specified by:

isAutoDetectionApplicable in interface DiscoveryStrategyFactory

Returns:

true if running in the Kubernetes environment

discoveryStrategyLevel

public DiscoveryStrategyFactory.DiscoveryStrategyLevel discoveryStrategyLevel()

Description copied from interface: DiscoveryStrategyFactory

Level of the discovery strategy.

Specified by:

discoveryStrategyLevel in interface DiscoveryStrategyFactory