Examples of LoadBalancingPolicy

com.datastax.driver.core.policies.LoadBalancingPolicy
The policy that decides which Cassandra hosts to contact for each new query.
Two methods need to be implemented:
- {@link LoadBalancingPolicy#distance}: returns the "distance" of an host for that balancing policy.
- {@link LoadBalancingPolicy#newQueryPlan}: it is used for each query to find which host to query first, and which hosts to use as failover.
The {@code LoadBalancingPolicy} is a {@link com.datastax.driver.core.Host.StateListener}and is thus informed of hosts up/down events. For efficiency purposes, the policy is expected to exclude down hosts from query plans.
com.sun.corba.ee.spi.extension.LoadBalancingPolicy
org.jboss.jms.client.plugin.LoadBalancingPolicy
The interface that must be implemented by any load balancing policy plugin. @author Ovidiu Feodorov @version $Revision: 1981 $ $Id: LoadBalancingPolicy.java 1981 2007-01-18 16:12:55Z clebert.suconic@jboss.com $

Examples of com.datastax.driver.core.policies.LoadBalancingPolicy


        if (kmd != null) {
            return when.resolve(kmd);
        }


        LoadBalancingPolicy lbPolicy = session.getCluster().getConfiguration().getPolicies().getLoadBalancingPolicy();
        String dc = null;
        int count = 0;


        for (Host host : metadata.getAllHosts()) {
            if (lbPolicy.distance(host) == HostDistance.LOCAL) {
                dc = host.getDatacenter();
                count++;
            }
        }

View Full Code Here

Examples of com.datastax.driver.core.policies.LoadBalancingPolicy

    public static Cluster getInputCluster(String host, Configuration conf)
    {
        int port = getInputNativePort(conf);
        Optional<AuthProvider> authProvider = getAuthProvider(conf);
        Optional<SSLOptions> sslOptions = getSSLOptions(conf);
        LoadBalancingPolicy loadBalancingPolicy = getReadLoadBalancingPolicy(conf, host);
        SocketOptions socketOptions = getReadSocketOptions(conf);
        QueryOptions queryOptions = getReadQueryOptions(conf);
        PoolingOptions poolingOptions = getReadPoolingOptions(conf);
        
        Cluster.Builder builder = Cluster.builder()

View Full Code Here

Examples of com.datastax.driver.core.policies.LoadBalancingPolicy

        return socketOptions;
    }


    private static LoadBalancingPolicy getReadLoadBalancingPolicy(Configuration conf, final String stickHost)
    {
        return new LoadBalancingPolicy()
        {
            private Host origHost;
            private Set<Host> liveRemoteHosts = Sets.newHashSet();


            @Override

View Full Code Here

Examples of com.datastax.driver.core.policies.LoadBalancingPolicy

        Policies policies = configuration.getPolicies();
        JsonObject policiesJson = new JsonObject();
        json.putObject("policies", policiesJson);


        if (policies != null) {
            LoadBalancingPolicy lbPolicy = policies.getLoadBalancingPolicy();
            policiesJson.putString("load_balancing", lbPolicy == null ? null : lbPolicy.getClass().getSimpleName());
            ReconnectionPolicy reconnectionPolicy = policies.getReconnectionPolicy();
            policiesJson.putString("reconnection", reconnectionPolicy == null ? null : reconnectionPolicy.getClass().getSimpleName());
            RetryPolicy retryPolicy = policies.getRetryPolicy();
            policiesJson.putString("retry", retryPolicy == null ? null : retryPolicy.getClass().getSimpleName());
        }

View Full Code Here

Examples of com.datastax.driver.core.policies.LoadBalancingPolicy

        if (LOGGER.isDebugEnabled()) {
            LOGGER.debug("Creating Cluster object with host/port {}/{} and parameters {}", host, cqlPort, parameters);
        }
        String clusterName = parameters.getTyped(CLUSTER_NAME);
        Compression compression = parameters.getTyped(COMPRESSION_TYPE);
        LoadBalancingPolicy loadBalancingPolicy = parameters.getTyped(LOAD_BALANCING_POLICY);
        RetryPolicy retryPolicy = parameters.getTyped(RETRY_POLICY);
        ReconnectionPolicy reconnectionPolicy = parameters.getTyped(RECONNECTION_POLICY);


        synchronized (this) {
            if (singletonCluster == null) {

View Full Code Here

Examples of com.datastax.driver.core.policies.LoadBalancingPolicy


        // add policy configuration
        String loadBalancingPolicy = connectionProperties.getProperty(Constants.LOADBALANCING_POLICY);
        if (!StringUtils.isBlank(loadBalancingPolicy))
        {
            LoadBalancingPolicy policy = getPolicyInstance(BalancingPolicy.getPolicy(loadBalancingPolicy),
                    connectionProperties);
            if (policy != null)
            {
                connectionBuilder.withLoadBalancingPolicy(policy);
            }

View Full Code Here

Examples of com.datastax.driver.core.policies.LoadBalancingPolicy

    }


    private LoadBalancingPolicy getPolicyInstance(BalancingPolicy policy, Properties conProperties)
    {


        LoadBalancingPolicy loadBalancingPolicy = null;
        String isTokenAware = (String) conProperties.get("isTokenAware");
        String isLatencyAware = (String) conProperties.get("isLatencyAware");
        // Policy.v
        switch (policy)
        {

View Full Code Here

Examples of com.sun.corba.ee.spi.extension.LoadBalancingPolicy

      policies.add(new CopyObjectPolicy(PASS_BY_REFERENCE_ID));
  }


        // Set per-request-load-balancing policy on ejb object references
        if( !home && extraDesc.hasPerRequestLoadBalancing() ) {
            policies.add( new LoadBalancingPolicy(ORBConstants.PER_REQUEST_LOAD_BALANCING));
            logger.log(Level.FINE, "Setting per-request-load-balancing policy " +
                       "for Ejb " + ejbDescriptor.getName());
        }

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

                  delegate = getFailoverDelegateForNode(failedNodeID);
                  failedNodeIDToServer = failedNodeID.intValue();
               }
               else
               {
                  LoadBalancingPolicy loadBalancingPolicy = clusteredDelegate.getLoadBalancingPolicy();
                  delegate = (ClientConnectionFactoryDelegate)loadBalancingPolicy.getNext();
               }
            }


            log.debug(this + " has chosen " + delegate + " as target, " +
               (attemptCount == 0 ? "first connection attempt" : attemptCount + " connection attempts"));

View Full Code Here

Examples of org.jboss.jms.client.plugin.LoadBalancingPolicy

         }


         failoverMap = recalculateFailoverMap(nodeAddressMap.keySet());
      }


      LoadBalancingPolicy lbp = loadBalancingFactory.createLoadBalancingPolicy(delegates);
      return new ClientClusteredConnectionFactoryDelegate(delegates, failoverMap, lbp);
   }

View Full Code Here

0 1 2 3

TOP

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.