Batch Metrics

config/collector.php

@@ -2,8 +2,18 @@
 
 return [
 
+	/**
+	 * The API endpoint for logs
+	 */
     'endpoint' => 'http://collector.test:8000',
 
-    'api_key' => '123456',
+    /**
+     * Your API key
+     */
+    'api_key'  => '123456',
 
+    /**
+     * Should batch requests
+     */
+    'batch'    => true,
 ];

src/Collector.php

@@ -2,6 +2,7 @@
 
 namespace Turbo124\Collector;
 
+use Illuminate\Support\Facades\Cache;
 use Turbo124\Collector\Collector\Generator;
 use Turbo124\Collector\Jobs\CreateMetric;
 
@@ -54,4 +55,9 @@ public function queue()
     {
         CreateMetric::dispatch($this->metric);
     }
+
+    public function batch()
+    {
+        Cache::tags(['collector'])->put(config('collector.api_key'), $this->metric);
+    }
 }

src/Collector/Generator.php

@@ -11,6 +11,11 @@ private function endPoint()
 		return config('collector.endpoint') . '/collect';
 	}
 
+	private function batchEndPoint()
+	{
+		return config('collector.endpoint') . '/collect/batch';
+	}
+
 	private function apiKey()
 	{
 		return config('collector.api_key');
@@ -28,6 +33,14 @@ public function fire($metric)
 		return $this->handleResponse($response);
 	}
 
+	public function batchFire($metric_array)
+	{
+		$client = $this->httpClient();	
+		$response = $client->request('POST',$this->batchEndPoint(), ['form_params' => $metric_array]);
+		return $this->handleResponse($response);
+	}
+
+
 	private function handleResponse($response)
 	{
 		switch ($response->getStatusCode()) {

src/CollectorServiceProvider.php

@@ -2,8 +2,10 @@
 
 namespace Turbo124\Collector;
 
+use Illuminate\Console\Scheduling\Schedule;
 use Illuminate\Support\ServiceProvider;
 use Turbo124\Collector\Collector;
+use Turbo124\Collector\Jobs\BatchMetrics;
 
 class CollectorServiceProvider extends ServiceProvider
 {
@@ -38,5 +40,12 @@ public function register()
         $this->app->singleton('collector', function () {
             return new Collector;
         });
+
+        /* Register the scheduler */
+        $this->app->booted(function () {
+            $schedule = app(Schedule::class);
+            $schedule->job(new BatchMetrics())->everyFiveMinutes();
+        });
+
     }
 }

src/Jobs/BatchMetrics.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace Turbo124\Collector\Jobs;
+
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Cache;
+use Turbo124\Collector\Collector\Generator;
+
+class BatchMetrics
+{
+    use Dispatchable;
+
+    /**
+     * Create a new job instance.
+     *
+     * @return void
+     */
+
+    public function __construct()
+    {
+    }
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+
+        $metrics = Cache::tags(['collector'])->get(config('collector.api_key'));
+
+        $generator = new Generator();
+        $generator->batchFire($metrics);
+
+        Cache::tags(['collector'])->flush();
+
+    }
+}