cassandra.connection¶

Low Level Connection Info

exception cassandra.connection.ConnectionException¶

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

exception cassandra.connection.ConnectionShutdown¶

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

exception cassandra.connection.ConnectionBusy¶

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¶

Communication did not match the protocol that this driver expects.

class cassandra.connection.EndPoint¶

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.

property tls_session_cache_key¶

A hashable value identifying the TLS peer this endpoint connects to, used to look up cached TLS sessions (see SSLSessionCache). Two endpoints may share a key only if a TLS session established with one is valid for the other.

An endpoint built to reach a node that another one already describes – an alternate listener of the same server – carries that node’s key here, so both share one cached session. Subclasses give their own identity in _default_tls_session_cache_key().

resolve()¶

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

class cassandra.connection.EndPointFactory¶

configure(cluster)¶

This is called by the cluster during its initialization.

create(row)¶

Create an EndPoint from a system.peers row.

class cassandra.connection.SniEndPoint(proxy_address, server_name, port=9042)¶

SNI Proxy EndPoint implementation.

class cassandra.connection.SniEndPointFactory(proxy_address, port, node_domain=None)¶

class cassandra.connection.UnixSocketEndPoint(unix_socket_path)¶

Unix Socket EndPoint implementation.