Руководство по интеграции
Обновлено: 2026-07-06
*Дисклеймер: Данный материал носит исключительно информационный характер и не является финансовой рекомендацией.*
## Почему взаимный дисбаланс кросс-вендорных потоков ордеров критически важен для HFT в 2026 году?
В летний сезон 2026 года, высокочастотная торговля сталкивается с фундаментальными ограничениями сетевой инфраструктуры и консенсус-протоколов, что порождает устойчивые задержки схождения цен между централизованными (Bybit UTA) и децентрализованными (Hyperliquid L1) платформами. Эти задержки и асимметрии в обновлении данных открывают возможности для статистического арбитража. Понимание микроструктуры ордербука, детекция скрытых объемов и моделирование токсичности потоков ордеров позволяют эффективно использовать эти возможности и защищаться от неблагоприятного отбора, оптимизируя исполнение и стабильность торговых стратегий.
| Микроструктурный параметр | Bybit UTA (Линейные перпы) | Hyperliquid L1 (HyperCore) |
|---------------------------------|----------------------------|----------------------------|
| Частота публикации L1 MD | Фиксированная, каждые `20мс` | Событийная, `<1мс` |
| Частота публикации L200 MD | Фиксированная, каждые `50мс` | Локальный вывод ноды в реальном времени |
| Задержка сопоставления (p50) | `5мкс` | `500нс` (внутри консенсуса) |
| Задержка финализации (p50) | Мгновенно в ОЗУ ядра | `70мс` (с учетом сетевого плеча) |
| Задержка финализации (p99) | `200мкс` | `150мс` (сетевые заторы) |
| Комиссия Maker (базовая) | `0.02%` | `0.01%` |
| Комиссия Taker (базовая) | `0.055%` | `0.025%` |
| Механизм защиты от спама | Лимиты частоты REST/WS запросов | Бюджет адреса в `ETH`, лимиты открытых ордеров |
### Кросс-вендорный арбитраж задержек: Bybit UTA и Hyperliquid L1
Взаимодействие между единым торговым аккаунтом Bybit (UTA) и децентрализованным стаканом Hyperliquid L1 на базе консенсуса HyperBFT создает устойчивую задержку схождения цен. Это задержка `Δt_conv` математически описывается уравнением:
```
Δt_conv = t_bybit_md_pub + t_net_bybit_to_strat + t_strat_proc + t_net_strat_to_hl + t_hl_consensus + t_hl_exec
```
Где:
* `t_bybit_md_pub` — время публикации пакета рыночных данных матчинговым ядром Bybit. Для Level 1 задержка составляет `20мс`; для Level 50 — `50мс`; для Level 200 — `50мс`.
* `t_net_bybit_to_strat` — сетевое время транспортировки данных от серверов Bybit до локального сервера стратегии.
* `t_strat_proc` — время обсчета стратегии: парсинг сообщения (JSON/SBE), вычисление дисбаланса, принятие решения, подписание транзакции.
* `t_net_strat_to_hl` — задержка передачи подписанной транзакции на ближайший валидатор Hyperliquid L1.
* `t_hl_consensus` — время достижения консенсуса в HyperBFT (медиана `70мс`, при нагрузке до `150мс`).
* `t_hl_exec` — время детерминированного исполнения и клиринга транзакции в Rust-модуле HyperCore (практически `0мкс` для торговых транзакций без EVM).
### Использование асимметрии обновления данных для арбитража
Для извлечения безрискового статистического арбитража используется тактика опережения устаревших котировок маркет-мейкеров на Hyperliquid. Сигналом для сделки является мгновенный сдвиг цены на Bybit `ΔP_bybit`, который превышает совокупные транзакционные и рыночные издержки `C_total`:
```
ΔP_bybit > C_total = C_bybit_taker + C_hyperliquid_taker + S(V_target) + R_risk
```
Где:
* `C_bybit_taker` — комиссия за исполнение ордера на Bybit (`0.055%` для базового VIP).
* `C_hyperliquid_taker` — комиссия за исполнение ордера на Hyperliquid L1 (`0.025%`).
* `S(V_target)` — функция проскальзывания ликвидности на Hyperliquid L1 для целевого объема `V_target`.
* `R_risk` — премия за риск неисполнения транзакции в рамках консенсусного окна HyperBFT.
### Архитектура подключения со сверхнизкой задержкой к Hyperliquid L1
Для минимизации сетевого компонента `t_net_strat_to_hl` и `t_net_bybit_to_strat`, а также исключения задержек десериализации, инфраструктура реализуется следующим образом:
* **Размещение сервера:** В дата-центре Equinix TY3 (Токио), для минимизации физической дистанции до валидаторов Hyperliquid L1.
* **Локальная нода Hyperliquid:** Развертывание собственной невалидирующей ноды, подключенной напрямую к доверенному валидатору.
* **Оптимизация ввода-вывода:** Запуск ноды с флагом `--disable-output-file-buffering` для мгновенной передачи изменений состояния в оперативную память.
* **Аппаратная конфигурация:** Не менее 32 логических ядер ЦП, 128 ГБ ОЗУ, NVMe дисковая подсистема с пропускной способностью записи не менее `7000 МБ/с`.
* **Реконструкция стакана:** Локальное вычисление цен матчинга из сырых выходных потоков локальной ноды, минуя публичный WebSocket-сервер.
* **Приоритетное исполнение:** Использование механизма Priority Fees с динамическим выкупом `ReserveRequestWeight` (`0.0001 ETH` за транзакцию).
### Высокочастотный алгоритм детекции айсбергов на Level 3 ITCH
Идентификация скрытого институционального объема в реальном времени требует анализа поордерных логов Level 3 (Market-By-Order, MBO). Протокол MBO транслирует атомарные события изменения состояния каждой конкретной заявки.
#### Микроструктурный маркер атомарного восстановления ликвидности
Детекция нативных айсберг-ордеров основана на принципе атомарной обработки транзакций матчинговым ядром. При исполнении видимой части `V_tip` лимитного ордера, матчинговое ядро мгновенно (в рамках того же такта процессора) создает новую лимитную заявку из скрытого резерва `R_reserve`.
В потоке Level 3 ITCH этот процесс проявляется как два последовательных события с временной разницей, не превышающей `τ_atomic = 5 мкс`.
#### Математическая формализация фильтрации MBO
Уровень `P*` идентифицируется как зона скрытой ликвидности айсберга в момент `t`, если выполняются следующие критерии:
```
1. m_i = (t_i, E, ID_old, P*, Q_i) где Q_rem(ID_old) -> 0
2. m_j = (t_j, Type_j, ID_new, P*, Q_j) где Type_j ∈ {A, U}
3. t_j - t_i <= τ_atomic, где τ_atomic = 5мкс
4. |Q_j - V_tip| <= ε * V_tip, где ε ∈ [0.0, 0.05]
5. ID_new != ID_old (для класса A)
```
Где `V_tip` — исторически зарегистрированная верхушка айсберга на данном уровне, а `ε` — коэффициент флуктуации верхушки.
#### Спецификация сообщений Level 3 ITCH и их поля
| Код события | Название типа | Ключевые анализируемые поля | Микроструктурное значение |
|-------------|------------------|----------------------------------|-----------------------------------------|
| A | Order Add | timestamp, order_id, price, quantity | Появление нового лимитного ордера. |
| E | Order Execute | timestamp, order_id, executed_qty | Списание объема лимитного ордера. |
| U | Order Modify | timestamp, order_id, new_qty, new_price | Изменение параметров ордера. |
| C | Order Cancel | timestamp, order_id | Отзыв неисполненной заявки. |
#### C++ Реализация детектора айсберг-ордеров
C++ класс `MicrosecondIcebergDetector` использует `absl::flat_hash_map` для обработки событий со сложностью `O(1)`, обеспечивая производительность более `100 000` событий в секунду.
```cpp
#include
#include
#include
#include "absl/container/flat_hash_map.h"
enum class ITCHMsgType : char {
ADD = 'A',
EXECUTE = 'E',
MODIFY = 'U',
CANCEL = 'C'
};
struct ITCHMessage {
uint64_t timestamp_ns; // Системный timestamp ядра матчинга (cts)
uint64_t order_id;
uint32_t price; // Внутреннее целочисленное представление цены (в тиках)
uint32_t quantity;
ITCHMsgType type;
};
struct ActiveOrder {
uint32_t price;
uint32_t initial_qty;
uint32_t remaining_qty;
};
struct PriceLevelState {
uint64_t last_execution_ts = 0;
uint32_t last_executed_qty = 0;
uint32_t expected_tip_size = 0;
};
class MicrosecondIcebergDetector {
private:
static constexpr uint64_t ATOMIC_WINDOW_NS = 5000; // 5 микросекунд
static constexpr double JITTER_TOLERANCE = 0.05; // 5% погрешность
absl::flat_hash_map active_orders_;
absl::flat_hash_map level_states_;
inline void dispatch_iceberg_alert(uint32_t price, uint32_t tip_size, uint64_t time_delta_ns) {
// Прямая передача сигнала в модуль принятия решений (Execution Router)
std::cout << " Native Iceberg Reload: Price=" << price
<< " | Tip=" << tip_size
<< " | Delta=" << time_delta_ns << " ns" << std::endl;
}
public:
void on_message(const ITCHMessage& msg) {
switch (msg.type) {
case ITCHMsgType::ADD: {
active_orders_[msg.order_id] = ActiveOrder{msg.price, msg.quantity, msg.quantity};
auto state_it = level_states_.find(msg.price);
if (state_it!= level_states_.end()) {
PriceLevelState& state = state_it->second;
if (state.last_execution_ts!= 0) {
uint64_t delta_t = msg.timestamp_ns - state.last_execution_ts;
if (delta_t <= ATOMIC_WINDOW_NS) {
double ratio = static_cast(msg.quantity) / state.expected_tip_size;
if (std::abs(ratio - 1.0) <= JITTER_TOLERANCE) {
dispatch_iceberg_alert(msg.price, state.expected_tip_size, delta_t);
state.last_execution_ts = 0; // Сброс состояния
}
}
}
}
break;
}
case ITCHMsgType::EXECUTE: {
auto ord_it = active_orders_.find(msg.order_id);
if (ord_it!= active_orders_.end()) {
ActiveOrder& order = ord_it->second;
if (msg.quantity >= order.remaining_qty) {
// Полное исполнение видимого уровня ордера
PriceLevelState& state = level_states_[order.price];
state.last_execution_ts = msg.timestamp_ns;
state.last_executed_qty = order.remaining_qty;
state.expected_tip_size = order.initial_qty;
active_orders_.erase(ord_it);
} else {
order.remaining_qty -= msg.quantity;
}
}
break;
}
case ITCHMsgType::MODIFY: {
auto ord_it = active_orders_.find(msg.order_id);
if (ord_it!= active_orders_.end()) {
ActiveOrder& order = ord_it->second;
order.remaining_qty = msg.quantity;
// Если модификация происходит на том же уровне с восстановлением объема
if (msg.quantity > order.remaining_qty) {
PriceLevelState& state = level_states_[order.price];
if (state.last_execution_ts!= 0 && (msg.timestamp_ns - state.last_execution_ts <= ATOMIC_WINDOW_NS)) {
dispatch_iceberg_alert(order.price, order.initial_qty, msg.timestamp_ns - state.last_execution_ts);
state.last_execution_ts = 0;
}
}
}
break;
}
case ITCHMsgType::CANCEL: {
active_orders_.erase(msg.order_id);
break;
}
}
}
};
```
### Моделирование токсичности потока ордеров на основе процессов Хокса
Моделирование входящего потока ордеров как простого пуассоновского процесса недооценивает риски неблагоприятного отбора. Реальный поток ордеров характеризуется эндогенной кластеризацией.
#### Математический аппарат многомерного процесса Хокса
Для моделирования динамики и взаимного влияния событий ордербука применяется 6-мерный само- и перекрестно-возбуждающийся точечный процесс Хокса. Вектор мгновенной условной интенсивности событий `λ(t)` задается системой уравнений:
```
λ_k(t) = μ_k + Σ_(j=1)^6 ∫_(-∞)^t φ_kj(t - s) dN_j(s)
```
Где:
* `k` индексирует типы событий: `Buy_Market`, `Sell_Market`, `Buy_Limit`, `Sell_Limit`, `Buy_Cancel`, `Sell_Cancel`.
* `μ_k` — базовая экзогенная интенсивность поступления заявок типа `k`.
* `N_j(s)` — кумулятивный счетчик событий типа `j` до момента `s`.
* `φ_kj(t - s)` — экспоненциальное ядро взаимного влияния событий типа `j` на интенсивность `k`.
Матрица интегральных ядер (`Φ`) отражает среднее количество вторичных событий, порождаемых одним первичным импульсом.
#### Поведение системы при приближении к границе нестабильности
Калибровка параметров Хокса методом максимального правдоподобия на скользящих окнах позволяет вычислять спектральный радиус матрицы ветвления `ρ(Φ)` в реальном времени. `ρ(Φ)` – это максимальное абсолютное значение собственного числа матрицы `Φ`.
При `ρ(Φ) ≈ 1` система входит в критическую субкритическую фазу, характеризующуюся лавинообразным ростом плотности событий. В периоды микроструктурного шока `ρ(Φ)` может локально возрастать до `>1`, что приводит к затяжным каскадам ликвидности.
Если при этом показатель затухания импульса `θ` (скорость релаксации интенсивности к базовым уровням) падает до диапазона `[0.001, 0.01] с^{-1}`, время памяти системы `T_memory` возрастает до `T_memory = 1/θ`.
В стакане возникает феномен персистентной токсичности: поток ордеров перестает быть стохастическим шумом и превращается в направленный вектор выедания ликвидности. В ценовых коридорах `P_liquidation` (historical liquidation triggers) этот паттерн указывает на неизбежный пробой уровней поддержки/сопротивления.
### Алгоритм перевода системы в стейт DEFER
Для предотвращения катастрофического неблагоприятного отбора маркет-мейкера при фиксации критической токсичности торговый автомат переводится в защитный стейт DEFER.
Математический триггер перехода:
```
ρ(Φ) >= 0.95 И θ <= 0.01
```
Где `θ` — скорость полного экспоненциального затухания интенсивности (соответствует 5 периодам полураспада возбуждения).
#### Комплекс защитных мер в состоянии DEFER:
* **Мгновенный отзыв заявок (Cancel All):** Отправка высокоприоритетных пакетов отмены всех активных лимитных ордеров на Bybit и Hyperliquid L1.
* **Пауза котирования (Quoting Freeze):** Замораживание генерации новых двухсторонних котировок. Маркет-мейкер полностью уходит из стакана.
* **Локальное кросс-хеджирование (Delta Neutralization):** Нейтрализация накопленного дельта-риска путем совершения встречных сделок на спотовом рынке или альтернативных площадках с высокой глубиной стакана.
#### Спецификация режимов стабильности торговой системы
| Режим системы | Спектральный радиус ρ(Φ) | Скорость затухания θ (s⁻¹) | Микроструктурное состояние стакана | Действие риск-модуля |
|---------------|--------------------------|----------------------------|-----------------------------------------------------|-----------------------------------------------------------------------------------|
| ACTIVE | `< 0.8` | `> 0.05` | Стабильное равновесие, быстрый распад флуктуаций. | Стандартное двухстороннее котирование с минимальным спредом. |
| WARNING | `[0.8, 0.95]` | `[0.01, 0.05]` | Повышенная рефлексивность, нарастание дисбаланса. | Расширение котируемого спреда, пропорциональное снижение объемов лимитов. |
| DEFER | `> 0.95` | `< 0.01` | Локальная суперкритичность, лавинообразное выедание. | Экстренная отмена всех ордеров, блокировка новых котировок, дельта-хедж. |
*Дисклеймер: Данный материал носит исключительно информационный характер и не является финансовой рекомендацией.*
## Почему взаимный дисбаланс кросс-вендорных потоков ордеров критически важен для HFT в 2026 году?
В летний сезон 2026 года, высокочастотная торговля сталкивается с фундаментальными ограничениями сетевой инфраструктуры и консенсус-протоколов, что порождает устойчивые задержки схождения цен между централизованными (Bybit UTA) и децентрализованными (Hyperliquid L1) платформами. Эти задержки и асимметрии в обновлении данных открывают возможности для статистического арбитража. Понимание микроструктуры ордербука, детекция скрытых объемов и моделирование токсичности потоков ордеров позволяют эффективно использовать эти возможности и защищаться от неблагоприятного отбора, оптимизируя исполнение и стабильность торговых стратегий.
| Микроструктурный параметр | Bybit UTA (Линейные перпы) | Hyperliquid L1 (HyperCore) |
|---------------------------------|----------------------------|----------------------------|
| Частота публикации L1 MD | Фиксированная, каждые `20мс` | Событийная, `<1мс` |
| Частота публикации L200 MD | Фиксированная, каждые `50мс` | Локальный вывод ноды в реальном времени |
| Задержка сопоставления (p50) | `5мкс` | `500нс` (внутри консенсуса) |
| Задержка финализации (p50) | Мгновенно в ОЗУ ядра | `70мс` (с учетом сетевого плеча) |
| Задержка финализации (p99) | `200мкс` | `150мс` (сетевые заторы) |
| Комиссия Maker (базовая) | `0.02%` | `0.01%` |
| Комиссия Taker (базовая) | `0.055%` | `0.025%` |
| Механизм защиты от спама | Лимиты частоты REST/WS запросов | Бюджет адреса в `ETH`, лимиты открытых ордеров |
### Кросс-вендорный арбитраж задержек: Bybit UTA и Hyperliquid L1
Взаимодействие между единым торговым аккаунтом Bybit (UTA) и децентрализованным стаканом Hyperliquid L1 на базе консенсуса HyperBFT создает устойчивую задержку схождения цен. Это задержка `Δt_conv` математически описывается уравнением:
```
Δt_conv = t_bybit_md_pub + t_net_bybit_to_strat + t_strat_proc + t_net_strat_to_hl + t_hl_consensus + t_hl_exec
```
Где:
* `t_bybit_md_pub` — время публикации пакета рыночных данных матчинговым ядром Bybit. Для Level 1 задержка составляет `20мс`; для Level 50 — `50мс`; для Level 200 — `50мс`.
* `t_net_bybit_to_strat` — сетевое время транспортировки данных от серверов Bybit до локального сервера стратегии.
* `t_strat_proc` — время обсчета стратегии: парсинг сообщения (JSON/SBE), вычисление дисбаланса, принятие решения, подписание транзакции.
* `t_net_strat_to_hl` — задержка передачи подписанной транзакции на ближайший валидатор Hyperliquid L1.
* `t_hl_consensus` — время достижения консенсуса в HyperBFT (медиана `70мс`, при нагрузке до `150мс`).
* `t_hl_exec` — время детерминированного исполнения и клиринга транзакции в Rust-модуле HyperCore (практически `0мкс` для торговых транзакций без EVM).
### Использование асимметрии обновления данных для арбитража
Для извлечения безрискового статистического арбитража используется тактика опережения устаревших котировок маркет-мейкеров на Hyperliquid. Сигналом для сделки является мгновенный сдвиг цены на Bybit `ΔP_bybit`, который превышает совокупные транзакционные и рыночные издержки `C_total`:
```
ΔP_bybit > C_total = C_bybit_taker + C_hyperliquid_taker + S(V_target) + R_risk
```
Где:
* `C_bybit_taker` — комиссия за исполнение ордера на Bybit (`0.055%` для базового VIP).
* `C_hyperliquid_taker` — комиссия за исполнение ордера на Hyperliquid L1 (`0.025%`).
* `S(V_target)` — функция проскальзывания ликвидности на Hyperliquid L1 для целевого объема `V_target`.
* `R_risk` — премия за риск неисполнения транзакции в рамках консенсусного окна HyperBFT.
### Архитектура подключения со сверхнизкой задержкой к Hyperliquid L1
Для минимизации сетевого компонента `t_net_strat_to_hl` и `t_net_bybit_to_strat`, а также исключения задержек десериализации, инфраструктура реализуется следующим образом:
* **Размещение сервера:** В дата-центре Equinix TY3 (Токио), для минимизации физической дистанции до валидаторов Hyperliquid L1.
* **Локальная нода Hyperliquid:** Развертывание собственной невалидирующей ноды, подключенной напрямую к доверенному валидатору.
* **Оптимизация ввода-вывода:** Запуск ноды с флагом `--disable-output-file-buffering` для мгновенной передачи изменений состояния в оперативную память.
* **Аппаратная конфигурация:** Не менее 32 логических ядер ЦП, 128 ГБ ОЗУ, NVMe дисковая подсистема с пропускной способностью записи не менее `7000 МБ/с`.
* **Реконструкция стакана:** Локальное вычисление цен матчинга из сырых выходных потоков локальной ноды, минуя публичный WebSocket-сервер.
* **Приоритетное исполнение:** Использование механизма Priority Fees с динамическим выкупом `ReserveRequestWeight` (`0.0001 ETH` за транзакцию).
### Высокочастотный алгоритм детекции айсбергов на Level 3 ITCH
Идентификация скрытого институционального объема в реальном времени требует анализа поордерных логов Level 3 (Market-By-Order, MBO). Протокол MBO транслирует атомарные события изменения состояния каждой конкретной заявки.
#### Микроструктурный маркер атомарного восстановления ликвидности
Детекция нативных айсберг-ордеров основана на принципе атомарной обработки транзакций матчинговым ядром. При исполнении видимой части `V_tip` лимитного ордера, матчинговое ядро мгновенно (в рамках того же такта процессора) создает новую лимитную заявку из скрытого резерва `R_reserve`.
В потоке Level 3 ITCH этот процесс проявляется как два последовательных события с временной разницей, не превышающей `τ_atomic = 5 мкс`.
#### Математическая формализация фильтрации MBO
Уровень `P*` идентифицируется как зона скрытой ликвидности айсберга в момент `t`, если выполняются следующие критерии:
```
1. m_i = (t_i, E, ID_old, P*, Q_i) где Q_rem(ID_old) -> 0
2. m_j = (t_j, Type_j, ID_new, P*, Q_j) где Type_j ∈ {A, U}
3. t_j - t_i <= τ_atomic, где τ_atomic = 5мкс
4. |Q_j - V_tip| <= ε * V_tip, где ε ∈ [0.0, 0.05]
5. ID_new != ID_old (для класса A)
```
Где `V_tip` — исторически зарегистрированная верхушка айсберга на данном уровне, а `ε` — коэффициент флуктуации верхушки.
#### Спецификация сообщений Level 3 ITCH и их поля
| Код события | Название типа | Ключевые анализируемые поля | Микроструктурное значение |
|-------------|------------------|----------------------------------|-----------------------------------------|
| A | Order Add | timestamp, order_id, price, quantity | Появление нового лимитного ордера. |
| E | Order Execute | timestamp, order_id, executed_qty | Списание объема лимитного ордера. |
| U | Order Modify | timestamp, order_id, new_qty, new_price | Изменение параметров ордера. |
| C | Order Cancel | timestamp, order_id | Отзыв неисполненной заявки. |
#### C++ Реализация детектора айсберг-ордеров
C++ класс `MicrosecondIcebergDetector` использует `absl::flat_hash_map` для обработки событий со сложностью `O(1)`, обеспечивая производительность более `100 000` событий в секунду.
```cpp
#include
#include
#include
#include "absl/container/flat_hash_map.h"
enum class ITCHMsgType : char {
ADD = 'A',
EXECUTE = 'E',
MODIFY = 'U',
CANCEL = 'C'
};
struct ITCHMessage {
uint64_t timestamp_ns; // Системный timestamp ядра матчинга (cts)
uint64_t order_id;
uint32_t price; // Внутреннее целочисленное представление цены (в тиках)
uint32_t quantity;
ITCHMsgType type;
};
struct ActiveOrder {
uint32_t price;
uint32_t initial_qty;
uint32_t remaining_qty;
};
struct PriceLevelState {
uint64_t last_execution_ts = 0;
uint32_t last_executed_qty = 0;
uint32_t expected_tip_size = 0;
};
class MicrosecondIcebergDetector {
private:
static constexpr uint64_t ATOMIC_WINDOW_NS = 5000; // 5 микросекунд
static constexpr double JITTER_TOLERANCE = 0.05; // 5% погрешность
absl::flat_hash_map
absl::flat_hash_map
inline void dispatch_iceberg_alert(uint32_t price, uint32_t tip_size, uint64_t time_delta_ns) {
// Прямая передача сигнала в модуль принятия решений (Execution Router)
std::cout << " Native Iceberg Reload: Price=" << price
<< " | Tip=" << tip_size
<< " | Delta=" << time_delta_ns << " ns" << std::endl;
}
public:
void on_message(const ITCHMessage& msg) {
switch (msg.type) {
case ITCHMsgType::ADD: {
active_orders_[msg.order_id] = ActiveOrder{msg.price, msg.quantity, msg.quantity};
auto state_it = level_states_.find(msg.price);
if (state_it!= level_states_.end()) {
PriceLevelState& state = state_it->second;
if (state.last_execution_ts!= 0) {
uint64_t delta_t = msg.timestamp_ns - state.last_execution_ts;
if (delta_t <= ATOMIC_WINDOW_NS) {
double ratio = static_cast
if (std::abs(ratio - 1.0) <= JITTER_TOLERANCE) {
dispatch_iceberg_alert(msg.price, state.expected_tip_size, delta_t);
state.last_execution_ts = 0; // Сброс состояния
}
}
}
}
break;
}
case ITCHMsgType::EXECUTE: {
auto ord_it = active_orders_.find(msg.order_id);
if (ord_it!= active_orders_.end()) {
ActiveOrder& order = ord_it->second;
if (msg.quantity >= order.remaining_qty) {
// Полное исполнение видимого уровня ордера
PriceLevelState& state = level_states_[order.price];
state.last_execution_ts = msg.timestamp_ns;
state.last_executed_qty = order.remaining_qty;
state.expected_tip_size = order.initial_qty;
active_orders_.erase(ord_it);
} else {
order.remaining_qty -= msg.quantity;
}
}
break;
}
case ITCHMsgType::MODIFY: {
auto ord_it = active_orders_.find(msg.order_id);
if (ord_it!= active_orders_.end()) {
ActiveOrder& order = ord_it->second;
order.remaining_qty = msg.quantity;
// Если модификация происходит на том же уровне с восстановлением объема
if (msg.quantity > order.remaining_qty) {
PriceLevelState& state = level_states_[order.price];
if (state.last_execution_ts!= 0 && (msg.timestamp_ns - state.last_execution_ts <= ATOMIC_WINDOW_NS)) {
dispatch_iceberg_alert(order.price, order.initial_qty, msg.timestamp_ns - state.last_execution_ts);
state.last_execution_ts = 0;
}
}
}
break;
}
case ITCHMsgType::CANCEL: {
active_orders_.erase(msg.order_id);
break;
}
}
}
};
```
### Моделирование токсичности потока ордеров на основе процессов Хокса
Моделирование входящего потока ордеров как простого пуассоновского процесса недооценивает риски неблагоприятного отбора. Реальный поток ордеров характеризуется эндогенной кластеризацией.
#### Математический аппарат многомерного процесса Хокса
Для моделирования динамики и взаимного влияния событий ордербука применяется 6-мерный само- и перекрестно-возбуждающийся точечный процесс Хокса. Вектор мгновенной условной интенсивности событий `λ(t)` задается системой уравнений:
```
λ_k(t) = μ_k + Σ_(j=1)^6 ∫_(-∞)^t φ_kj(t - s) dN_j(s)
```
Где:
* `k` индексирует типы событий: `Buy_Market`, `Sell_Market`, `Buy_Limit`, `Sell_Limit`, `Buy_Cancel`, `Sell_Cancel`.
* `μ_k` — базовая экзогенная интенсивность поступления заявок типа `k`.
* `N_j(s)` — кумулятивный счетчик событий типа `j` до момента `s`.
* `φ_kj(t - s)` — экспоненциальное ядро взаимного влияния событий типа `j` на интенсивность `k`.
Матрица интегральных ядер (`Φ`) отражает среднее количество вторичных событий, порождаемых одним первичным импульсом.
#### Поведение системы при приближении к границе нестабильности
Калибровка параметров Хокса методом максимального правдоподобия на скользящих окнах позволяет вычислять спектральный радиус матрицы ветвления `ρ(Φ)` в реальном времени. `ρ(Φ)` – это максимальное абсолютное значение собственного числа матрицы `Φ`.
При `ρ(Φ) ≈ 1` система входит в критическую субкритическую фазу, характеризующуюся лавинообразным ростом плотности событий. В периоды микроструктурного шока `ρ(Φ)` может локально возрастать до `>1`, что приводит к затяжным каскадам ликвидности.
Если при этом показатель затухания импульса `θ` (скорость релаксации интенсивности к базовым уровням) падает до диапазона `[0.001, 0.01] с^{-1}`, время памяти системы `T_memory` возрастает до `T_memory = 1/θ`.
В стакане возникает феномен персистентной токсичности: поток ордеров перестает быть стохастическим шумом и превращается в направленный вектор выедания ликвидности. В ценовых коридорах `P_liquidation` (historical liquidation triggers) этот паттерн указывает на неизбежный пробой уровней поддержки/сопротивления.
### Алгоритм перевода системы в стейт DEFER
Для предотвращения катастрофического неблагоприятного отбора маркет-мейкера при фиксации критической токсичности торговый автомат переводится в защитный стейт DEFER.
Математический триггер перехода:
```
ρ(Φ) >= 0.95 И θ <= 0.01
```
Где `θ` — скорость полного экспоненциального затухания интенсивности (соответствует 5 периодам полураспада возбуждения).
#### Комплекс защитных мер в состоянии DEFER:
* **Мгновенный отзыв заявок (Cancel All):** Отправка высокоприоритетных пакетов отмены всех активных лимитных ордеров на Bybit и Hyperliquid L1.
* **Пауза котирования (Quoting Freeze):** Замораживание генерации новых двухсторонних котировок. Маркет-мейкер полностью уходит из стакана.
* **Локальное кросс-хеджирование (Delta Neutralization):** Нейтрализация накопленного дельта-риска путем совершения встречных сделок на спотовом рынке или альтернативных площадках с высокой глубиной стакана.
#### Спецификация режимов стабильности торговой системы
| Режим системы | Спектральный радиус ρ(Φ) | Скорость затухания θ (s⁻¹) | Микроструктурное состояние стакана | Действие риск-модуля |
|---------------|--------------------------|----------------------------|-----------------------------------------------------|-----------------------------------------------------------------------------------|
| ACTIVE | `< 0.8` | `> 0.05` | Стабильное равновесие, быстрый распад флуктуаций. | Стандартное двухстороннее котирование с минимальным спредом. |
| WARNING | `[0.8, 0.95]` | `[0.01, 0.05]` | Повышенная рефлексивность, нарастание дисбаланса. | Расширение котируемого спреда, пропорциональное снижение объемов лимитов. |
| DEFER | `> 0.95` | `< 0.01` | Локальная суперкритичность, лавинообразное выедание. | Экстренная отмена всех ордеров, блокировка новых котировок, дельта-хедж. |