// Path: src/main/java/net/iponweb/disthene/util/CassandraLoadBalancingPolicies.java
// public class CassandraLoadBalancingPolicies {
// 
//     public static final String tokenAwarePolicy = "TokenAwarePolicy";
//     public static final String tokenDcAwareRoundRobinPolicy = "TokenDcAwareRoundRobinPolicy";
//     public static final String tokenLatencyAwarePolicy = "TokenLatencyAwarePolicy";
// 
//     public static LoadBalancingPolicy getLoadBalancingPolicy(String policy) {
//         LoadBalancingPolicy loadBalancingPolicy;
//         switch (policy) {
//             case tokenAwarePolicy:
//                 loadBalancingPolicy = new TokenAwarePolicy(new RoundRobinPolicy());
//                 break;
//             case tokenDcAwareRoundRobinPolicy:
//                 loadBalancingPolicy = new TokenAwarePolicy(DCAwareRoundRobinPolicy.builder().build());
//                 break;
//             case tokenLatencyAwarePolicy:
//                 loadBalancingPolicy = new TokenAwarePolicy(LatencyAwarePolicy.builder(new RoundRobinPolicy()).build());
//                 break;
//             default:
//                 throw new IllegalArgumentException("Cassandra load balancing policy can be " + tokenAwarePolicy + " ," + tokenLatencyAwarePolicy
//                        + " ," + tokenDcAwareRoundRobinPolicy);
//         }
//         return loadBalancingPolicy;
//     }
// }


import net.iponweb.disthene.util.CassandraLoadBalancingPolicies;
import java.util.ArrayList;
import java.util.List;
package net.iponweb.disthene.config;


/**
 * @author Andrei Ivanov
 */
public class StoreConfiguration {
    private List<String> cluster = new ArrayList<>();
    private String keyspace;
    private String columnFamily;
    private String userName;
    private String userPassword;
    private int port;
    private int maxConnections;
    private int readTimeout;
    private int connectTimeout;
    private int maxRequests;
    private boolean batch;
    private int batchSize;
    private int pool;
// Path: src/main/java/net/iponweb/disthene/util/CassandraLoadBalancingPolicies.java
// public class CassandraLoadBalancingPolicies {
// 
//     public static final String tokenAwarePolicy = "TokenAwarePolicy";
//     public static final String tokenDcAwareRoundRobinPolicy = "TokenDcAwareRoundRobinPolicy";
//     public static final String tokenLatencyAwarePolicy = "TokenLatencyAwarePolicy";
// 
//     public static LoadBalancingPolicy getLoadBalancingPolicy(String policy) {
//         LoadBalancingPolicy loadBalancingPolicy;
//         switch (policy) {
//             case tokenAwarePolicy:
//                 loadBalancingPolicy = new TokenAwarePolicy(new RoundRobinPolicy());
//                 break;
//             case tokenDcAwareRoundRobinPolicy:
//                 loadBalancingPolicy = new TokenAwarePolicy(DCAwareRoundRobinPolicy.builder().build());
//                 break;
//             case tokenLatencyAwarePolicy:
//                 loadBalancingPolicy = new TokenAwarePolicy(LatencyAwarePolicy.builder(new RoundRobinPolicy()).build());
//                 break;
//             default:
//                 throw new IllegalArgumentException("Cassandra load balancing policy can be " + tokenAwarePolicy + " ," + tokenLatencyAwarePolicy
//                        + " ," + tokenDcAwareRoundRobinPolicy);
//         }
//         return loadBalancingPolicy;
//     }
// }


// Path: src/main/java/net/iponweb/disthene/config/StoreConfiguration.java
import net.iponweb.disthene.util.CassandraLoadBalancingPolicies;
import java.util.ArrayList;
import java.util.List;

package net.iponweb.disthene.config;


/**
 * @author Andrei Ivanov
 */
public class StoreConfiguration {
    private List<String> cluster = new ArrayList<>();
    private String keyspace;
    private String columnFamily;
    private String userName;
    private String userPassword;
    private int port;
    private int maxConnections;
    private int readTimeout;
    private int connectTimeout;
    private int maxRequests;
    private boolean batch;
    private int batchSize;
    private int pool;
    private String loadBalancingPolicyName = CassandraLoadBalancingPolicies.tokenDcAwareRoundRobinPolicy;