PoolCounterFactory.php

Go to the documentation of this file.

<?php
namespace MediaWiki\PoolCounter;
 
use Psr\Log\LoggerInterface;
use Wikimedia\Telemetry\TracerInterface;
 
class PoolCounterFactory {
    private ?PoolCounterConnectionManager $manager = null;
    private ?array $typeConfigs;
    private array $clientConf;
    private LoggerInterface $logger;
    private TracerInterface $tracer;
 
    public function __construct( ?array $typeConfigs, array $clientConf,
        LoggerInterface $logger, TracerInterface $tracer ) {
        $this->typeConfigs = $typeConfigs;
        $this->clientConf = $clientConf;
        $this->logger = $logger;
        $this->tracer = $tracer;
    }
 
    private function getClientManager(): PoolCounterConnectionManager {
        $this->manager ??= new PoolCounterConnectionManager( $this->clientConf );
        return $this->manager;
    }
 
    public function create( string $type, string $key ): PoolCounter {
        $conf = $this->typeConfigs[$type] ?? null;
        if ( $conf === null ) {
            return new PoolCounterNull();
        }
 
        $class = $conf['class'] ?? null;
        if ( $class === 'PoolCounter_Client' ) {
            // Since 1.16: Introduce PoolCounter_Client in PoolCounter extension.
            // Since 1.40: Move to core as symbolic name, discourage use of class name.
            $class = PoolCounterClient::class;
        }
        $poolCounter = new $class( $conf, $type, $key );
        $poolCounter->setLogger( $this->logger );
        $poolCounter->setTracer( $this->tracer );
 
        // Support subclass for back-compat with the extension
        if ( $poolCounter instanceof PoolCounterClient ) {
            $poolCounter->setManager( $this->getClientManager() );
        }
 
        return $poolCounter;
    }
}