vendor/shopware/elasticsearch/Profiler/DataCollector.php line 18

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Elasticsearch\Profiler;
  5. use Symfony\Component\HttpFoundation\Request;
  6. use Symfony\Component\HttpFoundation\Response;
  7. use Symfony\Component\HttpKernel\DataCollector\DataCollector as BaseDataCollector;
  9. class DataCollector extends BaseDataCollector
  10. {
  11.     private ClientProfiler $client;
  13.     public function __construct(ClientProfiler $client)
  14.     {
  15.         $this->client = $client;
  16.     }
  18.     public function collect(Request $request, Response $response, ?\Throwable $exception = null): void
  19.     {
  20.         $this->data = [
  21.             'requests' => $this->client->getCalledRequests(),
  22.             'time' => 0,
  23.         ];
  25.         foreach ($this->client->getCalledRequests() as $calledRequest) {
  26.             $this->data['time'] += $calledRequest['time'];
  27.         }
  29.         $this->data['clusterInfo'] = $this->client->cluster()->health();
  30.         $this->data['indices'] = $this->client->cat()->indices();
  31.     }
  33.     public function getName(): string
  34.     {
  35.         return 'elasticsearch';
  36.     }
  38.     public function reset(): void
  39.     {
  40.         $this->data = [];
  41.         $this->client->resetRequests();
  42.     }
  44.     public function getTime(): float
  45.     {
  46.         $time = 0;
  48.         foreach ($this->data['requests'] as $calledRequest) {
  49.             $time += $calledRequest['time'];
  50.         }
  52.         return (int) ($time * 1000);
  53.     }
  55.     public function getRequestAmount(): int
  56.     {
  57.         return \count($this->data['requests']);
  58.     }
  60.     public function getRequests(): array
  61.     {
  62.         return $this->data['requests'];
  63.     }
  65.     public function getClusterInfo(): array
  66.     {
  67.         return $this->data['clusterInfo'];
  68.     }
  70.     public function getIndices(): array
  71.     {
  72.         return $this->data['indices'];
  73.     }
  74. }