Add Ingest\ProcessorGrok endpoint

Author: polyfractal

src/Elasticsearch/Endpoints/Ingest/ProcessorGrok.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace Elasticsearch\Endpoints\Ingest\Pipeline;
+
+use Elasticsearch\Common\Exceptions;
+use Elasticsearch\Endpoints\AbstractEndpoint;
+
+/**
+ * Class ProcessorGrok
+ *
+ * @category Elasticsearch
+ * @package  Elasticsearch\Endpoints\Ingest
+ * @author   Zachary Tong <[email protected]>
+ * @license  http://www.apache.org/licenses/LICENSE-2.0 Apache2
+ * @link     http://elastic.co
+ */
+class ProcessorGrok extends AbstractEndpoint
+{
+    /**
+     * @throws \Elasticsearch\Common\Exceptions\RuntimeException
+     * @return string
+     */
+    public function getURI()
+    {
+        return "/_ingest/processor/grok";
+    }
+
+    /**
+     * @return string[]
+     */
+    public function getParamWhitelist()
+    {
+        return [];
+    }
+
+    /**
+     * @return string
+     */
+    public function getMethod()
+    {
+        return 'GET';
+    }
+}

src/Elasticsearch/Namespaces/IngestNamespace.php

@@ -4,6 +4,7 @@
 
 use Elasticsearch\Endpoints\Ingest\Pipeline\Delete;
 use Elasticsearch\Endpoints\Ingest\Pipeline\Get;
+use Elasticsearch\Endpoints\Ingest\Pipeline\ProcessorGrok;
 use Elasticsearch\Endpoints\Ingest\Pipeline\Put;
 use Elasticsearch\Endpoints\Ingest\Simulate;
 
@@ -111,4 +112,22 @@ public function simulate($params = array())
 
         return $this->performRequest($endpoint);
     }
+
+    /**
+     * $params[]
+     *
+     * @param $params array Associative array of parameters
+     *
+     * @return array
+     */
+    public function processorGrok($params = [])
+    {
+        /** @var callback $endpointBuilder */
+        $endpointBuilder = $this->endpoints;
+
+        /** @var ProcessorGrok $endpoint */
+        $endpoint = $endpointBuilder('Ingest\ProcessorGrok');
+
+        return $this->performRequest($endpoint);
+    }
 }