Package com.netflix.loadbalancer

Examples of com.netflix.loadbalancer.Server

22
23
24
25
26
27
28
29
    }

    @Test
    public void pingFailTest() throws Exception {
        SuroPing ping = new SuroPing();
        Server server = new Server("localhost", 7901);
        assertEquals(false, ping.isAlive(server));
    }
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
    @Inject
    public StaticLoadBalancer(ClientConfig config) {
        List<Server> serverList = new ArrayList<Server>();
        for (String s : config.getLoadBalancerServer().split(",")) {
            String[] host_port = s.split(":");
            serverList.add(new Server(host_port[0], Integer.parseInt(host_port[1])));
        }
        if (serverList.isEmpty()) {
            throw new IllegalArgumentException("empty server list");
        }
View Full Code Here
204
205
206
207
208
209
210
211
212
213
214
        }

        if (config.getEnableOutPool()) {
            synchronized (this) {
                for (int i = 0; i < config.getRetryCount() && connection == null; ++i) {
                    Server server = lb.chooseServer(null);
                    if (server != null) {
                        connection = new SuroConnection(server, config, false);
                        try {
                            connection.connect();
                            ++outPoolSize;
View Full Code Here
233
234
235
236
237
238
239
240
241
242
243
    private SuroConnection chooseFromPool() {
        SuroConnection connection = null;
        int count = 0;

        while (connection == null) {
            Server server = lb.chooseServer(null);
            if (server != null) {
                if (!serverSet.contains(server)) {
                    newConnectionBuilder.execute(createNewConnection(server, true));
                } else {
                    connection = connectionPool.remove(server);
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
77
78
     * @param key can bel null
     * @return
     */
    @Override
    public Server chooseServer(Object key) {
        Server server = super.chooseServer(key);
        if (server == null) {
            return null;
        }
        server.setPort(port);

        return server;
    }
View Full Code Here
TOP

Related Classes of com.netflix.loadbalancer.Server

  • com.emc.vipr.ribbon.SmartClientConfig
  • com.emc.vipr.ribbon.ViPRDataServicesServerList
  • com.emc.vipr.services.s3.ViPRS3Config
  • com.netflix.suro.connection.ConnectionPool
  • com.netflix.suro.connection.EurekaLoadBalancer
  • com.netflix.suro.connection.StaticLoadBalancer
  • com.netflix.suro.connection.TestConnectionPool
  • com.netflix.suro.connection.TestSuroPing
  • feign.ribbon.LoadBalancingTarget
  • halfpipe.consul.loadbalancer.ConsulServerList
    • 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.