Add elastic search support

Check/ElasticSearchCollection.php

@@ -0,0 +1,37 @@
+<?php
+
+namespace Liip\MonitorBundle\Check;
+
+use Laminas\Diagnostics\Check\CheckCollectionInterface;
+use Laminas\Diagnostics\Check\ElasticSearch;
+
+/**
+ * @author Son Bui <[email protected]>
+ */
+class ElasticSearchCollection implements CheckCollectionInterface
+{
+    private $checks = [];
+
+    public function __construct(array $configs)
+    {
+        foreach ($configs as $name => $config) {
+            if (isset($config['dsn'])) {
+                $config = \array_merge($config, \parse_url($config['dsn']));
+            }
+
+            $elasticSearchUrl = sprintf('%s://%s:%s', $config['scheme'], $config['host'], $config['port']);
+            $check = new ElasticSearch($elasticSearchUrl);
+            $check->setLabel(\sprintf('Elastic Search "%s"', $name));
+
+            $this->checks[\sprintf('elastic_search_%s', $name)] = $check;
+        }
+    }
+
+    /**
+     * @return array|\Traversable
+     */
+    public function getChecks()
+    {
+        return $this->checks;
+    }
+}

DependencyInjection/Configuration.php

@@ -279,6 +279,22 @@ private function createGroupsNode(): NodeDefinition
                             ->end()
                         ->end()
                     ->end()
+                    ->arrayNode('elastic_search')
+                        ->info('Validate that an Elasticsearch service is running')
+                        ->useAttributeAsKey('name')
+                        ->beforeNormalization()
+                            ->ifString()
+                            ->then(function ($v) { return ['dsn' => $v]; })
+                        ->end()
+                        ->prototype('array')
+                            ->children()
+                                ->scalarNode('scheme')->defaultValue('http')->end()
+                                ->scalarNode('host')->defaultValue('localhost')->end()
+                                ->integerNode('port')->defaultValue(9200)->end()
+                                ->scalarNode('dsn')->defaultNull()->end()
+                            ->end()
+                        ->end()
+                    ->end()
                     ->arrayNode('http_service')
                         ->info('Attempt connection to given HTTP host and (optionally) check status code and page content')
                         ->useAttributeAsKey('name')

DependencyInjection/LiipMonitorExtension.php

@@ -125,6 +125,7 @@ private function setParameters(ContainerBuilder $container, $checkName, $group,
             case 'memcache':
             case 'memcached':
             case 'redis':
+            case 'elastic_search':
             case 'rabbit_mq':
             case 'stream_wrapper_exists':
             case 'file_ini':

README.md

@@ -380,6 +380,17 @@ liip_monitor:
                         # or
                         dsn: redis://localhost:6379
 
+                # Validate that an Elasticsearch service is running
+                elastic_search:
+
+                    # Prototype
+                    name:
+                        scheme:               http
+                        host:                 localhost
+                        port:                 9200
+                        # or
+                        dsn: http://localhost:9200
+
                 # Attempt connection to given HTTP host and (optionally) check status code and page content
                 http_service:
 

Resources/config/checks/elastic_search.xml

@@ -0,0 +1,13 @@
+<?xml version="1.0" ?>
+
+<container xmlns="http://symfony.com/schema/dic/services"
+           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+           xsi:schemaLocation="http://symfony.com/schema/dic/services http://symfony.com/schema/dic/services/services-1.0.xsd">
+
+    <services>
+        <service id="liip_monitor.check.elastic_search" public="true" class="Liip\MonitorBundle\Check\ElasticSearchCollection">
+            <argument>%%liip_monitor.check.elastic_search%%</argument>
+            <tag name="liip_monitor.check_collection" />
+        </service>
+    </services>
+</container>