for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
/*
* This file is part of the PHPProm package.
*
* (c) Philip Lehmann-Böhm <[email protected]>
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace PHPProm\Storage;
class Redis implements StorageInterface {
protected $redis;
public function __construct($host, $password = null, $port = 6379, $prefix = 'PHPProm:', $dbIndex = null) {
$this->redis = new \Redis();
$this->redis->connect($host, $port);
if ($password !== null) {
$this->redis->auth($password);
}
if ($dbIndex !== null) {
$this->redis->select($dbIndex);
$this->redis->setOption(\Redis::OPT_PREFIX, $prefix);
public function storeMeasurement($prefix, $key, $value) {
$this->redis->set($prefix.':'.$key, $value);
public function incrementMeasurement($prefix, $key) {
$this->redis->incr($prefix.':'.$key);
public function getMeasurements($prefix, array $keys, $defaultValue = 'Nan') {
$measurements = [];
$prefixedKeys = array_map(function($key) use ($prefix) {
return $prefix.':'.$key;
}, $keys);
foreach ($this->redis->mget($prefixedKeys) as $i => $value) {
$measurements[$keys[$i]] = $value !== false ? (float)$value : $defaultValue;
return $measurements;
philiplb /
PHPProm
