Файл: vendor/monolog/monolog/src/Monolog/Handler/RedisPubSubHandler.php
Строк: 80
<?php declare(strict_types=1);
/*
* This file is part of the Monolog package.
*
* (c) Jordi Boggiano <j.boggiano@seld.be>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace MonologHandler;
use MonologFormatterLineFormatter;
use MonologFormatterFormatterInterface;
use MonologLogger;
/**
* Sends the message to a Redis Pub/Sub channel using PUBLISH
*
* usage example:
*
* $log = new Logger('application');
* $redis = new RedisPubSubHandler(new PredisClient("tcp://localhost:6379"), "logs", Logger::WARNING);
* $log->pushHandler($redis);
*
* @author Gaëtan Faugère <gaetan@fauge.re>
*/
class RedisPubSubHandler extends AbstractProcessingHandler
{
/** @var PredisClient<PredisClient>|Redis */
private $redisClient;
/** @var string */
private $channelKey;
/**
* @param PredisClient<PredisClient>|Redis $redis The redis instance
* @param string $key The channel key to publish records to
*/
public function __construct($redis, string $key, $level = Logger::DEBUG, bool $bubble = true)
{
if (!(($redis instanceof PredisClient) || ($redis instanceof Redis))) {
throw new InvalidArgumentException('PredisClient or Redis instance required');
}
$this->redisClient = $redis;
$this->channelKey = $key;
parent::__construct($level, $bubble);
}
/**
* {@inheritDoc}
*/
protected function write(array $record): void
{
$this->redisClient->publish($this->channelKey, $record["formatted"]);
}
/**
* {@inheritDoc}
*/
protected function getDefaultFormatter(): FormatterInterface
{
return new LineFormatter();
}
}