Java源码示例:com.hazelcast.spi.discovery.DiscoveryStrategy
示例1
@Override
public DiscoveryStrategy newDiscoveryStrategy(
DiscoveryNode discoveryNode,
ILogger logger,
//Implementing DiscoveryStrategyFactory method with a raw type
@SuppressWarnings("rawtypes") Map<String, Comparable> properties
) {
return
new DockerDNSRRDiscoveryStrategy(
logger,
properties
);
}
示例2
@Test
public void createDiscoveryStrategy() {
HashMap<String, Comparable> properties = new HashMap<String, Comparable>();
properties.put(KubernetesProperties.KUBERNETES_API_TOKEN.key(), API_TOKEN);
properties.put(KubernetesProperties.KUBERNETES_CA_CERTIFICATE.key(), CA_CERTIFICATE);
properties.put(String.valueOf(KubernetesProperties.SERVICE_PORT), 333);
properties.put(KubernetesProperties.NAMESPACE.key(), "default");
HazelcastKubernetesDiscoveryStrategyFactory factory = new HazelcastKubernetesDiscoveryStrategyFactory();
DiscoveryStrategy strategy = factory.newDiscoveryStrategy(discoveryNode, LOGGER, properties);
assertTrue(strategy instanceof HazelcastKubernetesDiscoveryStrategy);
strategy.start();
strategy.destroy();
}
示例3
public Class<? extends DiscoveryStrategy> getDiscoveryStrategyType() {
// Returns the actual class type of the DiscoveryStrategy
// implementation, to match it against the configuration
return DockerSwarmDiscoveryStrategy.class;
}
示例4
public DiscoveryStrategy newDiscoveryStrategy(DiscoveryNode discoveryNode,
ILogger logger,
Map<String, Comparable> properties) {
return new DockerSwarmDiscoveryStrategy(discoveryNode, logger, properties);
}
示例5
@Override
public Class<? extends DiscoveryStrategy> getDiscoveryStrategyType() {
return DockerDNSRRDiscoveryStrategy.class;
}
示例6
public Class<? extends DiscoveryStrategy> getDiscoveryStrategyType() {
// Returns the actual class type of the DiscoveryStrategy
// implementation, to match it against the configuration
return ConsulDiscoveryStrategy.class;
}
示例7
public DiscoveryStrategy newDiscoveryStrategy(DiscoveryNode discoveryNode,
ILogger logger,
Map<String, Comparable> properties ) {
return new ConsulDiscoveryStrategy( discoveryNode, logger, properties );
}
示例8
public Class<? extends DiscoveryStrategy> getDiscoveryStrategyType() {
return HazelcastKubernetesDiscoveryStrategy.class;
}
示例9
public DiscoveryStrategy newDiscoveryStrategy(DiscoveryNode discoveryNode, ILogger logger,
Map<String, Comparable> properties) {
return new HazelcastKubernetesDiscoveryStrategy(logger, properties);
}
示例10
@Test
public void checkDiscoveryStrategyType() {
HazelcastKubernetesDiscoveryStrategyFactory factory = new HazelcastKubernetesDiscoveryStrategyFactory();
Class<? extends DiscoveryStrategy> strategyType = factory.getDiscoveryStrategyType();
assertEquals(HazelcastKubernetesDiscoveryStrategy.class.getCanonicalName(), strategyType.getCanonicalName());
}