ajout heimdall

2025-01-01 11:24:01 +01:00
parent f8be42e486
commit c52f60fca9
1477 changed files with 15692 additions and 0 deletions
--- a/heimdall/config/www/SupportedApps/Jaeger/Jaeger.php
+++ b/heimdall/config/www/SupportedApps/Jaeger/Jaeger.php
@@ -0,0 +1,77 @@
+<?php namespace App\SupportedApps\Jaeger;
+
+class Jaeger extends \App\SupportedApps implements \App\EnhancedApps {
+
+    public $config;
+
+    function __construct() {
+    }
+
+    private function tracesUrl() {
+        $service = $this->config->service;
+        $operation = $this->config->operation;
+        $tags = $this->config->tags;
+        $lookback = $this->config->lookback;
+        $minDuration = $this->config->minDuration;
+        $maxDuration = $this->config->maxDuration;
+        $limit = $this->config->limit;
+        
+        $endpoint = 'api/traces?service='.urlencode($service);
+        if (!empty($operation)) $endpoint .= '&operation='.urlencode($operation);
+        if (!empty($tags)) $endpoint .= '&tags='. urlencode($tags);
+        if (!empty($lookback)) {
+            $lookbackFormatted = str_replace('d', ' days', str_replace('h', ' hours', $lookback));
+            $timestampForOffset = time();
+            $offset = $timestampForOffset - strtotime('-'.$lookbackFormatted, $timestampForOffset);
+
+            $timestamp = microtime(true);
+            $end = sprintf('%0.0f', $timestamp * 1000000);
+            $start = sprintf('%0.0f', ($timestamp - $offset) * 1000000);
+            $endpoint .= '&lookback='.urlencode($lookback);
+            $endpoint .= '&start='.$start;
+            $endpoint .= '&end='.$end;
+        }
+        if (!empty($minDuration)) $endpoint .= '&minDuration='.urlencode($minDuration);
+        if (!empty($maxDuration)) $endpoint .= '&maxDuration='.urlencode($maxDuration);
+        if (!empty($limit)) $endpoint .= '&limit='.urlencode($limit);
+        return $this->url($endpoint);
+    }
+
+    public function test()
+    {
+        $test = parent::appTest($this->tracesUrl());
+        echo $test->status;
+    }
+
+    public function livestats()
+    {
+        $status = 'inactive';
+        $res = parent::execute($this->tracesUrl());
+        $details = json_decode($res->getBody());
+
+        $data = [];
+
+        if($details) {
+            $status = 'active';
+            $data['traces'] = count($details->data);
+            $data['avg_duration'] = 0;
+            if ($data['traces'] > 0) {
+                $durations = array_map(function($dataItem) {
+                    $max = 0;
+                    foreach ($dataItem->spans as $spanItem) {
+                        $max = max($max, $spanItem->duration);
+                    } 
+                    return $max;
+                }, $details->data);
+                $data['avg_duration'] = round(array_sum($durations)/$data['traces']/1000, 1);
+            }
+        }
+        return parent::getLiveStats($status, $data);
+        
+    }
+    public function url($endpoint)
+    {
+        $api_url = parent::normaliseurl($this->config->url).$endpoint;
+        return $api_url;
+    }
+}