summaryrefslogtreecommitdiff
path: root/vendor/ruflin/elastica/lib/Elastica/Cluster.php
diff options
context:
space:
mode:
authorLuke Shumaker <lukeshu@sbcglobal.net>2016-05-01 15:30:47 -0400
committerLuke Shumaker <lukeshu@sbcglobal.net>2016-05-01 15:30:47 -0400
commit7e85254903c7c0cb49e381f16b18441ea7b058cc (patch)
treeb22328fcf4c8408fc25a7acb73d1cb1089cd82ac /vendor/ruflin/elastica/lib/Elastica/Cluster.php
parent1de335ad3f395ca6861085393ba366a9e3fb4a0d (diff)
parent1a365e77dfb8825136626202b1df462731b42060 (diff)
Merge commit '1a365e'
Diffstat (limited to 'vendor/ruflin/elastica/lib/Elastica/Cluster.php')
-rw-r--r--vendor/ruflin/elastica/lib/Elastica/Cluster.php181
1 files changed, 181 insertions, 0 deletions
diff --git a/vendor/ruflin/elastica/lib/Elastica/Cluster.php b/vendor/ruflin/elastica/lib/Elastica/Cluster.php
new file mode 100644
index 00000000..ac5acf76
--- /dev/null
+++ b/vendor/ruflin/elastica/lib/Elastica/Cluster.php
@@ -0,0 +1,181 @@
+<?php
+
+namespace Elastica;
+use Elastica\Cluster\Health;
+use Elastica\Cluster\Settings;
+use Elastica\Exception\NotImplementedException;
+
+/**
+ * Cluster informations for elasticsearch
+ *
+ * @category Xodoa
+ * @package Elastica
+ * @author Nicolas Ruflin <spam@ruflin.com>
+ * @link http://www.elasticsearch.org/guide/reference/api/
+ */
+class Cluster
+{
+ /**
+ * Client
+ *
+ * @var \Elastica\Client Client object
+ */
+ protected $_client = null;
+
+ /**
+ * Cluster state response.
+ *
+ * @var \Elastica\Response
+ */
+ protected $_response;
+
+ /**
+ * Cluster state data.
+ *
+ * @var array
+ */
+ protected $_data;
+
+ /**
+ * Creates a cluster object
+ *
+ * @param \Elastica\Client $client Connection client object
+ */
+ public function __construct(Client $client)
+ {
+ $this->_client = $client;
+ $this->refresh();
+ }
+
+ /**
+ * Refreshes all cluster information (state)
+ */
+ public function refresh()
+ {
+ $path = '_cluster/state';
+ $this->_response = $this->_client->request($path, Request::GET);
+ $this->_data = $this->getResponse()->getData();
+ }
+
+ /**
+ * Returns the response object
+ *
+ * @return \Elastica\Response Response object
+ */
+ public function getResponse()
+ {
+ return $this->_response;
+ }
+
+ /**
+ * Return list of index names
+ *
+ * @return array List of index names
+ */
+ public function getIndexNames()
+ {
+ $metaData = $this->_data['metadata']['indices'];
+
+ $indices = array();
+ foreach ($metaData as $key => $value) {
+ $indices[] = $key;
+ }
+
+ return $indices;
+ }
+
+ /**
+ * Returns the full state of the cluster
+ *
+ * @return array State array
+ * @link http://www.elasticsearch.org/guide/reference/api/admin-cluster-state.html
+ */
+ public function getState()
+ {
+ return $this->_data;
+ }
+
+ /**
+ * Returns a list of existing node names
+ *
+ * @return array List of node names
+ */
+ public function getNodeNames()
+ {
+ $data = $this->getState();
+
+ return array_keys($data['routing_nodes']['nodes']);
+ }
+
+ /**
+ * Returns all nodes of the cluster
+ *
+ * @return \Elastica\Node[]
+ */
+ public function getNodes()
+ {
+ $nodes = array();
+ foreach ($this->getNodeNames() as $name) {
+ $nodes[] = new Node($name, $this->getClient());
+ }
+
+ return $nodes;
+ }
+
+ /**
+ * Returns the client object
+ *
+ * @return \Elastica\Client Client object
+ */
+ public function getClient()
+ {
+ return $this->_client;
+ }
+
+ /**
+ * Returns the cluster information (not implemented yet)
+ *
+ * @param array $args Additional arguments
+ * @throws \Elastica\Exception\NotImplementedException
+ * @link http://www.elasticsearch.org/guide/reference/api/admin-cluster-nodes-info.html
+ */
+ public function getInfo(array $args)
+ {
+ throw new NotImplementedException('not implemented yet');
+ }
+
+ /**
+ * Return Cluster health
+ *
+ * @return \Elastica\Cluster\Health
+ * @link http://www.elasticsearch.org/guide/reference/api/admin-cluster-health.html
+ */
+ public function getHealth()
+ {
+ return new Health($this->getClient());
+ }
+
+ /**
+ * Return Cluster settings
+ *
+ * @return \Elastica\Cluster\Settings
+ */
+ public function getSettings()
+ {
+ return new Settings($this->getClient());
+ }
+
+ /**
+ * Shuts down the complete cluster
+ *
+ * @param string $delay OPTIONAL Seconds to shutdown cluster after (default = 1s)
+ * @return \Elastica\Response
+ * @link http://www.elasticsearch.org/guide/reference/api/admin-cluster-nodes-shutdown.html
+ */
+ public function shutdown($delay = '1s')
+ {
+ $path = '_shutdown?delay=' . $delay;
+
+ return $this->_client->request($path, Request::POST);
+ }
+}