Elasticsearch

ADP предоставляет ElasticsearchCollectorAppDevPanel\Kernel\Collector\ElasticsearchCollectorCaptures Elasticsearch requests from the application.final Kernel · class · implements SummaryCollectorInterface для захвата запросов к Elasticsearch во время выполнения приложения и инспектор для инспекции кластера в реальном времени.

Коллектор

ElasticsearchCollectorAppDevPanel\Kernel\Collector\ElasticsearchCollectorCaptures Elasticsearch requests from the application.final Kernel · class · implements SummaryCollectorInterface реализует SummaryCollectorInterfaceAppDevPanel\Kernel\Collector\SummaryCollectorInterfaceSummary data collector responsibility is to collect summary data for a collector. Summary is used to display a list of previous requests and select one to display full info. Its data set is specific to the list and is reduced compared to full data collected in {@see CollectorInterface}.Kernel · interface · extends CollectorInterface и захватывает все запросы к Elasticsearch — поиск, индексацию, удаление, массовые операции.

Паттерны сбора данных

Поддерживаются два паттерна:

Парный паттерн — для proxy-адаптеров, перехватывающих ES-клиент:

$collector->collectRequestStart($id, 'GET', '/users/_search', $body, $line);
// ... выполняется запрос ...
$collector->collectRequestEnd($id, 200, $responseBody, $responseSize);
// или при ошибке:
$collector->collectRequestError($id, $exception);

Простой паттерн — для event-адаптеров, которые измеряют время самостоятельно:

$collector->logRequest(new ElasticsearchRequestRecord(
    method: 'GET',
    endpoint: '/users/_search',
    body: '{"query":{"match_all":{}}}',
    line: __FILE__ . ':' . __LINE__,
    startTime: $start,
    endTime: $end,
    statusCode: 200,
    responseBody: '{"hits":{"total":{"value":42}}}',
    responseSize: 256,
));

Собираемые данные

[
    'requests' => [
        [
            'method' => 'GET',
            'endpoint' => '/users/_search',
            'index' => 'users',           // автоматически извлекается из endpoint
            'body' => '{"query":{...}}',
            'line' => '/src/Repo.php:42',
            'status' => 'success',         // success | error | initialized
            'startTime' => 1711900000.123,
            'endTime' => 1711900000.135,
            'duration' => 0.012,
            'statusCode' => 200,
            'responseBody' => '...',
            'responseSize' => 256,
            'hitsCount' => 42,             // извлекается из ответа (null для не-search запросов)
            'exception' => null,
        ],
    ],
    'duplicates' => [
        'groups' => [...],                 // повторяющиеся комбинации method+endpoint
        'totalDuplicatedCount' => 0,
    ],
]

Summary

[
    'elasticsearch' => [
        'total' => 3,
        'errors' => 0,
        'totalTime' => 0.045,
        'duplicateGroups' => 0,
        'totalDuplicatedCount' => 0,
    ],
]

Возможности

• Извлечение индекса — парсит имя индекса из пути endpoint (например, /users/_search → users)
• Подсчёт hits — извлекает hits.total.value из ответов поиска
• Обнаружение дубликатов — выявляет повторяющиеся комбинации method + endpoint (детекция N+1 паттерна)
• Интеграция с Timeline — передаёт данные в TimelineCollectorAppDevPanel\Kernel\Collector\TimelineCollectorCollects Timeline data during application lifecycle.final Kernel · class · implements SummaryCollectorInterface для единой временной шкалы производительности

Инспектор

Инспектор Elasticsearch предоставляет инспекцию кластера в реальном времени через ElasticsearchProviderInterfaceAppDevPanel\Api\Inspector\Elasticsearch\ElasticsearchProviderInterfaceElasticsearch Provider contract.API · interface.

API-эндпоинты

Метод	Путь	Описание
GET	/inspect/api/elasticsearch	Здоровье кластера + список индексов
GET	/inspect/api/elasticsearch/{name}	Детали индекса (маппинги, настройки, статистика)
POST	/inspect/api/elasticsearch/search	Выполнение поискового запроса
POST	/inspect/api/elasticsearch/query	Выполнение произвольного запроса

Интерфейс провайдера

interface ElasticsearchProviderInterface
{
    public function getHealth(): array;
    public function getIndices(): array;
    public function getIndex(string $name): array;
    public function search(string $index, array $query, int $limit, int $offset): array;
    public function executeQuery(string $method, string $endpoint, array $body): array;
}

По умолчанию: NullElasticsearchProviderAppDevPanel\Api\Inspector\Elasticsearch\NullElasticsearchProviderProvides Null Elasticsearch data.API · class · implements ElasticsearchProviderInterface возвращает пустые данные. Адаптеры предоставляют конкретные реализации, подключённые к реальному ES-клиенту.

Фронтенд

Debug-панель

ElasticsearchPanel отображает захваченные запросы:

• Бейджи метода и кода статуса (цветовое кодирование)
• Endpoint с извлечённым именем индекса
• Длительность и количество hits на запрос
• Раскрываемое тело запроса/ответа (рендеринг JSON)
• Фильтрация по endpoint, индексу, методу или содержимому тела
• Предупреждения об обнаружении дубликатов

Страница Inspector

ElasticsearchPage показывает состояние кластера в реальном времени:

• Баннер здоровья кластера (чипы статуса green/yellow/red)
• Количество нод и шардов
• Таблица индексов с количеством документов, размером хранилища, здоровьем, шардами

Интеграция с фреймворком

Зарегистрируйте ElasticsearchCollectorAppDevPanel\Kernel\Collector\ElasticsearchCollectorCaptures Elasticsearch requests from the application.final Kernel · class · implements SummaryCollectorInterface в DI вашего адаптера с TimelineCollectorAppDevPanel\Kernel\Collector\TimelineCollectorCollects Timeline data during application lifecycle.final Kernel · class · implements SummaryCollectorInterface как зависимость конструктора. Включите через флаг конфигурации 'elasticsearch' => true.

Смотрите Адаптеры для паттернов регистрации в конкретных фреймворках.