Package | Description |
---|---|
com.datastax.driver.core |
The main package for the DataStax Java driver for Cassandra.
|
com.datastax.driver.core.exceptions |
Exceptions thrown by the DataStax Java driver for Cassandra.
|
com.datastax.driver.dse.auth |
Modifier and Type | Class and Description |
---|---|
class |
SniEndPoint
An endpoint to access nodes through a proxy that uses SNI routing.
|
Modifier and Type | Method and Description |
---|---|
EndPoint |
SniEndPointFactory.create(Row peersRow) |
EndPoint |
EndPointFactory.create(Row peersRow)
Creates an instance from a row in
system.peers , or returns null if there is no
sufficient information. |
EndPoint |
DefaultEndPointFactory.create(Row peersRow) |
EndPoint |
Host.getEndPoint()
Returns information to connect to the node.
|
Modifier and Type | Method and Description |
---|---|
List<EndPoint> |
Cluster.Initializer.getContactPoints()
Returns the initial Cassandra hosts to connect to.
|
List<EndPoint> |
Cluster.Builder.getContactPoints() |
Modifier and Type | Method and Description |
---|---|
Cluster.Builder |
Cluster.Builder.addContactPoint(EndPoint contactPoint)
Adds a contact point using the given connection information.
|
Authenticator |
PlainTextAuthProvider.newAuthenticator(EndPoint host,
String authenticator)
Uses the supplied credentials and the SASL PLAIN mechanism to login to the server.
|
Authenticator |
ExtendedAuthProvider.newAuthenticator(EndPoint endPoint,
String authenticator)
The
Authenticator to use when connecting to endpoint . |
Authenticator |
AuthProvider.NoAuthProvider.newAuthenticator(EndPoint endPoint,
String authenticator) |
protected SSLEngine |
SniSSLOptions.newSSLEngine(io.netty.channel.socket.SocketChannel channel,
EndPoint remoteEndpoint) |
io.netty.handler.ssl.SslHandler |
SniSSLOptions.newSSLHandler(io.netty.channel.socket.SocketChannel channel,
EndPoint remoteEndpoint) |
io.netty.handler.ssl.SslHandler |
RemoteEndpointAwareNettySSLOptions.newSSLHandler(io.netty.channel.socket.SocketChannel channel,
EndPoint remoteEndpoint) |
io.netty.handler.ssl.SslHandler |
RemoteEndpointAwareJdkSSLOptions.newSSLHandler(io.netty.channel.socket.SocketChannel channel,
EndPoint remoteEndpoint) |
io.netty.handler.ssl.SslHandler |
ExtendedRemoteEndpointAwareSslOptions.newSSLHandler(io.netty.channel.socket.SocketChannel channel,
EndPoint remoteEndpoint)
Creates a new SSL handler for the given Netty channel and the given remote endpoint.
|
Constructor and Description |
---|
Cluster(String name,
List<EndPoint> contactPoints,
Configuration configuration)
Constructs a new Cluster instance.
|
Modifier and Type | Method and Description |
---|---|
EndPoint |
UnsupportedProtocolVersionException.getEndPoint() |
EndPoint |
UnpreparedException.getEndPoint() |
EndPoint |
UnavailableException.getEndPoint() |
EndPoint |
UnauthorizedException.getEndPoint() |
EndPoint |
TruncateException.getEndPoint() |
EndPoint |
SyntaxError.getEndPoint() |
EndPoint |
ServerError.getEndPoint() |
EndPoint |
QueryConsistencyException.getEndPoint()
The connection information of the coordinator host that was contacted.
|
EndPoint |
ProtocolError.getEndPoint() |
EndPoint |
OverloadedException.getEndPoint() |
EndPoint |
InvalidQueryException.getEndPoint() |
EndPoint |
FunctionExecutionException.getEndPoint() |
EndPoint |
CoordinatorException.getEndPoint()
The connection information of the coordinator host that was contacted.
|
EndPoint |
ConnectionException.getEndPoint() |
EndPoint |
BusyPoolException.getEndPoint() |
EndPoint |
BusyConnectionException.getEndPoint() |
EndPoint |
BootstrappingException.getEndPoint() |
EndPoint |
AuthenticationException.getEndPoint() |
EndPoint |
AlreadyExistsException.getEndPoint() |
Modifier and Type | Method and Description |
---|---|
Map<EndPoint,Throwable> |
NoHostAvailableException.getErrors()
Return the hosts tried along with the error encountered while trying them.
|
Modifier and Type | Method and Description |
---|---|
WriteTimeoutException |
WriteTimeoutException.copy(EndPoint address)
Create a copy of this exception with a nicer stack trace, and including the coordinator address
that caused this exception to be raised.
|
WriteFailureException |
WriteFailureException.copy(EndPoint endPoint) |
UnavailableException |
UnavailableException.copy(EndPoint endPoint)
Create a copy of this exception with a nicer stack trace, and including the coordinator address
that caused this exception to be raised.
|
ReadTimeoutException |
ReadTimeoutException.copy(EndPoint endPoint)
Create a copy of this exception with a nicer stack trace, and including the coordinator address
that caused this exception to be raised.
|
ReadFailureException |
ReadFailureException.copy(EndPoint endPoint) |
AlreadyExistsException |
AlreadyExistsException.copy(EndPoint endPoint)
Create a copy of this exception with a nicer stack trace, and including the coordinator address
that caused this exception to be raised.
|
Constructor and Description |
---|
NoHostAvailableException(Map<EndPoint,Throwable> errors) |
Modifier and Type | Method and Description |
---|---|
Authenticator |
DsePlainTextAuthProvider.newAuthenticator(EndPoint endPoint,
String authenticator) |
Copyright © 2012–2019. All rights reserved.