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.

address

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

port

The port of the node.

ssl_options

SSL options specific to this endpoint.

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.