File Manager Lite

Dir: /home/codewavebd/public_html/vendor/monolog/monolog/src/Monolog/Handler

[..]

AmqpHandler.php (4.95 KB)

ChromePHPHandler.php (4.79 KB)

CubeHandler.php (5.31 KB)

Curl/

DoctrineCouchDBHandler.php (1.12 KB)

DynamoDbHandler.php (1.89 KB)

ElasticaHandler.php (3.66 KB)

ElasticsearchHandler.php (7.1 KB)

ErrorLogHandler.php (2.61 KB)

FilterHandler.php (6.92 KB)

FingersCrossed/

FingersCrossedHandler.php (7.99 KB)

FirePHPHandler.php (5.03 KB)

FleepHookHandler.php (3.44 KB)

GroupHandler.php (3.19 KB)

HandlerInterface.php (2.71 KB)

IFTTTHandler.php (2.22 KB)

LogEntriesHandler.php (1.86 KB)

LogglyHandler.php (4.01 KB)

LogmaticHandler.php (2.57 KB)

MandrillHandler.php (2.48 KB)

NoopHandler.php (908 B)

OverflowHandler.php (4.21 KB)

PsrHandler.php (2.41 KB)

RedisHandler.php (2.67 KB)

RollbarHandler.php (3.48 KB)

Slack/

SqsHandler.php (1.71 KB)

SymfonyMailerHandler.php (3.45 KB)

SyslogUdp/

SyslogUdpHandler.php (4.6 KB)

TestHandler.php (6.73 KB)

WebRequestRecognizerTrait.php (504 B)

ZendMonitorHandler.php (2.78 KB)

Edit: ElasticaHandler.php

<?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 Monolog\Handler;

use Elastic\Transport\Exception\TransportException;
use Elastica\Document;
use Monolog\Formatter\FormatterInterface;
use Monolog\Formatter\ElasticaFormatter;
use Monolog\Level;
use Elastica\Client;
use Elastica\Exception\ExceptionInterface;
use Monolog\LogRecord;

/**
 * Elastic Search handler
 *
 * Usage example:
 *
 *    $client = new \Elastica\Client();
 *    $options = array(
 *        'index' => 'elastic_index_name',
 *        'type' => 'elastic_doc_type', Types have been removed in Elastica 7
 *    );
 *    $handler = new ElasticaHandler($client, $options);
 *    $log = new Logger('application');
 *    $log->pushHandler($handler);
 *
 * @author Jelle Vink <jelle.vink@gmail.com>
 * @phpstan-type Options array{
 *     index: string,
 *     type: string,
 *     ignore_error: bool
 * }
 * @phpstan-type InputOptions array{
 *     index?: string,
 *     type?: string,
 *     ignore_error?: bool
 * }
 */
class ElasticaHandler extends AbstractProcessingHandler
{
    protected Client $client;

/**
     * @var mixed[] Handler config options
     * @phpstan-var Options
     */
    protected array $options;

/**
     * @param Client  $client  Elastica Client object
     * @param mixed[] $options Handler configuration
     *
     * @phpstan-param InputOptions $options
     */
    public function __construct(Client $client, array $options = [], int|string|Level $level = Level::Debug, bool $bubble = true)
    {
        parent::__construct($level, $bubble);
        $this->client = $client;
        $this->options = array_merge(
            [
                'index'          => 'monolog',      // Elastic index name
                'type'           => 'record',       // Elastic document type
                'ignore_error'   => false,          // Suppress Elastica exceptions
            ],
            $options
        );
    }

/**
     * @inheritDoc
     */
    protected function write(LogRecord $record): void
    {
        $this->bulkSend([$record->formatted]);
    }

/**
     * @inheritDoc
     */
    public function setFormatter(FormatterInterface $formatter): HandlerInterface
    {
        if ($formatter instanceof ElasticaFormatter) {
            return parent::setFormatter($formatter);
        }

throw new \InvalidArgumentException('ElasticaHandler is only compatible with ElasticaFormatter');
    }

/**
     * @return mixed[]
     *
     * @phpstan-return Options
     */
    public function getOptions(): array
    {
        return $this->options;
    }

/**
     * @inheritDoc
     */
    protected function getDefaultFormatter(): FormatterInterface
    {
        return new ElasticaFormatter($this->options['index'], $this->options['type']);
    }

/**
     * @inheritDoc
     */
    public function handleBatch(array $records): void
    {
        $documents = $this->getFormatter()->formatBatch($records);
        $this->bulkSend($documents);
    }

/**
     * Use Elasticsearch bulk API to send list of documents
     *
     * @param Document[] $documents
     *
     * @throws \RuntimeException
     */
    protected function bulkSend(array $documents): void
    {
        try {
            $this->client->addDocuments($documents);
        } catch (ExceptionInterface | TransportException $e) {
            if (!$this->options['ignore_error']) {
                throw new \RuntimeException("Error sending messages to Elasticsearch", 0, $e);
            }
        }
    }
}