*/ public $options; /** * The object cache instance. * * @var \RedisCachePro\ObjectCaches\MeasuredObjectCacheInterface */ public $cache; /** * Whether Relay is being used. * * @var bool */ public $usingRelay; /** * Holds the last 1000 measurement IDs. * * @var array */ protected $ids = []; /** * The measurements to display. * * @var \RedisCachePro\Metrics\Measurements|null */ protected $measurements; /** * Holds the default metrics. * * @var array */ protected $defaultMetrics = [ 'ms-total', 'ms-cache', 'ms-cache-ratio', 'hits', 'misses', 'hit-ratio', 'store-reads', 'store-writes', 'sql-queries', 'redis-hit-ratio', 'redis-ops-per-sec', 'redis-keys', 'relay-hits', 'relay-keys', 'relay-misses', 'relay-memory-ratio', 'relay-adaptive-loadfactor', ]; /** * Prints the metrics to the screen. * * @param bool $finish * @return void */ public function display($finish = false) { if ($this->_current === 1) { Streams::line($this->_message); } if (! $this->measurements) { return; } $metrics = empty($this->options['metrics']) ? $this->defaultMetrics : $this->options['metrics']; foreach ($this->measurements as $measurement) { $message = []; if ($measurement->hostname) { $message[] = sprintf("\e[32m%s %s:\e[0m", $measurement->rfc3339(), $measurement->hostname); } else { $message[] = sprintf("\e[32m%s:\e[0m", $measurement->rfc3339()); } if ($measurement->path) { $message[] = sprintf("\e[2mpath=\e[0m\e[32m\"%s\"\e[0m", urldecode($measurement->path)); } $message[] = $this->formatMeasurement( $measurement->toArray(), $metrics ); Streams::line(implode(' ', $message)); } $this->measurements = null; } /** * Prepare the metrics. * * @return void */ public function prepare() { if (empty($this->ids)) { $this->ids = $this->cache->measurements('-inf', '+inf', 0, 100)->pluck('id'); return; } $this->measurements = $this->cache->measurements( strval(microtime(true) - 2) )->filter(function ($measurement) { return ! in_array($measurement->id, $this->ids); }); array_push($this->ids, ...$this->measurements->pluck('id')); $this->ids = array_slice($this->ids, -1000); } /** * Format the given measurement in log format. * * @param array $measurement * @param array $metrics * @return string */ protected function formatMeasurement(array $measurement, array $metrics) { $format = "\e[2m%s\e[2m#\e[0m\e[%sm%s\e[0m\e[2m=\e[0m%s"; return implode(' ', array_filter( array_map(function ($null, $metric) use ($measurement, $format) { if (! isset($measurement[$metric])) { return; } switch (strstr($metric, '-', true)) { case 'redis': return sprintf($format, 'sample', 31, $metric, $measurement[$metric]); case 'relay': return sprintf($format, 'sample', 35, $metric, $measurement[$metric]); case 'ms': return sprintf($format, 'metric', 36, $metric, $measurement[$metric]); case 'sql': return sprintf($format, 'metric', 33, $metric, $measurement[$metric]); default: return sprintf($format, 'metric', 34, $metric, $measurement[$metric]); } }, array_flip($metrics), $metrics) )); } }