elastic_enterprise_search/_async/client/_base.py [80:140]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    ):
        if _transport is None:
            transport_kwargs = {}
            if connections_per_node is not DEFAULT:
                transport_kwargs["connections_per_node"] = connections_per_node
            if http_compress is not DEFAULT:
                transport_kwargs["http_compress"] = http_compress
            if verify_certs is not DEFAULT:
                transport_kwargs["verify_certs"] = verify_certs
            if node_class is not DEFAULT:
                transport_kwargs["node_class"] = node_class
            if dead_node_backoff_factor is not DEFAULT:
                transport_kwargs["dead_node_backoff_factor"] = dead_node_backoff_factor
            if max_dead_node_backoff is not DEFAULT:
                transport_kwargs["max_dead_node_backoff"] = max_dead_node_backoff
            if meta_header is not DEFAULT:
                if not isinstance(meta_header, bool):
                    raise TypeError("meta_header must be of type bool")
                transport_kwargs["meta_header"] = meta_header

            node_configs = client_node_configs(
                hosts,
                connections_per_node=connections_per_node,
                http_compress=http_compress,
                verify_certs=verify_certs,
                ca_certs=ca_certs,
                client_cert=client_cert,
                client_key=client_key,
                ssl_assert_hostname=ssl_assert_hostname,
                ssl_assert_fingerprint=ssl_assert_fingerprint,
                ssl_version=ssl_version,
                ssl_context=ssl_context,
                ssl_show_warn=ssl_show_warn,
            )
            self._transport = transport_class(
                node_configs,
                client_meta_service=CLIENT_META_SERVICE,
                **transport_kwargs,
            )
        else:
            self._transport = _transport

        # Need to filter out the 'None' values
        headers = {
            k: v
            for k, v in resolve_auth_headers(
                headers=headers,
                http_auth=http_auth,
                basic_auth=basic_auth,
                bearer_auth=bearer_auth,
            ).items()
            if v is not None
        }
        self._headers = HttpHeaders(headers)

        self._request_timeout = request_timeout
        self._max_retries = max_retries
        self._retry_on_status = retry_on_status
        self._retry_on_timeout = retry_on_timeout
        self._client_meta = DEFAULT
        self._ignore_status = None
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



elastic_enterprise_search/_sync/client/_base.py [80:140]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    ):
        if _transport is None:
            transport_kwargs = {}
            if connections_per_node is not DEFAULT:
                transport_kwargs["connections_per_node"] = connections_per_node
            if http_compress is not DEFAULT:
                transport_kwargs["http_compress"] = http_compress
            if verify_certs is not DEFAULT:
                transport_kwargs["verify_certs"] = verify_certs
            if node_class is not DEFAULT:
                transport_kwargs["node_class"] = node_class
            if dead_node_backoff_factor is not DEFAULT:
                transport_kwargs["dead_node_backoff_factor"] = dead_node_backoff_factor
            if max_dead_node_backoff is not DEFAULT:
                transport_kwargs["max_dead_node_backoff"] = max_dead_node_backoff
            if meta_header is not DEFAULT:
                if not isinstance(meta_header, bool):
                    raise TypeError("meta_header must be of type bool")
                transport_kwargs["meta_header"] = meta_header

            node_configs = client_node_configs(
                hosts,
                connections_per_node=connections_per_node,
                http_compress=http_compress,
                verify_certs=verify_certs,
                ca_certs=ca_certs,
                client_cert=client_cert,
                client_key=client_key,
                ssl_assert_hostname=ssl_assert_hostname,
                ssl_assert_fingerprint=ssl_assert_fingerprint,
                ssl_version=ssl_version,
                ssl_context=ssl_context,
                ssl_show_warn=ssl_show_warn,
            )
            self._transport = transport_class(
                node_configs,
                client_meta_service=CLIENT_META_SERVICE,
                **transport_kwargs,
            )
        else:
            self._transport = _transport

        # Need to filter out the 'None' values
        headers = {
            k: v
            for k, v in resolve_auth_headers(
                headers=headers,
                http_auth=http_auth,
                basic_auth=basic_auth,
                bearer_auth=bearer_auth,
            ).items()
            if v is not None
        }
        self._headers = HttpHeaders(headers)

        self._request_timeout = request_timeout
        self._max_retries = max_retries
        self._retry_on_status = retry_on_status
        self._retry_on_timeout = retry_on_timeout
        self._client_meta = DEFAULT
        self._ignore_status = None
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -