| /plugin/elasticsearch/vendor/elasticsearch/elasticsearch/docs/ |
| H A D | connection-factory.asciidoc | 1 [[connection-factory]]
|
| H A D | connection-pool.asciidoc | 4 The connection pool is an object inside the client that is responsible for
8 unclear why"_ or _"recently dead but now alive"_. The job of the connection pool
12 If a connection pool is unable to find an alive node to query against, it
15 request and 9 out of the 10 nodes fail due to connection timeouts. The tenth
17 (depending on the connection pool being used) and their "dead" timers begin
27 There are several connection pool implementations that you can choose from:
33 This connection pool maintains a static list of hosts which are assumed to be
99 Unlike the two previous static connection pools, this one is dynamic. The user
160 If your connection pool only makes minor changes, you may consider extending
212 ==== Which connection poo
[all...] |
| H A D | http-meta-data.asciidoc | 4 By default, the client sends some meta data about the HTTP connection using
|
| H A D | per-request-configuration.asciidoc | 5 than at a connection- or client-level. These are specified as part of the
260 If either timeout expires, curl closes the connection and returns an error. Both
|
| H A D | selectors.asciidoc | 4 The connection pool maintains the list of connections, and decides when nodes
8 The job of a selector is to return a single connection from a provided array of
9 connections. Like the connection pool, there are several implementations to
37 This selector is "sticky", so that it prefers to reuse the same connection
46 Instead, it is better to "stick" to a single connection for the duration of the
104 * Selects the first connection
|
| H A D | set-retries.asciidoc | 6 exception: connection refusal, connection timeout, DNS lookup timeout, etc. 4xx
24 result in a connection timeout (for example), the client will throw an
|
| /plugin/elasticsearch/vendor/elasticsearch/elasticsearch/src/Elasticsearch/ConnectionPool/ |
| H A D | SniffingConnectionPool.php | 58 * @var Connection $connection
60 $connection = $this->selector->select($this->connections);
61 if ($connection->isAlive() === true || $connection->ping() === true) {
62 return $connection;
88 * @var Connection $connection
90 $connection = $this->selector->select($this->connections);
92 if ($connection->isAlive() xor $force) {
96 if ($this->sniffConnection($connection) === true) {
105 foreach ($this->seedConnections as $connection) {
112 sniffConnection(Connection $connection) global() argument
[all...] |
| H A D | StaticConnectionPool.php | 55 * @var Connection $connection
57 $connection = $this->selector->select($this->connections);
58 if ($connection->isAlive() === true) {
59 return $connection;
62 if ($this->readyToRevive($connection) === true) {
63 if ($connection->ping() === true) {
64 return $connection;
67 $skipped[] = $connection;
72 foreach ($skipped as $connection) {
73 if ($connection
88 readyToRevive(Connection $connection) global() argument
[all...] |
| H A D | StaticNoPingConnectionPool.php | 52 * @var Connection $connection
54 $connection = $this->selector->select($this->connections);
55 if ($connection->isAlive() === true) {
56 return $connection;
59 if ($this->readyToRevive($connection) === true) {
60 return $connection;
71 private function readyToRevive(Connection $connection): bool argument
74 $this->pingTimeout * pow(2, $connection->getPingFailures()),
78 if ($connection->getLastPing() + $timeout < time()) {
|
| /plugin/elasticsearch/vendor/elasticsearch/elasticsearch/src/Elasticsearch/Connections/ |
| H A D | Connection.php | 258 return function (array $request, Connection $connection, Transport $transport = null, $options) use ($handler) {
266 function ($response) use ($connection, $transport, $request, $options) {
278 $node = $connection->getHost();
280 $connection->markDead();
316 $connection->markAlive();
|
| /plugin/elasticsearch/vendor/elasticsearch/elasticsearch/src/Elasticsearch/ |
| H A D | Transport.php | 77 * Returns a single connection from the connection pool
99 $connection = $this->getConnection();
107 $this->lastConnection = $connection;
109 $future = $connection->performRequest(
168 * Returns the last used connection so that it may be inspected. Mainly
|
| /plugin/elasticsearch/vendor/ruflin/elastica/ |
| H A D | CHANGELOG.md | 77 * Fixed `Http` PHPDoc adding `\CurlHandle` type for Curl connection by @franmomu [#2086](https://github.com/ruflin/Elastica/pull/2086)
195 * Added support for defining a connection pool with DSN. Example: `pool(http://127.0.0.1 http://127.0.0.2/bar?timeout=4)` [#1808](https://github.com/ruflin/Elastica/pull/1808)
214 * Allowed float values for connection timeout and connection connect-timeout, providing ms precision for those. Previous precision was second. [#1868](https://github.com/ruflin/Elastica/pull/1868)
485 - Fix [#1456](https://github.com/ruflin/Elastica/issues/1456) set SSL as connection scheme if it is required
785 - Set HTTP headers on each request preventing server error if persistent connection is enabled and compression enabled and later disabled for the same connection.
830 - `Elastica\Client->connect()` allows to establish a connection to ES server when the config was set using method `Elastica\Client->setConfigValue()` https://github.com/ruflin/Elastica/issues/1076 [#1077](https://github.com/ruflin/Elastica/pull/1077)
864 - Add username and password params to connection
885 - Add `bigintConversion` to keys passed to connection confi
[all...] |
| /plugin/elasticsearch/vendor/ruflin/elastica/src/ |
| H A D | Client.php | 67 * @param callable|null $callback OPTIONAL Callback function which can be used to be notified about errors (for example connection down)
163 * Returns the index for the given connection.
393 public function addConnection(Connection $connection)
395 $this->_connectionPool->addConnection($connection);
401 * Determines whether a valid connection is available for use.
540 $connection = $this->getConnection();
541 $request = $this->_lastRequest = new Request($path, $method, $data, $query, $connection, $contentType);
547 $this->_connectionPool->onFail($connection, $e, $this);
554 // In case there is no valid connection left, throw exception which caused the disabling of the connection
372 addConnection(Connection $connection) global() argument
[all...] |
| H A D | Request.php | 38 public function __construct(string $path, string $method = self::GET, $data = [], array $query = [], ?Connection $connection = null, string $contentType = self::DEFAULT_CONTENT_TYPE) argument
45 if ($connection) {
46 $this->setConnection($connection);
135 public function setConnection(Connection $connection) argument
137 $this->_connection = $connection;
145 * @throws Exception\InvalidException If no valid connection was set
150 throw new InvalidException('No valid connection object set');
193 $data['connection'] = $this->_connection->getParams();
|
| /plugin/elasticsearch/vendor/ruflin/elastica/src/Connection/ |
| H A D | ConnectionPool.php | 24 * @var StrategyInterface Strategy for connection
29 * @var callable|null Function called on connection fail
43 public function addConnection(Connection $connection): self argument
45 $this->_connections[] = $connection;
64 foreach ($this->_connections as $connection) {
65 if ($connection->isEnabled()) {
89 public function onFail(Connection $connection, Exception $e, Client $client): void argument
91 $connection->setEnabled(false);
94 ($this->_callback)($connection, $e, $client);
|
| /plugin/elasticsearch/vendor/ruflin/elastica/src/Connection/Strategy/ |
| H A D | Simple.php | 20 foreach ($connections as $connection) {
21 if ($connection->isEnabled()) {
22 return $connection;
26 throw new ClientException('No enabled connection');
|
| /plugin/elasticsearch/vendor/ruflin/elastica/src/Transport/ |
| H A D | AbstractTransport.php | 28 public function __construct(?Connection $connection = null) argument
30 if ($connection) {
31 $this->setConnection($connection);
43 public function setConnection(Connection $connection): AbstractTransport argument
45 $this->_connection = $connection;
91 * @param Connection $connection A connection instance
96 public static function create($transport, Connection $connection, array $params = []): AbstractTransport argument
123 $transport->setConnection($connection);
|
| H A D | AwsAuthV4.php | 32 protected function _getBaseUrl(Connection $connection): string argument
36 return parent::_getBaseUrl($connection);
75 $connection = $this->getConnection(); variable in Elastica\\Transport\\AwsAuthV4
77 if ($connection->hasParam('aws_credential_provider')) {
78 return $connection->getParam('aws_credential_provider');
81 if ($connection->hasParam('aws_secret_access_key')) {
83 $connection->getParam('aws_access_key_id'),
84 $connection->getParam('aws_secret_access_key'),
85 $connection->hasParam('aws_session_token')
86 ? $connection
[all...] |
| H A D | Guzzle.php | 52 $connection = $this->getConnection();
54 $client = $this->_getGuzzleClient($connection->isPersistent());
57 'base_uri' => $this->_getBaseUrl($connection),
64 if ($connection->getTimeout()) {
65 $options[RequestOptions::TIMEOUT] = $connection->getTimeout();
68 if (null !== $proxy = $connection->getProxy()) {
72 $req = $this->_createPsr7Request($request, $connection);
85 if ($connection->hasConfig('bigintConversion')) {
86 $response->setJsonBigintConversion($connection->getConfig('bigintConversion'));
110 protected function _createPsr7Request(Request $request, Connection $connection) argument
154 _getBaseUrl(Connection $connection) global() argument
[all...] |
| H A D | Http.php | 50 $connection = $this->getConnection();
52 $conn = $this->_getConnection($connection->isPersistent());
55 $url = $connection->hasConfig('url') ? $connection->getConfig('url') : '';
60 $baseUri = $this->_scheme.'://'.$connection->getHost().':'.$connection->getPort().'/'.$connection->getPath();
79 \curl_setopt($conn, \CURLOPT_TIMEOUT_MS, $connection->getTimeout() * 1000);
88 $connectTimeoutMs = $connection->getConnectTimeout() * 1000;
96 if (null !== $proxy = $connection
[all...] |
| H A D | HttpAdapter.php | 38 public function __construct(?Connection $connection, HttpAdapterInterface $httpAdapter) argument
40 parent::__construct($connection);
57 $connection = $this->getConnection();
59 if ($timeout = $connection->getTimeout()) {
63 $httpAdapterRequest = $this->_createHttpAdapterRequest($elasticaRequest, $connection);
95 protected function _createHttpAdapterRequest(ElasticaRequest $elasticaRequest, Connection $connection): HttpAdapterRequest argument
100 $headers = $connection->hasConfig('headers') ?: [];
118 $url = $this->_getUri($elasticaRequest, $connection);
124 protected function _getUri(ElasticaRequest $request, Connection $connection): string argument
126 $url = $connection
[all...] |
| /plugin/facebooklike/ |
| H A D | LICENSE | 513 If, pursuant to or in connection with a single transaction or
530 patent license (a) in connection with copies of the covered work
532 for and in connection with specific products or compilations that
617 an absolute waiver of all civil liability in connection with the
|
| /plugin/farm/install/animaltemplate/conf/ |
| H A D | mysql.conf.php.example | 229 /* This statement should remove a single connection from a user to a
|
| H A D | wordblock.conf | 1437 https?:\/\/([^\/]*\.)?cable-connection\.keckins\.be
|
| /plugin/fedauth/Auth/OpenID/ |
| H A D | MDB2Store.php | 52 * @param connection $connection This must be an established
65 function Auth_OpenID_MDB2Store($connection, argument
74 if (!is_object($connection) ||
82 $this->connection = $connection;
125 switch ($this->connection->phptype) {
130 $r = $this->connection->exec(
195 switch ($this->connection->phptype) {
306 return $this->connection->exec(
313 return $this->connection->exec(
359 $r = $this->connection->execParam(
[all …]
|