PHPProm\Storage\Redis

Complexity

Total Complexity

8

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	3
A	storeMeasurement()	0	3	1
A	incrementMeasurement()	0	3	1
A	getMeasurements()	0	10	3

<?php

/*
 * This file is part of the PHPProm package.
 *
 * (c) Philip Lehmann-Böhm <philip@philiplb.de>
 *
 * 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;
    }
}