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