1 files changed, 115 insertions, 0 deletions
diff --git a/vendor/ruflin/elastica/lib/Elastica/Node/Stats.php b/vendor/ruflin/elastica/lib/Elastica/Node/Stats.php
new file mode 100644
index 00000000..d918e686
--- /dev/null
+++ b/vendor/ruflin/elastica/lib/Elastica/Node/Stats.php
@@ -0,0 +1,115 @@
+<?php
+
+namespace Elastica\Node;
+
+use Elastica\Node as BaseNode;
+use Elastica\Request;
+
+/**
+ * Elastica cluster node object
+ *
+ * @category Xodoa
+ * @package Elastica
+ * @author Nicolas Ruflin <spam@ruflin.com>
+ * @link http://www.elasticsearch.org/guide/reference/api/admin-indices-status.html
+ */
+class Stats
+{
+    /**
+     * Response
+     *
+     * @var \Elastica\Response Response object
+     */
+    protected $_response = null;
+
+    /**
+     * Stats data
+     *
+     * @var array stats data
+     */
+    protected $_data = array();
+
+    /**
+     * Node
+     *
+     * @var \Elastica\Node Node object
+     */
+    protected $_node = null;
+
+    /**
+     * Create new stats for node
+     *
+     * @param \Elastica\Node $node Elastica node object
+     */
+    public function __construct(BaseNode $node)
+    {
+        $this->_node = $node;
+        $this->refresh();
+    }
+
+    /**
+     * Returns all node stats as array based on the arguments
+     *
+     * Several arguments can be use
+     * get('index', 'test', 'example')
+     *
+     * @return array Node stats for the given field or null if not found
+     */
+    public function get()
+    {
+        $data = $this->getData();
+
+        foreach (func_get_args() as $arg) {
+            if (isset($data[$arg])) {
+                $data = $data[$arg];
+            } else {
+                return null;
+            }
+        }
+
+        return $data;
+    }
+
+    /**
+     * Returns all stats data
+     *
+     * @return array Data array
+     */
+    public function getData()
+    {
+        return $this->_data;
+    }
+
+    /**
+     * Returns node object
+     *
+     * @return \Elastica\Node Node object
+     */
+    public function getNode()
+    {
+        return $this->_node;
+    }
+
+    /**
+     * Returns response object
+     *
+     * @return \Elastica\Response Response object
+     */
+    public function getResponse()
+    {
+        return $this->_response;
+    }
+
+    /**
+     * Reloads all nodes information. Has to be called if informations changed
+     *
+     * @return \Elastica\Response Response object
+     */
+    public function refresh()
+    {
+        $path = '_nodes/' . $this->getNode()->getName() . '/stats';
+        $this->_response = $this->getNode()->getClient()->request($path, Request::GET);
+        $data = $this->getResponse()->getData();
+        $this->_data = reset($data['nodes']);
+    }
+}