Added application.php and added query latency

Author: Илья

slo-workload/application.php

@@ -0,0 +1,29 @@
+<?php
+require_once './vendor/autoload.php';
+/**
+ * @var \YdbPlatform\Ydb\Slo\Command[] $commands
+ */
+$commands = [
+    "create"    =>new \YdbPlatform\Ydb\Slo\Commands\CreateCommand(),
+    "run"       =>new \YdbPlatform\Ydb\Slo\Commands\RunCommand(),
+    "cleanup"   =>new \YdbPlatform\Ydb\Slo\Commands\CleanupCommand()
+];
+
+if ($argc == 1 || !isset($commands[$argv[1]])){
+    echo "Commands:\n";
+    foreach ($commands as $name=>$command) {
+        echo "- ".$name."\t"."- ".$command->description."\n";
+    }
+    exit(0);
+}
+
+if ($argc<4||substr($argv[2],0,4)!="grpc" || substr($argv[3],0,1)!="/"){
+    echo $commands[$argv[1]]->help;
+    exit(0);
+}
+
+$data = $commands[$argv[1]]->generateOptions(array_slice($argv, 4));
+
+$command = $commands[$argv[1]];
+
+$commands[$argv[1]]->execute($argv[2],$argv[3], $data);

slo-workload/src/Commands/RunCommand.php

@@ -242,6 +242,7 @@ protected function metricsJob(int $reportPeriod, float $startTime, int $time, st
         $pushGateway = new PushGateway($promPgw);
 
         $latencies = $registry->getOrRegisterSummary('', 'latency', 'summary of latencies in ms', ['jobName', 'status'], 15, [0.5, 0.99, 0.999]);
+        $queryLatencies = $registry->getOrRegisterSummary('', 'query_latency', 'summary of latencies in ms in query',[], 15, [0.5, 0.99, 0.999]);
         $oks = $registry->getOrRegisterGauge('', 'oks', 'amount of OK requests', ['jobName']);
         $notOks = $registry->getOrRegisterGauge('', 'not_oks', 'amount of not OK requests', ['jobName']);
         $inflight = $registry->getOrRegisterGauge('', 'inflight', 'amount of requests in flight', ['jobName']);
@@ -269,6 +270,7 @@ protected function metricsJob(int $reportPeriod, float $startTime, int $time, st
 
         while (microtime(true) <= $startTime + $time) {
             msg_receive($msgQueue, Utils::MSG_TYPE, $msgType, PHP_INT_MAX, $message);
+            $queryLatencies->observe($this->getLatency($message["sent"]));
             switch ($message['type']) {
                 case 'reset':
                     $pushGateway->delete('workload-php', [

slo-workload/src/Utils.php

@@ -71,6 +71,7 @@ public static function metricFail(string $job, int $queueId, int $attemps, strin
 
     public static function postData(int $queueId, array $data)
     {
+        $data["sent"] = microtime(true);
         $msgQueue = msg_get_queue($queueId);
         msg_send($msgQueue, static::MSG_TYPE, $data);
     }