PHPProm\Storage\Redis

Complexity

Total Complexity

8

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	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
 * Storage implementation using Redis.
 * @package PHPProm\Storage
 */
class Redis extends AbstractStorage {

    /**
     * @var \Redis
     * The Redis connection.
     */
    protected $redis;

    /**
     * Redis constructor.
     *
     * @param string $host
     * the connection host
     * @param null|string $password
     * the password for authentication, null to ignore
     * @param int $port
     * the connection port, default 6379
     * @param string $prefix
     * the global key prefix to use, default 'PHPProm:'
     * @param null|string $dbIndex
     * the Redis DB index to use, null to ignore
     */
    public function __construct($host, $password = null, $port = 6379, $prefix = 'PHPProm:', $dbIndex = null) {
        parent::__construct();
        $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);
    }

    /**
     * {@inheritdoc}
     */
    public function storeMeasurement($metric, $key, $value) {
        $this->redis->set($metric.':'.$key, $value);
    }

    /**
     * {@inheritdoc}
     */
    public function incrementMeasurement($metric, $key) {
        $this->redis->incr($metric.':'.$key);
    }

    /**
     * {@inheritdoc}
     */
    public function getMeasurements($metric, array $keys, $defaultValue = 'Nan') {
        $measurements = [];
        $prefixedKeys = array_map(function($key) use ($metric) {
            return $metric.':'.$key;
        }, $keys);
        foreach ($this->redis->mget($prefixedKeys) as $i => $value) {
            $measurements[$keys[$i]] = $value !== false ? (float)$value : $defaultValue;
        }
        return $measurements;
    }
}