LeoCarmo\CircuitBreaker\Adapters\RedisClusterAdapter

Complexity

Total Complexity

3

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Importance

Changes	5
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	incrementFailure()	0	12	2
A	setSuccess()	0	7	1

<?php declare(strict_types=1);

namespace LeoCarmo\CircuitBreaker\Adapters;

class RedisClusterAdapter extends RedisAdapter
{
    /**
     * @param string $service
     * @param int $timeWindow
     * @return bool
     */
    public function incrementFailure(string $service, int $timeWindow): bool
    {
        $serviceName = $this->makeNamespace($service) . ':failures';

        $this->resetKeyIfInfiniteTTL($serviceName);

        if (! $this->redis->get($serviceName)) {
            $this->redis->incr($serviceName);
            return (bool) $this->redis->expire($serviceName, $timeWindow);
        }

        return (bool) $this->redis->incr($serviceName);
    }

    /**
     * @param string $service
     */
    public function setSuccess(string $service): void
    {
        $serviceName = $this->makeNamespace($service);

        $this->redis->del($serviceName . ':open');
        $this->redis->del($serviceName . ':failures');
        $this->redis->del($serviceName . ':half_open');
    }
}