|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of ConnectionException in com.netflix.astyanax |
---|
Methods in com.netflix.astyanax with parameters of type ConnectionException | |
---|---|
boolean |
RowCallback.failure(ConnectionException e)
Notification of an error calling cassandra. |
void |
CassandraOperationTracer.failure(ConnectionException e)
|
boolean |
ExceptionCallback.onException(ConnectionException e)
|
Methods in com.netflix.astyanax that throw ConnectionException | ||
---|---|---|
String |
Cluster.addColumnFamily(ColumnFamilyDefinition def)
Add a column family to an existing keyspace |
|
String |
Cluster.addKeyspace(KeyspaceDefinition def)
Add a new keyspace to the cluster. |
|
String |
Cluster.describeClusterName()
The cluster name is completely arbitrary |
|
KeyspaceDefinition |
Keyspace.describeKeyspace()
Return a complete description of the keyspace and its column families |
|
KeyspaceDefinition |
Cluster.describeKeyspace(String ksName)
Describe a single keyspace |
|
List<KeyspaceDefinition> |
Cluster.describeKeyspaces()
Return details about all keyspaces in the cluster |
|
String |
Cluster.describePartitioner()
Describe the partitioner used by the cluster |
|
List<TokenRange> |
Keyspace.describeRing()
Get a list of all tokens and their endpoints |
|
Map<String,List<String>> |
Cluster.describeSchemaVersions()
|
|
String |
Cluster.describeSnitch()
Describe the snitch name used on the cluster |
|
String |
Cluster.dropColumnFamily(String keyspaceName,
String columnFamilyName)
Delete the column family from the keyspace |
|
String |
Cluster.dropKeyspace(String keyspaceName)
Delete a keyspace from the cluster |
|
OperationResult<R> |
Execution.execute()
Block while executing the operations |
|
Future<OperationResult<R>> |
Execution.executeAsync()
Return a future to the operation. |
|
SerializerPackage |
Keyspace.getSerializerPackage(String cfName,
boolean ignoreErrors)
Return the serializer package for a specific column family. |
|
String |
Cluster.getVersion()
Return version of cassandra running on the cluster |
|
OperationResult<Void> |
Keyspace.testOperation(Operation<?,?> operation)
This method is used for testing purposes only. |
|
OperationResult<Void> |
Keyspace.testOperation(Operation<?,?> operation,
RetryPolicy retry)
This method is used for testing purposes only. |
|
|
Keyspace.truncateColumnFamily(ColumnFamily<K,C> columnFamily)
Delete all rows in a column family |
|
String |
Cluster.updateColumnFamily(ColumnFamilyDefinition def)
Update an existing column family |
|
String |
Cluster.updateKeyspace(KeyspaceDefinition def)
Update a new keyspace in the cluster. |
Uses of ConnectionException in com.netflix.astyanax.connectionpool |
---|
Methods in com.netflix.astyanax.connectionpool that return ConnectionException | |
---|---|
ConnectionException |
Connection.getLastException()
Get the last exception that caused the connection to be closed |
Methods in com.netflix.astyanax.connectionpool with parameters of type ConnectionException | |
---|---|
void |
Connection.AsyncOpenCallback.failure(Connection<CL> conn,
ConnectionException e)
|
void |
HostConnectionPool.markAsDown(ConnectionException reason)
Shut down the host so no more connections may be created when borrowConnections is called and connections will be terminated when returnConnection is called. |
Methods in com.netflix.astyanax.connectionpool that throw ConnectionException | ||
---|---|---|
Connection<CL> |
HostConnectionPool.borrowConnection(int timeout)
Borrow a connection from the host. |
|
R |
Operation.execute(CL client)
Execute the operation on the client object and return the results |
|
|
Connection.execute(Operation<CL,R> op)
Execute an operation on the connection and return a result |
|
|
ConnectionPool.executeWithFailover(Operation<CL,R> op,
RetryPolicy retry)
Execute an operation with failover within the context of the connection pool. |
|
int |
HostConnectionPool.growConnections(int numConnections)
Create numConnections new connections and add them to the |
|
void |
Connection.open()
Open a new connection |
|
Connection<CL> |
HostConnectionPool.openConnection()
This open is different from borrowConnection in that it actually creates a new connection without waiting for one that may be idle. |
|
OperationResult<R> |
ExecuteWithFailover.tryOperation(Operation<CL,R> operation)
|
Uses of ConnectionException in com.netflix.astyanax.connectionpool.exceptions |
---|
Subclasses of ConnectionException in com.netflix.astyanax.connectionpool.exceptions | |
---|---|
class |
BadConfigurationException
|
class |
BadRequestException
|
class |
ConnectionAbortedException
|
class |
HostDownException
No more connections may be opened on a host and no timeout was specified. |
class |
MaxConnsPerHostReachedException
No more connections may be opened on a host and no timeout was specified. |
class |
NoAvailableHostsException
|
class |
NotFoundException
|
class |
OperationException
Application exception for an operation executed within the context of the connection pool. |
class |
OperationTimeoutException
|
class |
PoolTimeoutException
|
class |
ThriftStateException
|
class |
ThrottledException
|
class |
TimeoutException
|
class |
TokenRangeOfflineException
|
class |
TransportException
|
class |
UnknownException
|
Methods in com.netflix.astyanax.connectionpool.exceptions that return ConnectionException | |
---|---|
ConnectionException |
ConnectionException.setAttempt(int attemptCount)
|
ConnectionException |
ConnectionException.setHost(Host host)
|
ConnectionException |
ConnectionException.setLatency(long latency)
|
ConnectionException |
ConnectionException.setLatencyWithPool(long latency)
|
Uses of ConnectionException in com.netflix.astyanax.connectionpool.impl |
---|
Methods in com.netflix.astyanax.connectionpool.impl with parameters of type ConnectionException | |
---|---|
void |
AbstractExecuteWithFailoverImpl.informException(ConnectionException connectionException)
|
void |
SimpleHostConnectionPool.markAsDown(ConnectionException reason)
Mark the host as down. |
Methods in com.netflix.astyanax.connectionpool.impl that throw ConnectionException | ||
---|---|---|
static
|
ExecutionHelper.blockingExecute(Execution<R> execution)
|
|
Connection<CL> |
SimpleHostConnectionPool.borrowConnection(int timeout)
Create a connection as long the max hasn't been reached |
|
Connection<CL> |
RoundRobinExecuteWithFailover.borrowConnection(Operation<CL,R> operation)
|
|
abstract Connection<CL> |
AbstractExecuteWithFailoverImpl.borrowConnection(Operation<CL,R> operation)
|
|
|
AbstractHostPartitionConnectionPool.executeWithFailover(Operation<CL,R> op,
RetryPolicy retry)
|
|
OperationResult<R> |
AbstractExecutionImpl.executeWithRetry(RetryPolicy retry)
|
|
int |
SimpleHostConnectionPool.growConnections(int numConnections)
|
|
void |
AbstractExecuteWithFailoverImpl.informException(ConnectionException connectionException)
|
|
|
TokenAwareConnectionPoolImpl.newExecuteWithFailover(Operation<CL,R> op)
|
|
|
RoundRobinConnectionPoolImpl.newExecuteWithFailover(Operation<CL,R> operation)
|
|
|
BagOfConnectionsConnectionPoolImpl.newExecuteWithFailover(Operation<CL,R> op)
|
|
protected abstract
|
AbstractHostPartitionConnectionPool.newExecuteWithFailover(Operation<CL,R> op)
Return a new failover context. |
|
Connection<CL> |
SimpleHostConnectionPool.openConnection()
Open a new connection synchronously |
|
OperationResult<R> |
AbstractExecuteWithFailoverImpl.tryOperation(Operation<CL,R> operation)
|
Constructors in com.netflix.astyanax.connectionpool.impl that throw ConnectionException | |
---|---|
AbstractExecuteWithFailoverImpl(ConnectionPoolConfiguration config,
ConnectionPoolMonitor monitor)
|
|
RoundRobinExecuteWithFailover(ConnectionPoolConfiguration config,
ConnectionPoolMonitor monitor,
List<HostConnectionPool<CL>> pools,
int index)
|
Uses of ConnectionException in com.netflix.astyanax.query |
---|
Methods in com.netflix.astyanax.query that throw ConnectionException | |
---|---|
void |
AllRowsQuery.executeWithCallback(RowCallback<K,C> callback)
Execute the operation in a separate thread for each token range and provide the results in a callback. |
Uses of ConnectionException in com.netflix.astyanax.recipes |
---|
Methods in com.netflix.astyanax.recipes that throw ConnectionException | |
---|---|
String |
UniquenessConstraintWithPrefix.isUnique(K key)
|
C |
UniquenessConstraint.isUnique(K key)
|
Uses of ConnectionException in com.netflix.astyanax.shallows |
---|
Methods in com.netflix.astyanax.shallows with parameters of type ConnectionException | |
---|---|
void |
EmptyKeyspaceTracer.failure(ConnectionException e)
|
Uses of ConnectionException in com.netflix.astyanax.thrift |
---|
Methods in com.netflix.astyanax.thrift that return ConnectionException | |
---|---|
static ConnectionException |
ThriftConverter.ToConnectionPoolException(Exception e)
Convert from Thrift exceptions to an internal ConnectionPoolException |
Methods in com.netflix.astyanax.thrift that throw ConnectionException | ||
---|---|---|
String |
ThriftClusterImpl.addColumnFamily(ColumnFamilyDefinition def)
|
|
String |
ThriftClusterImpl.addKeyspace(KeyspaceDefinition def)
|
|
String |
ThriftClusterImpl.describeClusterName()
|
|
KeyspaceDefinition |
ThriftKeyspaceImpl.describeKeyspace()
|
|
KeyspaceDefinition |
ThriftClusterImpl.describeKeyspace(String ksName)
|
|
List<KeyspaceDefinition> |
ThriftClusterImpl.describeKeyspaces()
|
|
String |
ThriftClusterImpl.describePartitioner()
|
|
List<TokenRange> |
ThriftKeyspaceImpl.describeRing()
|
|
Map<String,List<String>> |
ThriftClusterImpl.describeSchemaVersions()
|
|
String |
ThriftClusterImpl.describeSnitch()
|
|
String |
ThriftClusterImpl.dropColumnFamily(String keyspaceName,
String columnFamilyName)
|
|
String |
ThriftClusterImpl.dropKeyspace(String keyspaceName)
|
|
OperationResult<Void> |
AbstractThriftMutationBatchImpl.execute()
|
|
R |
AbstractOperationImpl.execute(org.apache.cassandra.thrift.Cassandra.Client client)
|
|
SerializerPackage |
ThriftKeyspaceImpl.getSerializerPackage(String cfName,
boolean ignoreErrors)
|
|
String |
ThriftClusterImpl.getVersion()
Get the version from the cluster |
|
OperationResult<Void> |
ThriftKeyspaceImpl.testOperation(Operation<?,?> operation)
|
|
OperationResult<Void> |
ThriftKeyspaceImpl.testOperation(Operation<?,?> operation,
RetryPolicy retry)
|
|
|
ThriftKeyspaceImpl.truncateColumnFamily(ColumnFamily<K,C> columnFamily)
|
|
String |
ThriftClusterImpl.updateColumnFamily(ColumnFamilyDefinition def)
|
|
String |
ThriftClusterImpl.updateKeyspace(KeyspaceDefinition def)
|
Uses of ConnectionException in com.netflix.astyanax.util |
---|
Methods in com.netflix.astyanax.util that throw ConnectionException | |
---|---|
void |
RecordWriter.start()
|
void |
ColumnarRecordWriter.start()
|
Constructors in com.netflix.astyanax.util that throw ConnectionException | |
---|---|
JsonRowsWriter(PrintWriter out,
SerializerPackage serializers)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |