plexorganizrnginxsonarrradarrdashboardcouchpotatonzbgetbookmarkapplication-dashboardmuximuxlandingpagestartpagelandinghtpcserverhomepagesabnzbdheimdallemby
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
60 lines
1.5 KiB
60 lines
1.5 KiB
<?php
|
|
|
|
namespace Http\Client\Common;
|
|
|
|
use Http\Client\Common\Exception\HttpClientNotFoundException;
|
|
use Http\Client\HttpAsyncClient;
|
|
use Http\Client\HttpClient;
|
|
use Psr\Http\Client\ClientInterface;
|
|
use Psr\Http\Message\RequestInterface;
|
|
|
|
/**
|
|
* A http client pool allows to send requests on a pool of different http client using a specific strategy (least used,
|
|
* round robin, ...).
|
|
*/
|
|
abstract class HttpClientPool implements HttpAsyncClient, HttpClient
|
|
{
|
|
/**
|
|
* @var HttpClientPoolItem[]
|
|
*/
|
|
protected $clientPool = [];
|
|
|
|
/**
|
|
* Add a client to the pool.
|
|
*
|
|
* @param HttpClient|HttpAsyncClient|HttpClientPoolItem|ClientInterface $client
|
|
*/
|
|
public function addHttpClient($client)
|
|
{
|
|
if (!$client instanceof HttpClientPoolItem) {
|
|
$client = new HttpClientPoolItem($client);
|
|
}
|
|
|
|
$this->clientPool[] = $client;
|
|
}
|
|
|
|
/**
|
|
* Return an http client given a specific strategy.
|
|
*
|
|
* @throws HttpClientNotFoundException When no http client has been found into the pool
|
|
*
|
|
* @return HttpClientPoolItem Return a http client that can do both sync or async
|
|
*/
|
|
abstract protected function chooseHttpClient();
|
|
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function sendAsyncRequest(RequestInterface $request)
|
|
{
|
|
return $this->chooseHttpClient()->sendAsyncRequest($request);
|
|
}
|
|
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function sendRequest(RequestInterface $request)
|
|
{
|
|
return $this->chooseHttpClient()->sendRequest($request);
|
|
}
|
|
}
|
|
|