cassandra.connection - Low Level Connection Info

exception cassandra.connection.ConnectionException[source]

An unrecoverable error was hit when attempting to use a connection, or the connection was already closed or defunct.

exception cassandra.connection.ConnectionShutdown[source]

Raised when a connection has been marked as defunct or has been closed.

exception cassandra.connection.ConnectionBusy[source]

An attempt was made to send a message through a Connection that was already at the max number of in-flight operations.

exception cassandra.connection.ProtocolError[source]

Communication did not match the protocol that this driver expects.

class cassandra.connection.EndPoint[source]

Represents the information to connect to a cassandra node.

property address

The IP address of the node. This is the RPC address the driver uses when connecting to the node

property port

The port of the node.

property ssl_options

SSL options specific to this endpoint.

property socket_family

The socket family of the endpoint.

resolve()[source]

Resolve the endpoint to an address/port. This is called only on socket connection.

class cassandra.connection.EndPointFactory[source]
configure(cluster)[source]

This is called by the cluster during its initialization.

create(row)[source]

Create an EndPoint from a system.peers row.

class cassandra.connection.SniEndPoint(proxy_address, server_name, port=9042)[source]

SNI Proxy EndPoint implementation.

class cassandra.connection.SniEndPointFactory(proxy_address, port)[source]
class cassandra.connection.UnixSocketEndPoint(unix_socket_path)[source]

Unix Socket EndPoint implementation.

3.21.0