Package com.netflix.discovery

Examples of com.netflix.discovery.DefaultEurekaClientConfig

34
35
36
37
38
39
40
41
42
43
44
    protected void configure() {
        LOG.info("Configuring EurekaModule");
       
                DiscoveryManager.getInstance().initComponent(
                new CloudInstanceConfig(),
                new DefaultEurekaClientConfig());

        // Eureka - Astyanax integration
        MapBinder<String, HostSupplierProvider> hostSuppliers = MapBinder.newMapBinder(binder(), String.class, HostSupplierProvider.class);
        hostSuppliers.addBinding("eureka").to(EurekaAstyanaxHostSupplier.class).asEagerSingleton();
       
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
       
        // Initialize eureka
        // TODO: Move this to a bootstrap thingy
        DiscoveryManager.getInstance().initComponent(
                new CloudInstanceConfig(),
                new DefaultEurekaClientConfig());

        // Eureka - Astyanax integration
        MapBinder<String, HostSupplierProvider> hostSuppliers = MapBinder.newMapBinder(binder(), String.class, HostSupplierProvider.class);
        hostSuppliers.addBinding("eureka").to(EurekaAstyanaxHostSupplier.class);
       
View Full Code Here
51
52
53
54
55
56
57
        new EurekaInstanceDiscovery().getInstanceEvents("api").toBlocking().forEach(i -> System.out.println(i));
    }

    public EurekaInstanceDiscovery() {
        // initialize eureka client.  make sure eureka properties are properly configured in config.properties
        DiscoveryManager.getInstance().initComponent(new MyDataCenterInstanceConfig(), new DefaultEurekaClientConfig());
    }
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
        ConfigurationManager.getConfigInstance().setProperty("eureka.serviceUrl.default",
                                                             "http://localhost:" + mockRemoteEurekaServer.getPort() +
                                                             MockRemoteEurekaServer.EUREKA_API_BASE_PATH);

        client = new DiscoveryClient(builder.build(), new DefaultEurekaClientConfig());
        ApplicationInfoManager.getInstance().initComponent(new MyDataCenterInstanceConfig());
        registry = new PeerAwareInstanceRegistry() {

            @Override
            public boolean isLeaseExpirationEnabled() {
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
        int sleepSeconds = 60; // Application initialization and running simulation time

        // Register with Eureka
        DiscoveryManager.getInstance().initComponent(
                new MyDataCenterInstanceConfig(),
                new DefaultEurekaClientConfig());

        // A good practice is to register as STARTING and only change status to UP
        // after the service is ready to receive traffic
        System.out.println("Registering service to eureka with STARTING status");
        ApplicationInfoManager.getInstance().setInstanceStatus(
View Full Code Here
155
156
157
158
159
160
161
            config = new MyDataCenterInstanceConfig();
        }
        logger.info("Initializing the eureka client...");

        DiscoveryManager.getInstance().initComponent(config,
                new DefaultEurekaClientConfig());
    }
View Full Code Here
20
21
22
23
24
25
26
27
28
29
30
31
   
    @Override
    public synchronized EurekaClientConfig get() {
        if (config == null) {
            if (namespace == null) {
                config = new DefaultEurekaClientConfig();
            } else {
                config = new DefaultEurekaClientConfig(namespace);
            }
        }
        return config;
    }
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
    public void sendRequestToServiceUsingEureka() {
        // Register with Eureka
        DiscoveryManager.getInstance().initComponent(
                new MyDataCenterInstanceConfig(),
                new DefaultEurekaClientConfig());
        ApplicationInfoManager.getInstance().setInstanceStatus(
                InstanceStatus.UP);
        String vipAddress = configInstance.getStringProperty(
                "eureka.vipAddress", "sampleservice.mydomain.net").get();
        InstanceInfo nextServerInfo = DiscoveryManager.getInstance()
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
            Injector injector = LifecycleInjector.builder().createInjector();
            injector.getInstance(LifecycleManager.class).start();

            final EurekaInstanceConfig config = new CloudInstanceConfig("netflix.appinfo.");
            final EurekaClientConfig clientConfig = new DefaultEurekaClientConfig("netflix.discovery.");
            log.info("initializing Eureka");
            DiscoveryManager.getInstance().initComponent(config, clientConfig);

            log.info("initializing EVCache");
            EVCacheClientPoolManager.getInstance().initEVCache("EVCACHE");
View Full Code Here
37
38
39
40
41
42
43
    private final String applicationName;

    public EurekaBasedHostSupplier(String applicationName) {
        this.applicationName = applicationName.toUpperCase();
        // initialize eureka client.  make sure eureka properties are properly configured in config.properties
        DiscoveryManager.getInstance().initComponent(new MyDataCenterInstanceConfig(), new DefaultEurekaClientConfig());
    }
View Full Code Here
TOP

Related Classes of com.netflix.discovery.DefaultEurekaClientConfig

  • com.netflix.astyanax.contrib.eureka.EurekaBasedHostSupplier
  • com.netflix.discovery.providers.DefaultEurekaClientConfigProvider
  • com.netflix.eureka.AbstractTester
  • com.netflix.eureka.EurekaBootStrap
  • com.netflix.eureka.SampleEurekaClient
  • com.netflix.eureka.SampleEurekaService
  • com.netflix.evcache.test.EurekaEVCacheTest
  • com.netflix.genie.common.client.BaseGenieClient
  • com.netflix.paas.cassandra.discovery.EurekaModule
  • com.netflix.staash.cassandra.discovery.EurekaModule
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.