NOJIRA: Adding a list of stats and then send all together.

Author: toni.lopez

README.md

@@ -38,15 +38,18 @@ $configuration->setHost($config['host'])
 
 $statsClient = new Statsd\Client($configuration);
 
-// send stats
-$statsClient->sendStat(
+// add stats (you can also add an array of stats with addStats())
+$statsClient->addStat(
     new Statsd\Domain\Stat(
         'endpoints.' . $path, // that will be your stat namespace
         $executionTime, // calculate it in microseconds
         Statsd\Domain\Stat::TIME_MS
     )
 );
 
+// send them
+$statsClient->sendStats();
+
 ```
 
 You can use TIME_MS, COUNT, GAUGE or SET (ms, c, g, s) as type of stats.

src/Statsd/Client.php

@@ -20,50 +20,66 @@
 class Client
 {
     /**
-     * @var string
+     * @var Configuration
      */
-    private $namespace;
+    private $configuration;
 
     /**
-     * @var Resource
+     * @var Logger|null
      */
-    private $socket;
+    private $logger;
 
     /**
-     * @var Logger|null
+     * @var array
      */
-    private $logger;
+    private $stats = array();
 
     /**
      * @param Configuration $configuration
      * @param Logger|null $logger
      */
     public function __construct(Configuration $configuration, $logger = null)
     {
-        $this->namespace = $configuration->getNamespace();
-
-        $socketUrl = sprintf('udp://' . $configuration->getHost());
-        $this->socket = fsockopen($socketUrl, $configuration->getPort());
-
+        $this->configuration = $configuration;
         $this->logger = $logger;
     }
 
     /**
      * @param Stat $stat
      */
-    public function sendStat(Stat $stat)
+    public function addStat(Stat $stat)
     {
-        $msg = sprintf(
-            "%s:%s|%s",
-            $this->namespace . '.' . $stat->getNamespace(),
-            $stat->getValue(),
-            $stat->getType()
-        );
-
-        if (null !== $this->logger) {
-            $this->logger->info('Sending metrics: ' . $msg);
+        $this->stats[] = $stat;
+    }
+
+    /**
+     * @param array $stats
+     */
+    public function addStats(array $stats)
+    {
+        foreach ($stats as $stat) {
+            $this->addStat($stat);
+        }
+    }
+
+    public function sendStats()
+    {
+        $namespace = $this->configuration->getNamespace();
+
+        $socketUrl = sprintf('udp://' . $this->configuration->getHost());
+        $socket = fsockopen($socketUrl, $this->configuration->getPort());
+
+        foreach ($this->stats as $key => $stat) {
+            $msg = $namespace . '.' . (string) $stat;
+
+            if (null !== $this->logger) {
+                $this->logger->info('Sending metrics: ' . $msg);
+            }
+
+            fwrite($socket, $msg);
+            unset($this->stats[$key]);
         }
 
-        fwrite($this->socket, $msg);
+        fclose($socket);
     }
 }

src/Statsd/Domain/Stat.php

@@ -114,4 +114,12 @@ public function getValue()
     {
         return $this->value;
     }
+
+    /**
+     * @return string
+     */
+    public function __toString()
+    {
+        return sprintf('%s:%s|%s', $this->namespace, $this->value, $this->type);
+    }
 }

tests/Statsd/Tests/Domain/StatTest.php

@@ -159,4 +159,14 @@ public function testGetDefaultType()
             'Unexpected default type from stat.'
         );
     }
+
+    public function testToString()
+    {
+        $stat = new Stat('name.space', 23.4, Stat::TIME_MS);
+        $this->assertSame(
+            (string) $stat,
+            'name.space:23.4|ms',
+            'Unexpected string cast of the stat.'
+        );
+    }
 }