Method connection_factory

cassandra/cluster.py:1629–1635

Called to create a new connection with proper configuration. Intended for internal use only.

(self, endpoint, *args, **kwargs)

        self._max_connections_per_host[host_distance] = max_connections

    def connection_factory(self, endpoint, *args, **kwargs):
        """
        Called to create a new connection with proper configuration.
        Intended for internal use only.
        """
        kwargs = self._make_connection_kwargs(endpoint, kwargs)
        return self.connection_class.factory(endpoint, self.connect_timeout, *args, **kwargs)

    def _make_connection_factory(self, host, *args, **kwargs):
        kwargs = self._make_connection_kwargs(host.endpoint, kwargs)