/*
 * Decompiled with CFR 0.152.
 * 
 * Could not load the following classes:
 *  com.datastax.oss.driver.api.core.DriverException
 *  com.l7tech.gateway.common.cassandra.CassandraConnection
 *  com.l7tech.objectmodel.Goid
 *  com.l7tech.objectmodel.UpdateException
 *  com.l7tech.util.TimeUnit
 */
package com.l7tech.server.cassandra;

import com.datastax.oss.driver.api.core.DriverException;
import com.l7tech.gateway.common.cassandra.CassandraConnection;
import com.l7tech.objectmodel.Goid;
import com.l7tech.objectmodel.UpdateException;
import com.l7tech.server.cassandra.CassandraConnectionHolder;
import com.l7tech.util.TimeUnit;

public interface CassandraConnectionManager {
    public static final int MAX_SIMUL_REQ_PER_HOST_LOCAL_DEF = 1024;
    public static final int MAX_CONNECTIONS_PER_LOCAL_HOST_DEFAULT = 1;
    public static final int MAX_CONNECTIONS_PER_REMOTE_HOST_DEFAULT = 1;
    public static final int NUM_OF_USED_HOSTS_PER_REMOTE_DC_DEFAULT = 0;
    public static final boolean ALLOW_REMOTE_DCS_FOR_LOCAL_CONSISTENCY_LEVEL_DEFAULT = false;
    public static final long DEFAULT_CONNECTION_MAX_AGE = 0L;
    public static final long DEFAULT_CONNECTION_MAX_IDLE = TimeUnit.MINUTES.toMillis(30L);
    public static final int DEFAULT_CONNECTION_CACHE_SIZE = 20;
    public static final int DEFAULT_FETCH_SIZE = 5000;
    public static final int DEFAULT_CONNECTION_TIMEOUT_MS = 5000;
    public static final int DEFAULT_READ_TIMEOUT_MS = 12000;
    public static final boolean DEFAULT_KEEP_ALIVE = true;
    public static final boolean DEFAULT_TCP_NO_DELAY = false;
    public static final String PLAIN_TEXT_AUTH_PROVIDER = "PlainTextAuthProvider";

    public CassandraConnectionHolder getConnection(String var1);

    public void testConnection(CassandraConnection var1) throws DriverException;

    public void closeAllConnections();

    public void addConnection(CassandraConnection var1);

    public void removeConnection(CassandraConnection var1);

    public void removeConnection(Goid var1);

    public void updateConnection(CassandraConnection var1) throws UpdateException;
}