vendor/m6web/amqp-bundle/src/AmqpBundle/Amqp/DataCollector.php line 41

Open in your IDE?
  1. <?php
  3. namespace M6Web\Bundle\AmqpBundle\Amqp;
  5. use Symfony\Component\HttpKernel\DataCollector\DataCollector as SymfonyDataCollector;
  6. use Symfony\Component\HttpFoundation\Response;
  7. use Symfony\Component\HttpFoundation\Request;
  9. /**
  10.  * Handle datacollector for amqp.
  11.  */
  12. class DataCollector extends SymfonyDataCollector
  13. {
  14.     /**
  15.      * @param string $name
  16.      *
  17.      * Construct the data collector
  18.      */
  19.     public function __construct(string $name)
  20.     {
  21.         $this->data['name'] = $name;
  22.         $this->reset();
  23.     }
  25.     /**
  26.      * Collect the data.
  27.      *
  28.      * @param Request    $request   The request object
  29.      * @param Response   $response  The response object
  30.      * @param \Exception $exception An exception
  31.      */
  32.     public function collect(Request $request, Response $response, \Exception $exception = null)
  33.     {
  34.     }
  36.     /**
  37.      * Listen for command event.
  38.      *
  39.      * @param object $event The event object
  40.      */
  41.     public function onCommand($event)
  42.     {
  43.         $this->data['commands'][] = array(
  44.             'command' => $event->getCommand(),
  45.             'arguments' => $event->getArguments(),
  46.             'executiontime' => $event->getExecutionTime(),
  47.         );
  48.     }
  50.     /**
  51.      * Return command list and number of times they were called.
  52.      *
  53.      * @return array The command list and number of times called
  54.      */
  55.     public function getCommands(): array
  56.     {
  57.         return $this->data['commands'];
  58.     }
  60.     /**
  61.      * Return the name of the collector.
  62.      *
  63.      * @return string data collector name
  64.      */
  65.     public function getName(): string
  66.     {
  67.         return $this->data['name'];
  68.     }
  70.     /**
  71.      * Return total command execution time.
  72.      *
  73.      * @return float
  74.      */
  75.     public function getTotalExecutionTime(): float
  76.     {
  77.         return (float) array_sum(array_column($this->data['commands'], 'executiontime'));
  78.     }
  80.     /**
  81.      * Get average execution time.
  82.      *
  83.      * @return float
  84.      */
  85.     public function getAvgExecutionTime(): float
  86.     {
  87.         return $this->getTotalExecutionTime() ? ($this->getTotalExecutionTime() / \count($this->data['commands'])) : (float) 0;
  88.     }
  90.     /**
  91.      * {@inheritdoc}
  92.      */
  93.     public function reset()
  94.     {
  95.         // Reset the current data, while keeping the 'name' intact.
  96.         $this->data = [
  97.             'name' => $this->data['name'],
  98.             'commands' => [],
  99.         ];
  100.     }
  101. }