1 files changed, 113 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..1af94b07
--- /dev/null
+++ b/vendor/ruflin/elastica/lib/Elastica/Node/Stats.php
@@ -0,0 +1,113 @@
+<?php
+namespace Elastica\Node;
+
+use Elastica\Node as BaseNode;
+use Elastica\Request;
+
+/**
+ * Elastica cluster node object.
+ *
+ * @author Nicolas Ruflin <spam@ruflin.com>
+ *
+ * @link http://www.elastic.co/guide/en/elasticsearch/reference/current/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;
+            }
+        }
+
+        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']);
+    }
+}