CircuitBreakerBundle\Traits\CircuitBreakerAwareTrait

Complexity

Total Complexity

4

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setCircuitBreaker()	0	4	1
A	setEventDispatcher()	0	4	1
A	notifyServiceIsDown()	0	7	1
A	notifyServiceIsUp()	0	7	1

<?php declare(strict_types = 1);

namespace CircuitBreakerBundle\Traits;

use CircuitBreakerBundle\Service\CircuitBreakerService;
use CircuitBreakerBundle\Event\CircuitBreakerEvent;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

trait CircuitBreakerAwareTrait
{
    /**
     * @var CircuitBreakerService
     */
    private $circuitBreaker;

    /**
     * @var EventDispatcherInterface
     */
    private $eventDispatcher;

    /**
     * Set the circuit breaker service
     *
     * @param CircuitBreakerService $circuitBreaker
     */
    public function setCircuitBreaker(CircuitBreakerService $circuitBreaker)
    {
        $this->circuitBreaker = $circuitBreaker;
    }

    /**
     * @param EventDispatcherInterface $eventDispatcher
     */
    public function setEventDispatcher(EventDispatcherInterface $eventDispatcher)
    {
        $this->eventDispatcher = $eventDispatcher;
    }


    /**
     * Send an event to notify the circuit breaker that a given service is down
     *
     * @param string $serviceName The service which is down
     */
    public function notifyServiceIsDown(string $serviceName)
    {
        $this->eventDispatcher->dispatch(
            'circuit.breaker',
            new CircuitBreakerEvent($serviceName, CircuitBreakerService::STATUS_DOWN)
        );
    }

    /**
     * Send an event to notify the circuit breaker that a given service is up
     *
     * @param string $serviceName The service which is up
     */
    public function notifyServiceIsUp(string $serviceName)
    {
        $this->eventDispatcher->dispatch(
            'circuit.breaker',
            new CircuitBreakerEvent($serviceName, CircuitBreakerService::STATUS_UP)
        );
    }
}