diff options
Diffstat (limited to 'vendor/ruflin/elastica/lib/Elastica/Status.php')
-rw-r--r-- | vendor/ruflin/elastica/lib/Elastica/Status.php | 179 |
1 files changed, 0 insertions, 179 deletions
diff --git a/vendor/ruflin/elastica/lib/Elastica/Status.php b/vendor/ruflin/elastica/lib/Elastica/Status.php deleted file mode 100644 index a747b9a5..00000000 --- a/vendor/ruflin/elastica/lib/Elastica/Status.php +++ /dev/null @@ -1,179 +0,0 @@ -<?php - -namespace Elastica; -use Elastica\Exception\ResponseException; -use Elastica\Index\Status as IndexStatus; - -/** - * Elastica general status - * - * @category Xodoa - * @package Elastica - * @author Nicolas Ruflin <spam@ruflin.com> - * @link http://www.elasticsearch.org/guide/reference/api/admin-indices-status.html - */ -class Status -{ - /** - * Contains all status infos - * - * @var \Elastica\Response Response object - */ - protected $_response = null; - - /** - * Data - * - * @var array Data - */ - protected $_data = array(); - - /** - * Client object - * - * @var \Elastica\Client Client object - */ - protected $_client = null; - - /** - * Constructs Status object - * - * @param \Elastica\Client $client Client object - */ - public function __construct(Client $client) - { - $this->_client = $client; - $this->refresh(); - } - - /** - * Returns status data - * - * @return array Status data - */ - public function getData() - { - return $this->_data; - } - - /** - * Returns status objects of all indices - * - * @return array|\Elastica\Index\Status[] List of Elastica\Client\Index objects - */ - public function getIndexStatuses() - { - $statuses = array(); - foreach ($this->getIndexNames() as $name) { - $index = new Index($this->_client, $name); - $statuses[] = new IndexStatus($index); - } - - return $statuses; - } - - /** - * Returns a list of the existing index names - * - * @return array Index names list - */ - public function getIndexNames() - { - $names = array(); - foreach ($this->_data['indices'] as $name => $data) { - $names[] = $name; - } - - return $names; - } - - /** - * Checks if the given index exists - * - * @param string $name Index name to check - * @return bool True if index exists - */ - public function indexExists($name) - { - return in_array($name, $this->getIndexNames()); - } - - /** - * Checks if the given alias exists - * - * @param string $name Alias name - * @return bool True if alias exists - */ - public function aliasExists($name) - { - return count($this->getIndicesWithAlias($name)) > 0; - } - - /** - * Returns an array with all indices that the given alias name points to - * - * @param string $alias Alias name - * @return array|\Elastica\Index[] List of Elastica\Index - */ - public function getIndicesWithAlias($alias) - { - $response = null; - try { - $response = $this->_client->request('/_alias/' . $alias); - } catch (ResponseException $e) { - $transferInfo = $e->getResponse()->getTransferInfo(); - // 404 means the index alias doesn't exist which means no indexes have it. - if ($transferInfo['http_code'] === 404) { - return array(); - } - // If we don't have a 404 then this is still unexpected so rethrow the exception. - throw $e; - } - $indices = array(); - foreach ($response->getData() as $name => $unused) { - $indices[] = new Index($this->_client, $name); - } - return $indices; - } - - /** - * Returns response object - * - * @return \Elastica\Response Response object - */ - public function getResponse() - { - return $this->_response; - } - - /** - * Return shards info - * - * @return array Shards info - */ - public function getShards() - { - return $this->_data['shards']; - } - - /** - * Refresh status object - */ - public function refresh() - { - $path = '_status'; - $this->_response = $this->_client->request($path, Request::GET); - $this->_data = $this->getResponse()->getData(); - } - - /** - * Refresh serverStatus object - */ - public function getServerStatus() - { - $path = ''; - $response = $this->_client->request($path, Request::GET); - - return $response->getData(); - } -} |