Add Redis adapter

README.md

@@ -18,6 +18,7 @@ Currently supported backends:
 * Null (Dummy that does nothing)
 * StatsD
 * Zabbix
+* Redis
 
 ## Installation
 

composer.json

@@ -18,7 +18,8 @@
     "suggest": {
         "corley/influxdb-sdk": "For InfluxDB integration",
         "okitsu/zabbix-sender": "For zabbix integration",
-        "kriswallsmith/buzz": "For Librato integration"
+        "kriswallsmith/buzz": "For Librato integration",
+        "colinmollenhour/credis": "For Redis integration"
     },
     "require": {
         "psr/log": "~1.0"
@@ -30,7 +31,8 @@
         "okitsu/zabbix-sender": "*@dev",
         "symfony/config": "~2.3",
         "symfony/dependency-injection": "~2.3",
-        "symfony/http-kernel": "~2.3"
+        "symfony/http-kernel": "~2.3",
+        "colinmollenhour/credis": "^1.5"
     },
     "autoload": {
         "psr-4": {

example/redis.php

@@ -0,0 +1,16 @@
+<?php
+
+require_once __DIR__.'/../vendor/autoload.php';
+
+$credis = new Credis_Client();
+
+$metrics = \Beberlei\Metrics\Factory::create('credis', array(
+    'credis_client' => $credis,
+));
+
+while (true) {
+    $metrics->increment('foo.bar');
+    $metrics->decrement('foo.baz');
+    $metrics->measure('foo', rand(1, 10));
+    usleep(10000);
+}

src/Beberlei/Bundle/MetricsBundle/DependencyInjection/BeberleiMetricsExtension.php

@@ -90,6 +90,14 @@ private function createCollector($type, $config)
                 $definition->replaceArgument(0, $sender);
                 $definition->replaceArgument(1, $config['prefix']);
 
+                return $definition;
+            case 'credis':
+                $credis_client = new Definition('Credis_Client');
+                $credis_client ->addArgument($config['host'] ?: 'localhost');
+                $credis_client ->addArgument($config['port'] ?: 6379);
+
+                $definition->replaceArgument(0, $credis_client);
+
                 return $definition;
             default:
                 throw new \InvalidArgumentException(sprintf('The type "%s" is not supported', $type));

src/Beberlei/Bundle/MetricsBundle/DependencyInjection/Configuration.php

@@ -28,6 +28,7 @@ public function getConfigTreeBuilder()
                         ->children()
                             ->scalarNode('type')->isRequired()->end()
                             ->scalarNode('connection')->defaultNull()->end()
+                            ->scalarNode('credis_client')->defaultNull()->end()
                             ->scalarNode('file')->defaultNull()->end()
                             ->scalarNode('host')->defaultNull()->end()
                             ->scalarNode('password')->defaultNull()->end()

src/Beberlei/Bundle/MetricsBundle/Resources/config/metrics.xml

@@ -43,6 +43,9 @@
             <argument /> <!-- sender, set by the extension -->
             <argument /> <!-- host, set by the extension -->
         </service>
+        <service id="beberlei_metrics.collector_proto.credis" class="Beberlei\Metrics\Collector\CRedis" abstract="true">
+            <argument /> <!-- credis_client, set by the extension -->
+        </service>
     </services>
 
 </container>

src/Beberlei/Bundle/MetricsBundle/Tests/DependencyInjection/BeberleiMetricsExtensionTest.php

@@ -187,6 +187,32 @@ public function testWithZabbix()
         $this->assertInstanceOf('Net\Zabbix\Sender', $sender);
     }
 
+    public function testWithCRedis()
+    {
+        $container = $this->createContainer(array(
+            'default' => 'simple',
+            'collectors' => array(
+                'simple' => array(
+                    'type' => 'credis',
+                    'credis_client' => 'credis'
+                ),
+                'full' => array(
+                    'type' => 'credis',
+                    'credis_client' => 'credis',
+                    'host' => 'redis.localhost',
+                    'port' => 1234
+                )
+            ),
+        ));
+
+        $collector = $container->get('beberlei_metrics.collector.simple');
+        $this->assertInstanceOf('Beberlei\Metrics\Collector\CRedis', $collector);
+
+        $collector = $container->get('beberlei_metrics.collector.full');
+        $this->assertInstanceOf('Beberlei\Metrics\Collector\CRedis', $collector);
+    }
+
+
     private function createContainer($configs)
     {
         $container = new ContainerBuilder();

src/Beberlei/Metrics/Collector/CRedis.php

@@ -0,0 +1,66 @@
+<?php
+/**
+ * Beberlei Metrics.
+ *
+ * LICENSE
+ *
+ * This source file is subject to the MIT license that is bundled
+ * with this package in the file LICENSE.txt.
+ * If you did not receive a copy of the license and are unable to
+ * obtain it through the world-wide-web, please send an email
+ * to kontakt@beberlei.de so I can send you a copy immediately.
+ */
+namespace Beberlei\Metrics\Collector;
+
+use Credis_Client;
+
+class CRedis implements Collector
+{
+    /** @var \Credis_Client */
+    private $credis_client;
+
+    public function __construct(Credis_Client $credis_client)
+    {
+        $this->credis_client = $credis_client;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function increment($variable)
+    {
+        $this->credis_client->incr($variable);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function decrement($variable)
+    {
+        $this->credis_client->decr($variable);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function timing($variable, $time)
+    {
+        $this->credis_client->set($variable, $time);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function measure($variable, $value)
+    {
+        $this->credis_client->set($variable, $value);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function flush()
+    {
+        // No Need to Implement flush() method for now.
+    }
+}

src/Beberlei/Metrics/Factory.php

@@ -53,7 +53,7 @@ public static function create($type, array $options = array())
                 if (!isset($options['host']) && isset($options['port'])) {
                     throw new MetricsException('You should specified a host if you specified a port.');
                 }
-                
+
                 $prefix = isset($options['prefix']) ? $options['prefix'] : '';
 
                 return new Collector\StatsD($options['host'], $options['port'], $prefix);
@@ -135,6 +135,13 @@ public static function create($type, array $options = array())
 
                 return new Collector\InfluxDB($options['client']);
 
+            case 'credis':
+                if (!isset($options['credis_client'])) {
+                    throw new MetricsException('Missing \'credis_client\' key for CRedis collector.');
+                }
+
+                return new Collector\CRedis($options['credis_client']);
+
             case 'null':
                 return new Collector\NullCollector();
 

src/Beberlei/Metrics/Tests/FactoryTest.php

@@ -24,6 +24,7 @@ public function getCreateValidMetricTests()
             array('Beberlei\Metrics\Collector\Logger', 'logger', array('logger' => new NullLogger())),
             array('Beberlei\Metrics\Collector\NullCollector', 'null'),
             array('Beberlei\Metrics\Collector\InfluxDB', 'influxdb', array('client' => $this->getMockBuilder('\\InfluxDB\\Client')->disableOriginalConstructor()->getMock())),
+            array('Beberlei\Metrics\Collector\CRedis', 'credis', array('credis_client' => $this->getMockBuilder('Credis_Client')->disableOriginalConstructor()->getMock()))
         );
     }
 
@@ -53,6 +54,7 @@ public function getCreateThrowExceptionIfOptionsAreInvalidTests()
             array('connection is required for Doctrine DBAL collector.', 'doctrine_dbal'),
             array('Missing \'logger\' key with logger service.', 'logger'),
             array('Missing \'client\' key for InfluxDB collector.', 'influxdb'),
+            array('Missing \'credis_client\' key for CRedis collector.', 'credis'),
         );
     }