Merge pull request #6 from evgeek/master

Added count to counter

Author: dezone

.gitignore

@@ -1,3 +1,4 @@
 /.idea
 /vendor/
 /.ecs_cache
+.phpunit.result.cache

src/Repositories/PrometheusRepository/NullPrometheusRepository.php

@@ -11,7 +11,10 @@ public function getMetrics(): array
         return [];
     }
 
-    public function writeCounter(string $measurement, array $trackerLabels = []): void
+    /**
+     * @param float|int $count
+     */
+    public function writeCounter(string $measurement, array $trackerLabels = [], $count = 1): void
     {
     }
 

src/Repositories/PrometheusRepository/PrometheusRepository.php

@@ -22,12 +22,15 @@ public function getMetrics(): array
         return $this->registry->getMetricFamilySamples();
     }
 
-    public function writeCounter(string $measurement, array $trackerLabels = []): void
+    /**
+     * @param float|int $count
+     */
+    public function writeCounter(string $measurement, array $trackerLabels = [], $count = 1): void
     {
         $labels = $this->labels($trackerLabels);
 
         $this->registry->getOrRegisterCounter($this->namespace(), $measurement, '', array_keys($labels))
-            ->inc($labels);
+            ->incBy($count, $labels);
     }
 
     public function writeGauge(string $measurement, $value, array $trackerLabels = []): void

src/Repositories/PrometheusRepository/PrometheusRepositoryContract.php

@@ -7,7 +7,10 @@
 interface PrometheusRepositoryContract
 {
     public function getMetrics(): array;
-    public function writeCounter(string $measurement, array $trackerLabels): void;
+    /**
+     * @param float|int $count
+     */
+    public function writeCounter(string $measurement, array $trackerLabels, $count): void;
     public function writeGauge(string $measurement, $value, array $trackerLabels): void;
     public function writeHistogram(string $measurement, $value, array $trackerLabels, array $buckets): void;
     public function writeSummary(

src/Services/Adapters/PrometheusCounterAdapter.php

@@ -8,6 +8,6 @@ class PrometheusCounterAdapter extends BasePrometheusAdapter
 {
     public function write(string $measurement, $value = null, array $tags = []): void
     {
-        $this->repository->writeCounter($measurement, $tags);
+        $this->repository->writeCounter($measurement, $tags, $value);
     }
 }

src/Trackers/JobsLog/JobsLogTracker.php

@@ -27,7 +27,7 @@ public function write(Job $job, string $eventName): void
             return;
         }
 
-        $this->adapter->write($this->metricConfig['measurement'], '', [
+        $this->adapter->write($this->metricConfig['measurement'], 1, [
             'jobName' => $job->resolveName(),
             'eventName' => $eventName,
         ]);

tests/Unit/Trackers/JobsLog/JobsLogTrackerTest.php

@@ -44,7 +44,7 @@ public function correctWrite(): void
         $eventAdapter
             ->expects($this->once())
             ->method('write')
-            ->with($measurement, '', [
+            ->with($measurement, 1, [
                 'eventName' => 'processing',
                 'jobName' => $jobName,
             ]);