Package com.netflix.astyanax.impl

Examples of com.netflix.astyanax.impl.FilteringHostSupplier

613
614
615
616
617
618
619
620
621
622
623
624
625
626
        LOG.info(sourceSupplier1.get().toString());
       
        // 127.0.0.2
        LOG.info(sourceSupplier2.get().toString());
       
        hosts = new FilteringHostSupplier(ringSupplier, sourceSupplier1).get();
        LOG.info(hosts.toString());
       
        Assert.assertEquals(1, hosts.size());
        Assert.assertEquals(1, hosts.get(0).getTokenRanges().size());
        hosts = new FilteringHostSupplier(ringSupplier, sourceSupplier2).get();
        LOG.info(hosts.toString());
        Assert.assertEquals(1, hosts.size());
    }
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
            case TOKEN_AWARE:
                if (hostSupplier == null) {
                    supplier = new RingDescribeHostSupplier(keyspace, cpConfig.getPort(), cpConfig.getLocalDatacenter());
                }
                else {
                    supplier = new FilteringHostSupplier(new RingDescribeHostSupplier(keyspace, cpConfig.getPort(), cpConfig.getLocalDatacenter()),
                            hostSupplier);
                }
                break;

            case NONE:
View Full Code Here
TOP

Related Classes of com.netflix.astyanax.impl.FilteringHostSupplier

  • com.netflix.astyanax.AstyanaxContext$Builder
  • com.netflix.astyanax.connectionpool.Host
  • com.netflix.astyanax.thrift.ThriftKeyspaceImplTest
    • 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.