summaryrefslogtreecommitdiff
path: root/vendor/ruflin/elastica/lib/Elastica/Status.php
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/ruflin/elastica/lib/Elastica/Status.php')
-rw-r--r--vendor/ruflin/elastica/lib/Elastica/Status.php179
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();
- }
-}