A full-stack quantitative trading research platform built on Special Relativistic Financial Mechanics (SRFM) -- from raw tick data to live paper trading and autonomous idea discovery, across 9 languages, 4,888 files, and 1,708,917 lines of code.
Mad scientist workshop. Everything automated, everything measurable, rapid iteration at scale.
| Section | Description |
|---|---|
| What is This? | Core innovation and philosophy |
| Architecture | System diagram and data flow |
| Quick Start | Get running in 5 minutes |
| Deep Documentation | Every subsystem has a dedicated doc |
| Tools and Primitives | Every executable tool flagged |
| Stack | All 9 languages, LOC counts, and roles |
| File Structure | Complete directory map |
| BH Physics Reference | Signal math |
| Key Parameters | All tunable constants |
| IAE Research Output | Live findings |
| Service Endpoints | All running ports |
| AETERNUS Lab | BH physics experiment results |
Pick a subsystem to deep dive into. Every doc covers architecture, key primitives, code examples, and integration points.
| Doc | What it covers |
|---|---|
| BH Physics Engine | Minkowski metric, mass accumulation, Hawking temperature, delta scoring, worked example |
| Quaternion Navigation | 4-space bar representation, rotation tracking, geodesic deviation, angular velocity, Lorentz boosts |
| C++ Signal Engine | SignalOutput struct, InstrumentState, SIMD indicators, ring buffer, Kalman filter, tick indicators, ZMQ publisher |
| Doc | What it covers |
|---|---|
| IAE Architecture | Genome evolution, hypothesis engine, causal discovery, regime oracle, feedback loop |
| Genome Evolution | NSGA-II Rust crate, crossover/mutation/selection strategies, constraint handling, lineage tracking |
| RL Exit Optimizer | Q-table policy (3125 states), Double DQN trainer, PER experience replay, reward shaping |
| Online Learning | FTRL-Proximal, Passive-Aggressive II, Hedge algorithm, Adam/AdaGrad/RMSProp, bandit explorer |
| Optimization | Bayesian optimizer (GP+EI), NSGA-II hyperparameter search, regime-conditional Optuna, Sobol sensitivity |
| Wave 4 Backtest | EventCalendarFilter, Granger lead signal, ML signal module, 4-variant comparison |
| Doc | What it covers |
|---|---|
| Execution Stack | L2 orderbook, smart router, spread-tier routing, supervisor, Docker deployment |
| Order Management | TWAP/VWAP/Iceberg engines, algo scheduler, order state machine, TCA benchmarks |
| Broker Adapters | Alpaca/Binance/Paper adapters, circuit breaker integration, failover chain, adding new brokers |
| Coordination Layer | Elixir/OTP supervision, circuit breakers, parameter validation, rollback, event bus |
| Doc | What it covers |
|---|---|
| Kalman Filters | LinearKF, EKF, UKF, SIR particle filter, RTS smoother, KalmanPairsSpread, DynamicBeta |
| Extreme Value Theory | GPD/POT, GEV block maxima, Hill estimator, EVT VaR/CVaR |
| Portfolio Math | Markowitz MVO, Black-Litterman, HRP, ERC risk parity, CVaR LP, Kelly, max entropy |
| Time Series Models | ARMA, GARCH/GJR-GARCH, HAR-RV, Engle-Granger cointegration, VAR, Granger causality, CUSUM |
| Market Making Math | Avellaneda-Stoikov, Almgren-Chriss, sqrt impact, Glosten-Milgrom, TWAP/VWAP |
| Levy Processes | CGMY, alpha-stable, Carr-Madan FFT pricing, NIG, VG simulation |
| Causal Inference | PC algorithm, backdoor adjustment, 2SLS IV, RDD, DiD, synthetic control, transfer entropy |
| Stochastic Control | HJB, Merton, LQR Riccati, optimal stopping OU, risk-sensitive control |
| Derivatives Pricing | Full BS Greeks (delta/gamma/vega/theta/rho/vanna/volga/charm), barrier/lookback/Asian/exchange options, variance swaps |
| Econometrics | OLS/WLS, Newey-West HAC, ADF/KPSS unit root, VAR+IRF+FEVD, Johansen cointegration |
| Credit Models | Merton structural, KMV, Jarrow-Turnbull, CDS pricing, CDO Gaussian copula, Credit VaR |
| Order Book Models | OBI, micro-price, queue-reactive CST, Hawkes order flow, spread decomposition, resilience |
| Mean Field Games | MFG Nash execution, herding equilibrium, systemic risk MFG, Vicsek flocking model |
| FX Models | Garman-Kohlhagen, vanna-volga FX vol surface, SABR FX, carry scoring, FX momentum |
| Crypto Microstructure | Funding rate models, liquidation cascade, NVT/MVRV, hash ribbon, OIWAP |
| Commodity Models | Gibson-Schwartz, Schwartz-Smith two-factor, Fourier seasonal decomposition, calendar spread arb |
| Fixed Income Advanced | Key rate durations, OAS binomial tree, MBS PSA prepayment, Z-spread, swap pricing, TIPS carry |
| Auction Theory | FPSBA, Vickrey, common value/winner's curse, treasury auction, dark pool crossing, IPO book-building |
| Optimal Stopping | Longstaff-Schwartz LSM, Bayesian stopping, Snell envelope, Shiryaev-Roberts change detection |
| Tensor Decomposition | CP/Tucker/NTF, tensor completion, multi-linear PCA, tensor regression, online CP |
| Point Processes | Hawkes (univariate + multivariate), Cox process, marked point process, Ogata thinning, MLE |
| Manifold Learning | Isomap, LLE, Laplacian eigenmaps, diffusion maps, t-SNE, persistent homology |
| Convex Optimization | ADMM, proximal operators, QP active set, CVaR LP, log-barrier, simplex projection |
| Wavelets Advanced | DWT Haar/Db4/Symlet, MODWT, wavelet packets, wavelet denoising, multifractal leaders |
| Ergodic Theory | Time-average vs ensemble, Kelly from ergodicity, leverage optimization, volatility drag |
| Additional Modules | Copulas, functional analysis, HMM, information theory, jump diffusion, robust statistics, factor models, optimal transport, risk measures, simulation, spectral analysis, network contagion, graph theory, microstructure, matrix factorization, numerical methods, interest rate models, regime switching, volatility models, portfolio construction, reinforcement learning, Bayesian update, random matrix, rough volatility, stochastic calculus |
| Doc | What it covers |
|---|---|
| Deep Signal Network | Dense/BN/Dropout/Residual/LSTM/TCN layers, full backprop, Adam optimizer |
| Graph Neural Network | GCN, GAT, GraphSAGE, temporal GNN, portfolio GNN, link prediction |
| Market Transformer | Multi-head attention, causal mask, GRN (TFT), walk-forward inference |
| Gaussian Process | GP regression, 7 kernels (RBF/Matern/Periodic/RQ/Spectral), sparse GP FITC, LOOCV |
| Online Learning | FTRL, ONS, EG, Hedge, Cover's Universal Portfolio, ADWIN drift detection |
| Variational Autoencoder | VAE + Beta-VAE + Conditional VAE, ELBO loss, anomaly detection via reconstruction error |
| Normalizing Flows | Planar/radial/RealNVP flows, density estimation, fat-tail return modeling |
| Temporal Conv Network | Causal dilated conv, TCN blocks, WaveNet gated units, multi-horizon forecasting |
| State Space Model | Linear Gaussian SSM, deep SSM, S4-inspired architecture, HiPPO, parallel scan |
| Diffusion Model | Denoising diffusion for synthetic returns, DDIM sampler, conditional generation |
| Mixture Density Network | GMM output layer, conditional density p(r given x), mode extraction, tail probability |
| Contrastive Learning | SimCLR for regime representation, NT-Xent loss, augmentations, similarity search |
| Bayesian Neural Network | Variational inference, MC Dropout, epistemic vs aleatoric uncertainty, calibration |
| Additional Modules | Ensemble forecaster, attention patterns, causal discovery, feature engineering, anomaly detector, SNN event processor |
| Doc | What it covers |
|---|---|
| Autonomous Trader | Full 10-stage autonomous trading loop: scan, signal, synthesize, debate, validate, risk, execute, monitor, learn, report |
| Risk Engine | VaR/CVaR (historical/parametric/MC), 8 stress scenarios, reverse stress test, drawdown monitor, risk budgets, tail hedge |
| Liquidity Oracle | Multi-dim scoring, intraday patterns, cross-asset contagion, dark pool analytics, MM inventory |
| Regime Oracle | Vol/trend/correlation/macro detectors, Markov transition model, strategy recommendations |
| Knowledge Graph | Entity-relationship graph, causal chain reasoning, transitive impact propagation, node2vec embeddings |
| Counterfactual Engine | Timing/parameter/allocation/regime counterfactuals, synthetic control, regret analysis |
| Debate Tournament | Round-robin debate, Dempster-Shafer consensus, calibrated agent weighting, risk veto |
| Genetic Evolution | NSGA-II fitness, adaptive mutation, island model population, speciation, Pareto archive |
| Scenario Generator | Macro scenarios (8 built-in), regime scenarios, Monte Carlo over regime paths |
| Walk-Forward Engine | Rolling/expanding CV, purging + embargo, parameter stability, regime-aware folds |
| Experiment Tracker | Experiment versioning, comparison, hyperparameter search, early stopping, leaderboard |
| Causal Hypothesis | Granger causality, transfer entropy, causal DAG (PC algorithm), mediation analysis |
| Live Feedback | Real-time model adaptation, signal quality tracking, drift detection, alert generation |
| Shadow Runner | Paper portfolio tracking, A/B testing, promotion criteria, multi-shadow parallel |
| Event Calendar | FOMC/CPI/NFP impact models, seasonal patterns, event clustering, earnings straddle |
| Data Quality | Missing data, outlier detection (z-score/IQR/Grubbs), staleness, splits, cross-source validation |
| Alternative Data | Satellite, web traffic, app downloads, credit card spending, job postings, weather impact |
| Doc | What it covers |
|---|---|
| Options Flow Signal | GEX/DEX by strike, charm, 0DTE flow, put-call ratio, vol skew, block sweep detection |
| Macro Momentum Signal | Nowcasting, economic surprise index, yield curve, credit spreads, cross-asset momentum |
| Sentiment Composite | News, social, analyst revisions, short interest, insider transactions, fund flows |
| Alpha Decay Signal | Rolling IC tracking, half-life estimation, MultiSignalDecayPortfolio with decay-weighted blending |
| Idea Synthesizer | Multi-domain signal fusion, conflict detection/resolution, narrative generation |
| Strategy Library | Persistent strategy registry, versioning, genealogy, decay detection, JSON persistence |
| Portfolio Allocator | Multi-strategy Kelly, regime-aware allocation, drawdown deleveraging, vol targeting |
| Idea Scorer | Novelty, feasibility, risk-adjusted return, timing, cross-domain, regime fit, capacity |
| Hypothesis Validator | PSR, OOS degradation, regime robustness, transaction cost break-even, BH FDR correction |
| Statistical Arbitrage | Pairs, ETF-NAV, index arb, triangular, vol arb, merger arb, convertible bond arb |
| Market Analogy Database | 12 cross-domain analogies (biology/physics/game theory), Lotka-Volterra, SIR cascade |
| Doc | What it covers |
|---|---|
| Research Validation | CPCV purged K-fold, Deflated Sharpe Ratio, causal inference, market efficiency tests |
| Market Microstructure | VPIN, OFI, Kyle's Lambda, L3 orderbook, Zig order flow, adversarial orderbook testing |
| Statistical Tooling | All Julia and R modules -- copulas, SVI, Kalman, HJB PDE, SABR, HMM, WFA |
| Monte Carlo Engine | GBM, Merton jump-diffusion, Heston, Longstaff-Schwartz American pricing, variance reduction |
Production-grade quantitative research framework built on SRFM BH physics. Control/experiment design: synthetic Heston paths vs real ES/NQ/YM SRFM data.
| Doc | What it covers |
|---|---|
| AETERNUS Overview | Full experiment design, LARSA v16 physics, results summary across all 4 hypotheses |
| TensorNet | MPS/TT-SVD correlation compression — 51x lower error on real vs synthetic, 67.2% BH direction alignment |
| Omni-Graph | Granger causality network — density 0.624 convergence vs 0.806 calm, p<0.0001 |
| Lumina | LSTM directional forecasting — 52.0% accuracy during convergence vs 50.4% calm |
| Hyper-Agent | 5-agent MARL with BH physics observations — ELO tournament, convergence episode analysis |
Experiment scripts:
run_aeternus_experiment.py— Synthetic control (Heston)run_aeternus_real.py— Real SRFM data experiment
Results: experiments/results/ (synthetic) and experiments/results/real_run/ (real)
| Doc | What it covers |
|---|---|
| Market Data Service | Dual-feed L2 aggregation, 15m bar assembly, WebSocket hub, failover, Prometheus metrics |
| Native Layer | Zig ITCH 5.0 decoder, lock-free L2 book, AVX2 L3 book, SIMD matrix, bar compression, tick processor |
| Rust Crates Reference | All 27 Rust crates: genome, MC, portfolio, risk, execution, fractal, FIX, online-learning, tick-backtest |
| Stack Overview | Every language, what it does, how to run it, integration diagram |
| Primitive Interactions | Full dependency map: every primitive, what it reads, writes, and calls |
| Doc | What it covers |
|---|---|
| Quick Start | Prerequisites, first backtest, first live trade |
| Running Backtests | All backtest modes, parameters, output interpretation |
| Live Trading | Paper and live setup, Alpaca keys, risk limits |
| Strategy Builder | Adding signals, instruments, and custom strategies |
| Interpreting Results | Sharpe, DSR, MC percentiles, IAE pattern scores |
The core innovation is the Black Hole (BH) Physics Strategy -- a signal model derived from special-relativistic mechanics applied to price data. Price bars are classified as timelike or spacelike using a Minkowski spacetime metric (ds^2 = c^2*dt^2 - dx^2). Mass accumulates on ordered (causal) bars, and a gravitational well forms when mass crosses the BH_FORM=1.92 threshold -- the black hole formation event that gates entries.
On top of this sits the Idea Automation Engine (IAE) -- an autonomous research system that runs genetic genome evolution (NSGA-II), causal discovery, regime classification, walk-forward validation, and academic paper mining continuously, feeding confirmed patterns back into live strategy parameters.
The system runs continuously in production on Alpaca paper trading, evolving its own parameters every 4-6 hours.
-> Full BH Physics deep dive -> Full IAE architecture deep dive
+------------------------------------------------------------------------------+
| SRFM Trading Lab |
| |
| +---------------------+ +------------------------------------------+ |
| | Live Trader | | Idea Automation Engine (IAE) | |
| | live_trader_ | | | |
| | alpaca.py |<---+ Genome Evolution (NSGA-II Rust) | |
| | | | Hypothesis Generator (Bayesian) | |
| | BH Physics Engine | | Regime Oracle (6 modes) | |
| | GARCH vol forecast | | Causal Discovery (Granger + PC) | |
| | OU mean reversion | | Walk-Forward (CPCV + DSR) | |
| | Mayer dampener | | Signal Library (105+ signals, IC decay) | |
| | BTC lead signal | | Academic Miner (arXiv + SSRN) | |
| | Dynamic CORR | | | |
| | RL Exit Policy | | +-------------------------------------+ | |
| | Regime Ensemble | | | Event Bus (:8768) Go API (:8767) | | |
| +------+-------------+ | | Scheduler (:8769) Webhook (:8770)| | |
| | | +-------------------------------------+ | |
| | fills | React Dashboard (:5175) | |
| v +------------------------------------------+ |
| +-------------+ |
| | SQLite | +----------------------------------------------------+ |
| | trade log | | Execution Stack | |
| | (WAL mode) | | L2 Orderbook (Alpaca WS + Binance fallback) | |
| +------+------+ | BookManager (30s failover) FeedMonitor | |
| | | SmartRouter (spread-tier: <=50/50-100/>100 bps) | |
| | | TWAP/VWAP/Iceberg algos AlgoScheduler | |
| | | Broker Adapters (Alpaca/Binance/Paper) | |
| | | CircuitBreaker + AdapterManager failover | |
| | +----------------------------------------------------+ |
| | |
| v |
| +--------------------+ +--------------------------------------------+ |
| | live_monitor/ | | crypto_backtest_mc.py + wave4 | |
| | CLI + dashboard | | 3-TF BH + GARCH + OU + MC (10K paths) | |
| +--------------------+ | EventCalendar + Granger + ML signal | |
| +--------------------------------------------+ |
| |
| +------------------------------------------------------------------+ |
| | Coordination Layer (Elixir/OTP :8781) | |
| | ParameterCoordinator CircuitBreaker HealthMonitor EventBus | |
| | RiskGuard delta check Rollback guard Schema validation | |
| +------------------------------------------------------------------+ |
| |
| Julia (~123K LOC) R (~60K LOC) Rust (~141K LOC) C/C++ (~19K LOC) |
| stats-service: copulas, HJB PDE, SVI/SABR, SARIMA, Kalman, AMM, CoVaR |
+------------------------------------------------------------------------------+
Data flow: Alpaca streams -> BH Engine -> position sizing -> SmartRouter -> L2 spread check -> orders -> SQLite log -> IAE ingestion -> genome evolution -> parameter feedback -> live strategy.
pip install alpaca-py pandas numpy scipy statsmodels matplotlib
# Rust (genome engine, Monte Carlo, 27 crates)
curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh
# Go 1.22+ (IAE microservices, market data)
# Node 18+ (React dashboards)
# Julia 1.9+ (statistical tooling)
# R 4.2+ (HMM, WFA, regime models)
# Zig 0.12+ (native layer: ITCH decoder, lock-free book)# Full crypto BH backtest + 10,000-path Monte Carlo
python tools/crypto_backtest_mc.py
# With Wave 4 enhancements (EventCalendar + Granger lead + ML signal)
python tools/backtest_wave4.py
# Custom parameters
python tools/crypto_backtest_mc.py \
--start-date 2022-01-01 --end-date 2025-01-01 \
--mc-paths 5000 --symbols BTC,ETH,SOL \
--bh-form 1.92 --corr 0.25 --garch-target-vol 0.90 \
--output-dir tools/backtest_output --verbose# All services at once
bash scripts/start_all.sh start
# Or individual trader
python tools/live_trader_alpaca.py --paper --log-level INFO
# Dry run (log orders but don't submit)
python tools/live_trader_alpaca.py --dry-run# Macro regime + on-chain + alt data + fear/greed + IAE idea miner
python run_full_analysis.py
# IAE ideas only (from backtest data)
python run_iae_analysis.pypython -m idea_engine.db.migrate # Initialize schema
python -m idea_engine.ingestion.pipeline # Run all miners
cd idea-engine && go run cmd/api/main.go # API :8767
go run cmd/bus/main.go # Event bus :8768
go run cmd/scheduler/main.go # Scheduler :8769
cd idea-engine/idea-dashboard && npm run dev # Dashboard :5175All executable tools, engines, and core primitives flagged by language and role.
Full dependency map showing which primitives call which: Primitive Interactions
Bar arrives from market-data :8780
|
v
BHState.update(bar) -- Minkowski ds^2, mass accumulation
|-- MinkowskiClassifier -- TIMELIKE / SPACELIKE classification
|-- GeodesicAnalyzer -- 20-bar regression quality
|-- GravitationalLens -- mu = tanh(mass / scale)
|
+-> GARCHTracker.update(bar) -- conditional vol h_t
+-> OUDetector.update(bar) -- mean-reversion theta, mu, sigma
+-> ATRTracker.update(bar) -- stop/size distance
+-> BullScale.update(bar, bh) -- BTC lead scaler
+-> HurstExponent.update(bar) -- H>0.58 trending, H<0.42 mean-reverting
|
+-> RegimeEnsemble -- 6-detector weighted majority vote
| |-- HMMRegime (Baum-Welch EM + Viterbi)
| |-- GARCHRegime (vol-based)
| |-- HurstRegime (scaling law)
| |-- OnlineRegimeSGD (adaptive)
| +-- TransitionPredictor (Markov matrix + Laplace smoothing)
|
+-> agent_d3qn(features) -- trend + momentum signal
+-> agent_ddqn(features) -- alignment composite
+-> agent_td3qn(features) -- mean-reversion contrarian
| each weighted by RegimeEnsemble (BULL/BEAR/SIDEWAYS/HIGH_VOL/TRENDING/MEAN_REV)
|
+-> RLExitPolicy.should_exit() -- Q-table lookup (3125 states, ~100ns)
| state: [pnl_bps, bars_held, bh_mass, garch_vol, spread_bps] binned 5x5x5x5x5
|
+-> QuatNavPy.update(bar, bh) -- nav observability (read-only)
NavStateWriter -> live_trades.db (nav_state table)
|
v
SmartRouter.route(signal, size)
BookManager.get_spread() -- live L2 spread check
AlpacaL2Feed (primary)
BinanceL2Feed (fallback, 30s failover)
CircuitBreaker[alpaca/binance] -- fast-fail if API degraded
|-- spread <= 50 bps: market order
|-- spread 50-100 bps: TWAP over 3 bars
+-- spread > 100 bps: VWAP or block
|
v
BrokerAdapter (Alpaca / Binance / Paper)
AlpacaAdapter: token bucket 200 req/min, exponential backoff
BinanceAdapter: HMAC-SHA256 signing, Spot/Futures routing
AdapterManager: failover chain, health-based routing
|
v
OrderManager.submit()
RiskGuard.pre_trade_check() -- notional, VaR, Greeks
ComplianceLogger.log_submission() -- hash-chain tamper-evident audit
AuditLog.record() -- immutable event store
|
v
execution/live_trades.db (WAL)
|
v (every 4-6h)
IAE ingestion -> GenomeEngine (Rust NSGA-II)
tick-backtest (Rust rayon) -- parallel fitness evaluation
CounterfactualEngine -- Sobol sensitivity validation
ParameterCoordinator (Elixir) -- schema + delta + rollback validation
LiveParamBridge (30s poll) -- hot-reload to LiveTrader
| Tool / Primitive | Path | Role | Flag |
|---|---|---|---|
LiveTrader |
tools/live_trader_alpaca.py |
Main live trading class | LIVE TRADER |
BHState |
tools/live_trader_alpaca.py |
BH mass accumulation struct | PRIMITIVE |
QuatNavPy |
bridge/quat_nav_bridge.py |
Quaternion navigation state machine | PRIMITIVE |
NavStateWriter |
bridge/quat_nav_bridge.py |
Writes nav signals to live_trades.db | PRIMITIVE |
GARCHTracker |
tools/live_trader_alpaca.py |
GARCH(1,1) vol forecaster | PRIMITIVE |
OUDetector |
tools/live_trader_alpaca.py |
OU mean-reversion detector | PRIMITIVE |
ATRTracker |
tools/live_trader_alpaca.py |
ATR position sizing | PRIMITIVE |
BullScale |
tools/live_trader_alpaca.py |
BTC lead signal scaler | PRIMITIVE |
RLExitPolicy |
lib/rl_exit_policy.py |
Q-table exit policy (3125 states) | PRIMITIVE |
RegimeEnsemble |
lib/regime.py |
6-detector weighted majority vote | PRIMITIVE |
HurstExponent |
lib/srfm_core.py |
R/S analysis trending vs mean-reverting | PRIMITIVE |
SignalCombiner |
lib/signal_combiner.py |
IC-weighted, Rank, Ensemble, conflict detection | PRIMITIVE |
PortfolioConstructor |
lib/portfolio_constructor.py |
RiskBudget, TurnoverConstraint, Sector limits | PRIMITIVE |
PnLCalculator |
lib/pnl_calculator.py |
FIFO cost basis, daily aggregation, attribution | PRIMITIVE |
AlphaDecayTracker |
lib/alpha_decay_tracker.py |
Exponential IC decay, retire candidates | PRIMITIVE |
ExecutionState |
lib/execution_state.py |
Thread-safe state with SQLite WAL, crash recovery | PRIMITIVE |
MarketCalendar |
lib/market_calendar.py |
NYSE hours, half-days, FOMC/CPI/NFP/OpEx | PRIMITIVE |
crypto_backtest_mc.py |
tools/ |
BH backtest + 10K-path Monte Carlo | BACKTEST ENGINE |
backtest_wave4.py |
tools/ |
Wave 4: EventCalendar + Granger + ML signal | BACKTEST ENGINE |
EventCalendarFilter |
tools/backtest_wave4.py |
FOMC/unlock event filter (0.5x +-2h) | PRIMITIVE |
MLSignalModule |
tools/backtest_wave4.py |
Logistic SGD signal (5-lag returns + GARCH) | PRIMITIVE |
NetworkSignalTracker |
tools/backtest_wave4.py |
BTC Granger lead (1.2x when | corr |
run_full_analysis.py |
/ |
Macro + on-chain + alt data + IAE pipeline | ANALYSIS RUNNER |
run_iae_analysis.py |
/ |
IAE idea miner (63K trades) | ANALYSIS RUNNER |
| Tool / Primitive | Path | Role | Flag |
|---|---|---|---|
ingestion/pipeline.py |
idea-engine/ |
4-stage mine -> filter -> store | PIPELINE |
TimeOfDayMiner |
idea-engine/ingestion/miners/ |
Hour-of-day P&L statistical test | MINER |
RegimeClusterMiner |
idea-engine/ingestion/miners/ |
Cluster-based regime patterns | MINER |
BHPhysicsMiner |
idea-engine/ingestion/miners/ |
BH state pattern extraction | MINER |
DrawdownMiner |
idea-engine/ingestion/miners/ |
Drawdown event patterns | MINER |
BootstrapFilter |
idea-engine/ingestion/statistical_filters/ |
BH FDR correction | FILTER |
OnChainEngine |
idea-engine/onchain/ |
BTC on-chain composite signal | SIGNAL ENGINE |
RegimeClassifier |
idea-engine/macro-factor/ |
6-class macro regime oracle | CLASSIFIER |
GenomeAnalyzer |
idea-engine/analysis/ |
Breakthrough events, gradient estimator | ANALYZER |
IAEPerformanceTracker |
idea-engine/analysis/ |
Cycle-level performance tracking | MONITOR |
ParameterExplorer |
idea-engine/analysis/ |
Landscape mapping, sensitivity | ANALYZER |
LiveFeedbackAnalyzer |
idea-engine/analysis/ |
Live trading gradient bridge | ANALYZER |
| Tool / Primitive | Path | Role | Flag |
|---|---|---|---|
OrderBook |
execution/orderbook/orderbook.py |
Thread-safe L2 book with VWAP fill | PRIMITIVE |
AlpacaL2Feed |
execution/orderbook/alpaca_l2_feed.py |
Alpaca WSS L2 feed | FEED |
BinanceL2Feed |
execution/orderbook/binance_l2_feed.py |
Binance @depth10 fallback feed | FEED |
BookManager |
execution/orderbook/book_manager.py |
Dual-feed + 30s failover | INFRASTRUCTURE |
SmartRouter |
execution/routing/smart_router.py |
Spread-tier order routing | ROUTER |
AlpacaAdapter |
execution/broker_adapters/alpaca_adapter.py |
Token bucket rate limiter, retry | ADAPTER |
BinanceAdapter |
execution/broker_adapters/binance_adapter.py |
HMAC signing, Spot/Futures routing | ADAPTER |
PaperAdapter |
execution/broker_adapters/paper_adapter.py |
FIFO P&L, partial fill simulation | ADAPTER |
AdapterManager |
execution/broker_adapters/adapter_manager.py |
Multi-adapter failover chain | ROUTER |
TWAPEngine |
execution/order_management/twap_engine.py |
Time-sliced TWAP execution | ALGO |
VWAPEngine |
execution/order_management/twap_engine.py |
U-shaped intraday VWAP execution | ALGO |
IcebergEngine |
execution/order_management/algo_scheduler.py |
Hidden qty with visible slice | ALGO |
AlgoScheduler |
execution/order_management/algo_scheduler.py |
Unified algo priority scheduler | INFRASTRUCTURE |
OrderBookTracker |
execution/order_management/order_book_tracker.py |
SQLite WAL tracker, crash recovery | INFRASTRUCTURE |
ComplianceLogger |
execution/audit/compliance_logger.py |
Hash-chain tamper-evident audit log | AUDIT |
FillProcessor |
execution/oms/fill_processor.py |
Fill normalization and P&L attribution | OMS |
OrderRouter |
execution/oms/order_router.py |
Internal order routing state machine | OMS |
supervisor.py |
scripts/ |
HTTP :8790 process supervisor | INFRASTRUCTURE |
| Tool / Primitive | Path | Role | Flag |
|---|---|---|---|
ConfigManager |
config/config_manager.py |
Dot-notation config, file watcher, subscribers | CONFIG |
InstrumentsManager |
config/instruments_manager.py |
32-instrument universe, BH physics fields | CONFIG |
EventCalendarManager |
config/event_calendar_manager.py |
FOMC/CPI/NFP/OpEx blackout dates | CONFIG |
RiskConfig |
config/risk_config.py |
Risk limits, position compliance, BH-aware sizing | RISK |
59 modules covering stochastic calculus, portfolio optimization, derivatives, credit, microstructure, and more. All pure numpy/scipy.
| Tool / Primitive | Path | Role | Flag |
|---|---|---|---|
LinearKalmanFilter |
lib/math/kalman_filter.py |
1D/2D Kalman, EKF, UKF, SIR particle, RTS smoother | PRIMITIVE |
fit_gpd / gpd_var |
lib/math/extreme_value_theory.py |
GPD tail fitting, EVT VaR/CVaR, Hill estimator | PRIMITIVE |
mvo_portfolio / black_litterman |
lib/math/portfolio_math.py |
MVO, BL, HRP, ERC, CVaR LP, Kelly, max entropy | PRIMITIVE |
AlmgrenChrissParams |
lib/math/market_impact.py |
Almgren-Chriss optimal execution + efficient frontier | PRIMITIVE |
sqrt_market_impact |
lib/math/market_impact.py |
Square-root impact model, VWAP cost, info leakage | PRIMITIVE |
OrderBookPressureSignal |
lib/math/order_book_models.py |
OBI, micro-price, queue-reactive, Hawkes, spread decomposition | PRIMITIVE |
MFGExecutionParams |
lib/math/mean_field_games.py |
MFG Nash execution, herding equilibrium, systemic risk | PRIMITIVE |
garman_kohlhagen / sabr_vol |
lib/math/fx_models.py |
GK pricing, vanna-volga, SABR FX calibration | PRIMITIVE |
funding_rate_model |
lib/math/crypto_microstructure.py |
Funding rate, liquidation cascade, NVT/MVRV, hash ribbon | PRIMITIVE |
GibsonSchwartzModel |
lib/math/commodity_models.py |
Gibson-Schwartz, Schwartz-Smith, Fourier seasonal | PRIMITIVE |
bond_price_from_ytm / key_rate_duration |
lib/math/fixed_income_advanced.py |
Full bond math, OAS, MBS PSA, swap pricing, TIPS | PRIMITIVE |
batch_auction_price_discovery |
lib/math/auction_theory.py |
FPSBA, Vickrey, treasury auction, dark pool crossing | PRIMITIVE |
almgren_chriss_optimal_schedule |
lib/math/optimal_stopping.py |
LSM American options, Bayesian stopping, Snell envelope | PRIMITIVE |
cp_decomposition |
lib/math/tensor_decomposition.py |
CP/Tucker/NTF tensor decomposition, tensor regression | PRIMITIVE |
HawkesProcess |
lib/math/point_processes.py |
Hawkes (uni+multivariate), Cox process, Ogata thinning | PRIMITIVE |
Isomap / DiffusionMap |
lib/math/manifold_learning.py |
Isomap, LLE, Laplacian eigenmaps, t-SNE, persistent homology | PRIMITIVE |
admm_solver |
lib/math/convex_optimization.py |
ADMM, proximal operators, QP, CVaR LP, log-barrier | PRIMITIVE |
wavelet_transform |
lib/math/wavelets_advanced.py |
DWT, MODWT, wavelet packets, denoising, multifractal | PRIMITIVE |
ergodic_kelly |
lib/math/ergodic_theory.py |
Time-average returns, Kelly from ergodicity, vol drag | PRIMITIVE |
bs_greeks |
lib/math/derivatives_pricing.py |
Full BS Greeks, barrier/lookback/Asian options, variance swaps | PRIMITIVE |
HypothesisValidator |
lib/math/combinatorics_finance.py |
PSR, Deflated SR, CPCV, walk-forward CV, BH FDR | PRIMITIVE |
merton_structural_model |
lib/math/credit_models.py |
Merton, KMV, Jarrow-Turnbull, CDS, CDO, Credit VaR | PRIMITIVE |
hamilton_filter |
lib/math/regime_switching_econometrics.py |
Hamilton MS-AR, TAR, STAR, MS-GARCH, BOCPD, Bai-Perron | PRIMITIVE |
| Additional (36 more modules) | lib/math/ |
Copulas, HMM, factor models, graph theory, robust stats, simulation, spectral, network contagion, information theory, jump diffusion, numerical methods, interest rate models, volatility models, portfolio construction, RL, Bayesian update | PRIMITIVES |
22 modules. All pure numpy, no external DL frameworks.
| Tool / Primitive | Path | Role | Flag |
|---|---|---|---|
SignalNetwork |
lib/ml/deep_signal_network.py |
Dense/BN/Dropout/Residual/LSTM/TCN, backprop, Adam | ML MODEL |
FinancialGNNPipeline |
lib/ml/graph_neural_network.py |
GCN, GAT, GraphSAGE, temporal GNN, portfolio GNN | ML MODEL |
TransformerEncoder |
lib/ml/market_transformer.py |
Multi-head attention, causal mask, GRN, walk-forward | ML MODEL |
GPRegressor |
lib/ml/gaussian_process.py |
7 kernels, sparse GP FITC, marginal likelihood opt | ML MODEL |
CompositeOnlineLearner |
lib/ml/online_learning.py |
FTRL, ONS, EG, Hedge, Universal Portfolio, ADWIN | ML MODEL |
VAE |
lib/ml/variational_autoencoder.py |
VAE + Beta-VAE + Conditional VAE, ELBO, anomaly detection | ML MODEL |
NormalizingFlow |
lib/ml/normalizing_flows.py |
Planar/radial/RealNVP, density estimation, fat tails | ML MODEL |
TCNBlock |
lib/ml/temporal_conv_network.py |
Causal dilated conv, WaveNet gated units, multi-horizon | ML MODEL |
DeepSSM |
lib/ml/state_space_model.py |
Linear Gaussian SSM, S4-inspired, HiPPO initialization | ML MODEL |
DiffusionModel |
lib/ml/diffusion_model.py |
Denoising diffusion, DDIM sampler, conditional generation | ML MODEL |
MixtureDensityNetwork |
lib/ml/mixture_density_network.py |
GMM output, conditional density, tail probability | ML MODEL |
ContrastiveEncoder |
lib/ml/contrastive_learning.py |
SimCLR regime representation, NT-Xent, similarity search | ML MODEL |
BayesianNeuralNetwork |
lib/ml/bayesian_neural_network.py |
Variational inference, MC Dropout, calibrated uncertainty | ML MODEL |
EnsembleForecast |
lib/ml/ensemble_forecaster.py |
Linear/Kernel/Tree/SVM ensemble, online weight update | ML MODEL |
FeatureMatrix |
lib/ml/feature_engineering.py |
50+ features: momentum, vol, technicals, microstructure | FEATURE ENGINE |
22 major subsystems covering the full autonomous trading pipeline.
| Tool / Primitive | Path | Role | Flag |
|---|---|---|---|
AutonomousTrader |
idea-engine/autonomous-loop/autonomous_trader.py |
10-stage autonomous trading loop orchestrator | ORCHESTRATOR |
PortfolioRiskEngine |
idea-engine/risk-engine/portfolio_risk.py |
VaR/CVaR, 8 stress scenarios, drawdown monitor, risk budgets | RISK ENGINE |
LiquidityOracle |
idea-engine/liquidity-oracle/liquidity_engine.py |
Multi-dim scoring, intraday patterns, cross-asset contagion | ORACLE |
RegimeOracle |
idea-engine/regime-oracle/regime_ensemble.py |
Vol/trend/correlation/macro ensemble, Markov transitions | ORACLE |
MarketKnowledgeGraph |
idea-engine/knowledge-graph/market_knowledge_graph.py |
Causal chain reasoning, impact propagation, node2vec | KNOWLEDGE |
CounterfactualEngine |
idea-engine/counterfactual/counterfactual_engine.py |
Timing/parameter/regime counterfactuals, regret analysis | ANALYSIS |
DebateTournament |
idea-engine/debate-system/debate_tournament.py |
Round-robin multi-agent debate with consensus building | DEBATE |
IdeaSynthesizer |
idea-engine/meta/idea_synthesizer.py |
Multi-domain signal fusion, conflict resolution, narrative | SYNTHESIZER |
StrategyLibrary |
idea-engine/meta/strategy_library.py |
Strategy registry, versioning, genealogy, decay detection | REGISTRY |
PortfolioAllocator |
idea-engine/meta/portfolio_allocator.py |
Multi-strategy Kelly, regime-aware, drawdown deleverage | ALLOCATOR |
IdeaScorer |
idea-engine/meta/idea_scorer.py |
7-dimension scoring: novelty, feasibility, timing, capacity | SCORER |
CausalHypothesisEngine |
idea-engine/causal/causal_hypothesis_engine.py |
Granger causality, transfer entropy, causal DAG discovery | CAUSAL |
FeedbackLoop |
idea-engine/live-feedback/feedback_loop.py |
Real-time model adaptation, drift detection, alerts | FEEDBACK |
ShadowPortfolio |
idea-engine/shadow-runner/shadow_portfolio.py |
Paper portfolio tracking, A/B testing, promotion criteria | SHADOW |
EventImpactModel |
idea-engine/event-calendar/event_impact_model.py |
FOMC/CPI/NFP impact, seasonal patterns, event clustering | EVENT |
DataValidator |
idea-engine/data-quality/data_validator.py |
Missing data, outliers, staleness, splits, cross-source | VALIDATOR |
AltDataSignalEngine |
idea-engine/alternative-data/alt_data_signals.py |
Satellite, web traffic, app downloads, credit card, jobs | ALT DATA |
WalkForwardEngine |
idea-engine/walk-forward/walk_forward_engine.py |
Rolling/expanding CV, purging, parameter stability | VALIDATION |
ExperimentManager |
idea-engine/experiment-tracker/experiment_manager.py |
Versioning, comparison, hyperparameter search, leaderboard | TRACKER |
MarketAnalogyEngine |
idea-engine/serendipity/market_analogy_database.py |
12 cross-domain analogies, Lotka-Volterra, SIR cascade | SERENDIPITY |
SelfImprovingEngine |
idea-engine/meta/self_improving_engine.py |
Parameter evolution, template pruning/promotion, fitness landscape | EVOLUTION |
PPOAgent |
idea-engine/rl/ppo_trader.py |
PPO with GAE, entropy bonus, LR schedule, actor-critic | RL AGENT |
| Tool / Primitive | Path | Role | Flag |
|---|---|---|---|
CausalInference |
research/validation/causal_inference.py |
Granger, PSM, DiD, 2SLS | VALIDATION |
OutOfSampleValidator |
research/validation/out_of_sample_validator.py |
CPCV, DSR, BH FDR | VALIDATION |
MarketEfficiencyTests |
research/validation/market_efficiency_tests.py |
VR test, runs test, GPH long memory | VALIDATION |
PerformancePersistence |
research/validation/performance_persistence.py |
Contingency table, IR stability | VALIDATION |
EfficientFrontierLab |
research/portfolio_lab/efficient_frontier_lab.py |
SLSQP, bootstrap confidence bands | RESEARCH |
FactorExposureAnalyzer |
research/portfolio_lab/factor_exposure_analyzer.py |
OLS attribution, 7-factor model | RESEARCH |
ReturnAttributionLab |
research/portfolio_lab/return_attribution_lab.py |
BHB Brinson, factor attribution | RESEARCH |
AgentBasedModel |
research/simulation/agent_based_model.py |
5 agent types, OU true-value walk | SIMULATION |
MicrostructureSimulator |
research/simulation/microstructure_simulator.py |
LOB simulator, tick data generator | SIMULATION |
WhaleTracker |
research/onchain_advanced/whale_tracker.py |
Per-asset thresholds, z-score significance | ON-CHAIN |
NetworkValue |
research/onchain_advanced/network_value.py |
NVT, Metcalfe, MVRV, S2F | ON-CHAIN |
| Tool / Primitive | Path | Role | Flag |
|---|---|---|---|
BayesianOptimizer |
optimization/bayesian_optimizer.py |
Matern 5/2 GP + EI acquisition | OPTIMIZER |
HyperparameterSearch |
optimization/hyperparameter_search.py |
NSGA-II with hypervolume, Sobol sampling | OPTIMIZER |
RegimeParameterOptimizer |
optimization/regime_parameter_optimizer.py |
Per-regime Optuna studies, SQLite store | OPTIMIZER |
ParameterLandscape |
spacetime/engine/parameter_landscape.py |
DuckDB-cached landscape, gradient, robustness | ANALYZER |
ScenarioEngine |
spacetime/engine/scenario_engine.py |
12 scenarios, parallel ThreadPoolExecutor | SIMULATION |
| Tool / Primitive | Crate | Role | Flag |
|---|---|---|---|
genome-engine |
idea-engine/rust/ |
NSGA-II multi-objective genome evolution | OPTIMIZER |
idea-genome-engine |
crates/idea-genome-engine/ |
Crossover/mutation/selection/constraint strategies | OPTIMIZER |
counterfactual-oracle |
idea-engine/rust/ |
Counterfactual scenario runner | ORACLE |
tick-backtest |
crates/tick-backtest/ |
Tick-level BH backtest (rayon parallel) | BACKTEST ENGINE |
larsa-core |
crates/larsa-core/ |
Core BH engine (Rust port, PyO3) | PRIMITIVE |
larsa-wasm |
crates/larsa-wasm/ |
BH trajectory, heatmap, efficient frontier (WASM) | WASM |
portfolio-engine |
crates/portfolio-engine/ |
Ledoit-Wolf, HRP, Black-Litterman | OPTIMIZER |
risk-engine |
crates/risk-engine/ |
VaR/CVaR, Greeks, stress scenarios | RISK |
monte-carlo-engine |
crates/monte-carlo-engine/ |
GBM, Merton, Heston, Longstaff-Schwartz | SIMULATION |
online-learning |
crates/online-learning/ |
FTRL, PA-II, Hedge, Adam, bandits | ML |
rl-exit-optimizer |
crates/rl-exit-optimizer/ |
Double DQN, PER, reward shaping | RL |
regime-analytics |
crates/regime-analytics/ |
HMM (Baum-Welch), transition model, conditional perf | ANALYTICS |
smart-order-router |
crates/smart-order-router/ |
PoV strategy, dark pool router, liquidity aggregator | EXECUTION |
microstructure-engine |
crates/microstructure-engine/ |
VPIN, OFI, effective spread, regime signals | MICROSTRUCTURE |
orderbook-sim |
crates/orderbook-sim/ |
Synthetic orderbook, adversarial testing | SIMULATION |
fix-engine |
crates/fix-engine/ |
FIX 4.2 session, execution report parser, order manager | PROTOCOL |
execution-optimizer |
crates/execution-optimizer/ |
Almgren-Chriss trajectory, adaptive urgency | EXECUTION |
data-pipeline |
crates/data-pipeline/ |
Quality checks, timeseries ops, HDR histogram metrics | DATA |
factor-analytics |
crates/factor-analytics/ |
IC, factor decay, Fama-MacBeth | ANALYTICS |
alpha-decay |
crates/alpha-decay/ |
IC half-life, signal retirement scoring | ANALYTICS |
fractal-analysis |
crates/fractal-analysis/ |
Hurst exponent, DFA, multifractal | ANALYTICS |
order-flow-engine |
crates/order-flow-engine/ |
Order flow prediction, liquidity provision (Avellaneda-Stoikov) | MICROSTRUCTURE |
Full module reference: Statistical Tooling docs
| Module | Location | Key Capability | Flag |
|---|---|---|---|
BHPhysics.jl |
julia/src/ |
BH engine, walk-forward, cross-sectional | CORE ENGINE |
Stochastic.jl |
julia/src/ |
GARCH, Heston, Hawkes, OU, Merton JD | STOCHASTIC |
Bayesian.jl |
julia/src/ |
MCMC, Bayesian CF estimation | INFERENCE |
SystemicRisk.jl |
julia/src/ |
CoVaR, MES, SRISK, Eisenberg-Noe, DebtRank | RISK |
NumericalMethods.jl |
julia/src/ |
PDE solvers, Halton/Sobol MC, quadrature | NUMERICAL |
TimeSeriesAdvanced.jl |
julia/src/ |
SARIMA, Kalman/RTS, DFM, Granger, VECM | TIME SERIES |
CryptoDefi.jl |
julia/src/ |
AMM pricing, Uniswap v3, IL, MEV | CRYPTO |
ExecutionAnalytics.jl |
julia/src/ |
VWAP/TWAP, Almgren-Chriss, TCA | EXECUTION |
volatility_surface.jl |
idea-engine/stats-service/julia/ |
SVI, SABR, Dupire local vol, variance swaps | VOLATILITY |
alpha_research.jl |
idea-engine/stats-service/julia/ |
IC/ICIR pipeline, factor decay, quintile bt | ALPHA |
stochastic_control.jl |
idea-engine/stats-service/julia/ |
HJB PDE, optimal control | CONTROL |
copula_models.jl |
idea-engine/stats-service/julia/ |
Gaussian/Clayton/Gumbel copulas, tail dep | DEPENDENCE |
machine_learning_advanced.jl |
idea-engine/stats-service/julia/ |
GBM, neural net from scratch, CV, SHAP | ML |
reinforcement_learning.jl |
idea-engine/stats-service/julia/ |
Q-learning, policy gradient, DQN | RL |
numerical_methods.jl |
idea-engine/stats-service/julia/ |
Halton/Sobol, variance reduction, PDE | NUMERICAL |
40 Julia source modules + 34 notebooks. See Statistical Tooling for full list.
Full module reference: Statistical Tooling docs
| Module | Location | Key Capability | Flag |
|---|---|---|---|
bh_analysis.R |
r/R/ |
BH state reconstruction, regime classification | CORE |
regime_models.R |
r/R/ |
HMM, Markov switching, GARCH-DCC | REGIME |
volatility_models.R |
idea-engine/stats-service/r/ |
GARCH, EGARCH, realized vol, HAR | VOLATILITY |
spectral_analysis.R |
idea-engine/stats-service/r/ |
FFT, wavelet decomposition, periodogram | SPECTRAL |
copula_analysis.R |
idea-engine/stats-service/r/ |
Copula fitting, tail dependence | DEPENDENCE |
bayesian_portfolio.R |
idea-engine/stats-service/r/ |
Bayesian Black-Litterman, shrinkage | PORTFOLIO |
systemic_risk.R |
r/R/ |
CoVaR, MES, SRISK, DebtRank contagion | RISK |
advanced_ml.R |
idea-engine/stats-service/r/ |
SVM, GP regression, MLP+Adam, attention | ML |
time_series_advanced.R |
r/R/ |
TBATS, DFM via EM, DCC-GARCH, BEKK | TIME SERIES |
stress_testing.R |
r/R/ |
COVID/LUNA/FTX/Apr-2026 historical scenarios | RISK |
signal_research.R |
r/R/ |
IC/ICIR, Fama-MacBeth, factor decay half-life | ALPHA |
walk_forward_analysis.R |
idea-engine/stats-service/r/ |
CPCV walk-forward, Sobol optimization | VALIDATION |
29 R modules across 3 directories + 12 research scripts. See Statistical Tooling for full list.
Deep dive: C++ Signal Engine | Native Layer
| Component | Path | Role | Flag |
|---|---|---|---|
BHState (C++) |
cpp/signal-engine/src/bh_physics/ |
Sub-millisecond BH mass accumulation | PRIMITIVE |
QuatNav (C++) |
cpp/signal-engine/src/quaternion/ |
C++ quaternion nav | PRIMITIVE |
GARCHState (C++) |
cpp/signal-engine/src/bh_physics/ |
GARCH(1,1) vol forecaster | PRIMITIVE |
KalmanFilter (C++) |
cpp/signal-engine/src/indicators/ |
1D/2D/Adaptive/Pair Kalman filters, C ABI | PRIMITIVE |
TickIndicators (C++) |
cpp/signal-engine/src/indicators/ |
TickImbalance, VPIN, MicropriceCalculator, OFI | PRIMITIVE |
MultiTimeframeSignal (C++) |
cpp/signal-engine/src/composite/ |
4H/1H/15M aggregation (0.50/0.30/0.20), 4H override | PRIMITIVE |
LorentzBoost (C++) |
cpp/signal-engine/src/bh_physics/ |
Minkowski boost, worldline integrator, proper time | PRIMITIVE |
ZmqPublisher (C++) |
cpp/signal-engine/src/io/ |
In-process bus, batch publisher, signal router | PRIMITIVE |
| Fast indicators (20 signals) | cpp/signal-engine/src/indicators/ |
SIMD-accelerated RSI/MACD/BB/ATR/VWAP | PRIMITIVE |
SignalOutput struct |
cpp/signal-engine/include/srfm/types.hpp |
320-byte output frame (5 cache lines) | PRIMITIVE |
RingBuffer |
cpp/signal-engine/include/srfm/ring_buffer.hpp |
Lock-free SPSC bar event queue | PRIMITIVE |
| L3 orderbook (C) | native/orderbook/ |
AVX2 price ladder, VWAP fill estimation | PRIMITIVE |
| SIMD matrix (C) | native/matrix/ |
AVX2 matmul for portfolio covariance | PRIMITIVE |
Deep dive: Native Layer
| Component | Path | Role | Flag |
|---|---|---|---|
| ITCH 5.0 decoder | native/zig/itch/ |
NASDAQ ITCH 5.0 binary protocol parser, 4 GB/s | DECODER |
| Lock-free L2 book | native/zig/orderbook/ |
~180ns add/cancel, ~15ns best bid/ask | PRIMITIVE |
| Bar compression | native/zig/src/compression.zig |
Delta+RLE encoding, ~10x compression, C ABI | PRIMITIVE |
| Tick processor | native/zig/src/tick_processor.zig |
SPSC ring buffer, bar aggregator, VWAP | PRIMITIVE |
| SIMD indicators | native/zig/src/simd_indicators.zig |
EMA/SMA/RSI/ATR/Bollinger/MACD vectorized | PRIMITIVE |
| Order flow | native/zig/src/order_flow.zig |
FootprintBar, CumulativeDelta, BuyPressure, VPIN | PRIMITIVE |
| Lock-free ring buffer (C) | native/ringbuffer/ |
180M ops/sec SPSC, cache-line padded | PRIMITIVE |
Deep dive: Market Data Service
| Service | Port | Path | Role | Flag |
|---|---|---|---|---|
| Market Data | :8780 |
market-data/ |
L2 aggregation, 15m bar assembly, WebSocket fan-out | LIVE |
| IAE API | :8767 |
idea-engine/cmd/api/ |
Hypotheses, patterns, backtest jobs | API |
| IAE Event Bus | :8768 |
idea-engine/cmd/bus/ |
Pub/sub: pattern_confirmed, backtest_complete | MESSAGE BUS |
| IAE Scheduler | :8769 |
idea-engine/cmd/scheduler/ |
Cron: mine (1h/4h/daily), tune (4h) | SCHEDULER |
| IAE Webhook | :8770 |
idea-engine/cmd/webhook/ |
Alpaca fill ingest + external alerts | WEBHOOK |
| Metrics Server | internal | idea-engine/cmd/metrics-server/ |
Ring buffers, Prometheus /metrics, ingest endpoints | METRICS |
| Genome Inspector | CLI | idea-engine/cmd/genome-inspector/ |
ANSI CLI: list/best/compare/history/stats | CLI |
| Correlation Tracker | internal | market-data/pkg/analytics/ |
Rolling cross-asset correlations | ANALYTICS |
| Regime Classifier | internal | market-data/pkg/analytics/ |
Market regime from bar stream | ANALYTICS |
| Bar Compressor | internal | market-data/pkg/storage/ |
Tiered cache: L1 ring + L2 SQLite, 252d retention | STORAGE |
| Research API | :8766 |
infra/research-api/ |
Research data query API | API |
| Alerter | internal | cmd/alerter/ |
Slack/email/PagerDuty alert routing | INFRA |
| TUI | terminal | cmd/srfm-tui/ |
Terminal live trading dashboard | UI |
Key Go primitives:
BookManager(market-data): dual-feed failover state machine, 30s Alpaca timeoutBarAggregator(market-data): tick-to-OHLCV, wall-clock-anchored 15m windowsWebSocketHub(market-data): fan-out to all subscribers, 100-message slow-consumer limitAlertEngine(cmd/alerter): dedup, snooze, maintenance window, multi-channel routingGenomeStore(idea-engine/pkg/persistence): lineage BFS, generational pruningFitnessAggregator(idea-engine/pkg/evaluation): 3-period weighted Sharpe + Pareto rankTieredCache(market-data/pkg/cache): L1 ring + L2 SQLite, 252-day retention
Deep dive: Coordination Layer
| Component | Port | Role | Flag |
|---|---|---|---|
ParameterCoordinator |
:8781 |
Validates + fans out IAE parameter updates | LIVE |
CircuitBreaker |
:8781 |
Per-API fault isolation (Alpaca, Binance, Polygon) | LIVE |
HealthMonitor |
:8781 |
30s health polls, automatic service restarts | LIVE |
EventBus |
:8781 |
In-process pub/sub with 1000-event ETS history | LIVE |
ServiceRegistry |
:8781 |
ETS-backed service PID + metadata registry | LIVE |
GenomeBridge |
:8781 |
HTTP bridge to IAE genome engine | LIVE |
PerformanceLedger |
:8781 |
ETS + SQLite cycle performance tracking | LIVE |
ConfigBroadcast |
:8781 |
Ack-tracked config fanout with retry | LIVE |
AlertManager |
:8781 |
Dedup, rate limit, multi-channel alerts | LIVE |
SessionManager |
:8781 |
Session lifecycle state machine | LIVE |
MetricsAggregator |
:8781 |
Prometheus text-format export | LIVE |
| Component | Port | Path | Role | Flag |
|---|---|---|---|---|
| IAE Dashboard | :5175 |
idea-engine/idea-dashboard/ |
Genome evolution, patterns, backtests | UI |
| IAE Evolution | internal | terminal/src/pages/IAEEvolution.tsx |
Parallel coords, heatmap, pedigree SVG | UI |
| Signal Evolution | internal | terminal/src/pages/SignalEvolution.tsx |
Signal tree, gene contribution, novelty scatter | UI |
| BH Physics Panel | internal | terminal/src/components/bh/BHPhysicsPanel.tsx |
Quaternion sphere, spacetime flow field | UI |
| Walk Forward | internal | spacetime/web/src/pages/WalkForward.tsx |
IS/OOS grid, fold timeline | UI |
| Factor Analysis | internal | spacetime/web/src/pages/FactorAnalysis.tsx |
7-factor attribution, Fama-MacBeth | UI |
| Spacetime Web | :5173 |
spacetime/web/ |
BH backtester UI, parameter sweep | UI |
| Research Dashboard | :5174 |
research/dashboard/ |
Risk, signal research, on-chain | UI |
| Component | Description | Flag |
|---|---|---|
docker-compose.yml |
5-service deployment (trader/monitor/supervisor/orderbook/bridge) | DEPLOY |
Dockerfile.python |
2-stage build, non-root srfm user | DEPLOY |
scripts/supervisor.py |
HTTP :8790 process supervisor, exponential backoff restart | INFRASTRUCTURE |
scripts/start_all.sh |
Health-check loop, auto-restart, stop/restart/status | INFRASTRUCTURE |
scripts/daily_startup.py |
9-step orchestrated daily startup | INFRASTRUCTURE |
scripts/daily_shutdown.py |
10-step EOD shutdown with P&L capture | INFRASTRUCTURE |
scripts/emergency_stop.py |
Halt + flatten all positions + PD alert | INFRASTRUCTURE |
scripts/param_update_manual.py |
Diff + confirm + audit parameter changes | INFRASTRUCTURE |
config/signal_overrides.json |
Hot-reloaded per-symbol + global multipliers | CONFIG |
config/instruments.yaml |
32 instruments with CF calibration | CONFIG |
warehouse/warehouse_manager.py |
DuckDB analytics warehouse, migration runner, TCA queries | DATA |
.github/workflows/ |
CI/CD for Python/Rust/Go/TS/Julia | CI/CD |
| Language | LOC | Key Systems | Docs |
|---|---|---|---|
| Python | ~1,000K | Live trader (LARSA v18), backtesting, IAE pipeline, AETERNUS lab, 59-module quant math library, 22-module ML library, 22 idea-engine subsystems, execution algos, broker adapters, risk API, regime ensemble, config management, research validation, optimization | Execution Stack |
| Julia | ~172K | Advanced options (Heston/SABR/Merton/Dupire), live risk (VaR/CVaR/stress), ML signals (GP/Kalman/HMM), vectorized backtesting (CPCV/DSR), numerical methods (PDE/Sobol/quadrature) | Statistical Tooling |
| Rust | ~202K | 27 crates: genome engine, Monte Carlo, portfolio, risk, online-learning (FTRL/Hedge/bandits), RL exit optimizer, regime-analytics, smart-order-router, microstructure, FIX engine, WASM analytics | Rust Crates Reference |
| R | ~73K | HMM, regime models, WFA, factor analysis, options risk, microstructure, stress testing, copulas, spectral | Statistical Tooling |
| TypeScript/React | ~58K | IAE dashboard, signal evolution, BH physics panel, walk-forward, factor analysis, spacetime UI, research dashboards | Stack Overview |
| Go | ~109K | IAE microservices (API/bus/scheduler/webhook/metrics), market data (L2 agg/bar assembly/WebSocket), genome inspector, alerter, TUI | Market Data Service |
| C/C++ | ~59K | Signal engine (Kalman, tick indicators, multi-timeframe, Lorentz boost, ZMQ), L3 orderbook (AVX2), matrix ops | C++ Signal Engine |
| Zig | ~13K | ITCH 5.0 decoder, lock-free L2 book, bar compression, tick processor, SIMD indicators, order flow | Native Layer |
| Elixir/OTP | ~12K | Coordination: OTP supervision, circuit breakers, param validation, rollback, genome bridge, alert manager | Coordination Layer |
| SQL | ~7K | SQLite (16 migrations, WAL), DuckDB analytics, BH UDFs, warehouse views, TCA queries | Stack Overview |
| Total | ~1,708,917 | 4,888 tracked files |
srfm-lab/
|
+-- tools/ # Core trading tools
| +-- live_trader_alpaca.py # LIVE TRADER: BH Physics + GARCH + OU + IAE params
| +-- crypto_backtest_mc.py # BACKTEST: BH + 10K-path Monte Carlo
| +-- backtest_wave4.py # WAVE 4: EventCalendar + Granger + ML signal
| +-- walk_forward_engine.py # Walk-forward analysis
| +-- factor_analysis.py # Fama-MacBeth, IC/ICIR, factor decay
| +-- larsa_v18_backtest.py # LARSA v18 full backtest
| +-- stress_testing.py # 20 stress scenarios
| +-- backtest_output/ # SQLite DBs, CSV trade logs, PNG charts
|
+-- idea-engine/ # IAE (Idea Automation Engine)
| +-- db/ # Schema migrations (SQLite WAL)
| +-- ingestion/ # 4-stage pipeline: load -> mine -> filter -> store
| +-- analysis/ # GenomeAnalyzer, PerformanceTracker, ParameterExplorer
| +-- autonomous-loop/ # LoopController, PerformanceEvaluator, CycleReporter (Go)
| +-- strategy-lab/ # ChampionManager, ExperimentTracker, Versioner (Go)
| +-- genome/ # Rust NSGA-II genome evolution
| +-- hypothesis/ # Bayesian hypothesis generator + 22 templates
| | +-- templates/ # stat arb, macro-micro fusion, physics-inspired, etc.
| | +-- hypothesis_validator.py # PSR, OOS degradation, regime robustness, FDR
| | +-- adversarial_tester.py # Data snooping, overfitting, stress tests
| | +-- genealogy.py # DAG lineage, crossover spawn
| +-- causal/ # Granger + PC algorithm causal discovery
| | +-- causal_hypothesis_engine.py # Transfer entropy, causal DAG, mediation
| +-- walk-forward/ # Walk-forward analysis
| | +-- walk_forward_engine.py # Rolling/expanding CV, purging, stability
| +-- regime-oracle/ # Regime detection ensemble
| | +-- regime_ensemble.py # Vol/trend/corr/macro, Markov transitions
| +-- risk-engine/ # Portfolio risk
| | +-- portfolio_risk.py # VaR/CVaR, stress testing, drawdown monitor
| +-- liquidity-oracle/ # Liquidity assessment
| | +-- liquidity_engine.py # Scoring, intraday patterns, contagion
| +-- knowledge-graph/ # Market knowledge
| | +-- market_knowledge_graph.py # Causal chains, impact propagation, embeddings
| +-- counterfactual/ # What-if analysis
| | +-- counterfactual_engine.py # Timing/allocation/regime counterfactuals
| +-- autonomous-loop/ # Master orchestrator
| | +-- autonomous_trader.py # 10-stage autonomous trading loop
| +-- data-quality/ # Data validation
| | +-- data_validator.py # Outliers, staleness, splits, cross-source
| +-- live-feedback/ # Real-time adaptation
| | +-- feedback_loop.py # Model update, drift detection, alerts
| +-- shadow-runner/ # Paper trading
| | +-- shadow_portfolio.py # A/B testing, promotion criteria
| +-- event-calendar/ # Event impact
| | +-- event_impact_model.py # FOMC/CPI/NFP models, seasonal patterns
| +-- experiment-tracker/ # Experiment management
| | +-- experiment_manager.py # Versioning, comparison, leaderboard
| +-- alternative-data/ # Alt data signals
| | +-- alt_data_signals.py # Satellite, web traffic, credit card, jobs
| +-- signals/ # 12 signal modules with IC tracking
| +-- cmd/ # Go: API :8767, bus :8768, scheduler :8769, webhook :8770
| +-- cmd/genome-inspector/ # ANSI CLI: list/best/compare/history/stats
| +-- cmd/metrics-server/ # Ring buffers, Prometheus /metrics
| +-- stats-service/julia/ # 40 Julia modules
| +-- stats-service/r/ # 29 R modules
| +-- idea-dashboard/ # React/TS + Vite + Recharts + D3 (:5175)
|
+-- execution/ # Execution infrastructure
| +-- orderbook/ # L2 book, Alpaca/Binance feeds, BookManager, FeedMonitor
| +-- routing/smart_router.py # Spread-tier routing (<=50/50-100/>100 bps)
| +-- broker_adapters/ # Alpaca, Binance, Paper, AdapterManager
| +-- order_management/ # TWAP/VWAP/Iceberg engines, AlgoScheduler, OrderBookTracker
| +-- oms/ # FillProcessor, OrderRouter, StateMachine
| +-- audit/ # ComplianceLogger (hash-chain tamper-evident)
| +-- risk/ # VaR, attribution, correlation monitor, FastAPI :8791
|
+-- crates/ # 27 Rust crates
| +-- idea-genome-engine/ # Crossover, mutation, selection, constraint strategies
| +-- monte-carlo-engine/ # GBM, Merton, Heston, Longstaff-Schwartz, VaR
| +-- online-learning/ # FTRL, PA-II, Hedge, Adam, bandits
| +-- rl-exit-optimizer/ # Double DQN, PER, reward shaping
| +-- regime-analytics/ # HMM, transition model, conditional performance
| +-- smart-order-router/ # PoV, dark pool, liquidity aggregator
| +-- microstructure-engine/ # VPIN, OFI, effective spread, regime signals
| +-- orderbook-sim/ # Synthetic orderbook, adversarial testing
| +-- fix-engine/ # FIX 4.2 session, execution reports, order manager
| +-- execution-optimizer/ # Almgren-Chriss trajectory, adaptive urgency
| +-- tick-backtest/ # Tick replay, intraday patterns, bar-from-ticks
| +-- data-pipeline/ # Quality checks, timeseries ops, HDR histogram
| +-- larsa-core/ # Core BH engine (PyO3)
| +-- larsa-wasm/ # BH trajectory + portfolio analytics (WASM)
| +-- portfolio-engine/ # Ledoit-Wolf, HRP, Black-Litterman
| +-- risk-engine/ # VaR/CVaR, Greeks, stress scenarios
| +-- order-flow-engine/ # Order flow prediction, Avellaneda-Stoikov MM
| +-- [10 more crates]
|
+-- cpp/signal-engine/ # C++ signal engine (~16K LOC)
| +-- src/bh_physics/ # BHState, GARCHState, OUDetector, LorentzBoost
| +-- src/indicators/ # KalmanFilter (4 variants), TickIndicators
| +-- src/composite/ # MultiTimeframeSignal (4H override rule)
| +-- src/io/ # ZmqPublisher, InProcessBus, BatchPublisher
| +-- src/quaternion/ # QuatNav
|
+-- native/ # Zig and C ultra-low-latency
| +-- zig/itch/ # ITCH 5.0 decoder (4 GB/s)
| +-- zig/orderbook/ # Lock-free L2 book (~180ns)
| +-- zig/src/compression.zig # Delta+RLE bar compression
| +-- zig/src/tick_processor.zig # SPSC ring buffer, bar aggregator
| +-- zig/src/simd_indicators.zig # Vectorized EMA/RSI/ATR/MACD
| +-- zig/src/order_flow.zig # FootprintBar, VPIN, CumulativeDelta
| +-- orderbook/ # C L3 book (AVX2, individual order IDs)
| +-- matrix/ # C AVX2 matmul (covariance)
| +-- ringbuffer/ # C SPSC ring (180M ops/sec)
|
+-- coordination/ # Elixir/OTP coordination layer (:8781)
| +-- lib/srfm_coordination/ # 11 GenServer modules
|
+-- config/ # Config and risk management
| +-- config_manager.py # Dot-notation, file watcher, subscribers
| +-- instruments_manager.py # 32-instrument universe
| +-- event_calendar_manager.py # FOMC/CPI/NFP/OpEx blackout dates
| +-- risk_config.py # Risk limits, BH-aware position sizing
| +-- instruments.yaml # BH physics calibration per instrument
|
+-- warehouse/ # DuckDB analytics warehouse
| +-- migrations/ # 020 migrations (schema versioning)
| +-- schema/ # Views: IAE analytics, execution quality
| +-- queries/ # Named query files with parameter substitution
| +-- warehouse_manager.py # Migration runner, upsert, analytics shortcuts
|
+-- research/ # Research tooling
| +-- validation/ # CPCV, DSR, causal inference, market efficiency
| +-- portfolio_lab/ # Efficient frontier, factor exposure, attribution
| +-- simulation/ # Agent-based model, microstructure simulator
| +-- onchain_advanced/ # Whale tracker, miner metrics, stablecoin flows
| +-- signal_analytics/ # 105-signal library, IC/ICIR, alpha decay
| +-- walk_forward/ # CPCV + Sobol/Bayesian param opt
|
+-- optimization/ # Parameter optimization
| +-- bayesian_optimizer.py # GP + EI acquisition
| +-- hyperparameter_search.py # NSGA-II with hypervolume
| +-- regime_parameter_optimizer.py # Per-regime Optuna studies
|
+-- ml/ # Machine learning pipeline
| +-- training/cross_validator.py # CPCV + DSR training CV
| +-- nlp_alpha/ # NLP alpha signals
|
+-- julia/src/ # 40 Julia modules (~123K LOC)
+-- r/R/ # 21 R modules (~60K LOC)
+-- bridge/ # On-chain bridge (MVRV, VPIN, Kyle's Lambda)
+-- spacetime/ # Spacetime Arena (BH backtester + web UI)
+-- lib/ # Core Python primitives
| +-- math/ # 59 quantitative modules (numpy/scipy)
| | +-- kalman_filter.py # KF, EKF, UKF, particle, RTS smoother
| | +-- extreme_value_theory.py # GPD/POT, GEV, Hill estimator
| | +-- portfolio_math.py # MVO, BL, HRP, ERC, CVaR LP
| | +-- derivatives_pricing.py # Full BS Greeks, exotic options
| | +-- credit_models.py # Merton, KMV, CDS, CDO, Credit VaR
| | +-- order_book_models.py # OBI, micro-price, Hawkes, spread decomp
| | +-- mean_field_games.py # MFG Nash execution, herding, systemic risk
| | +-- fx_models.py # GK, vanna-volga, SABR FX, carry, momentum
| | +-- crypto_microstructure.py # Funding rate, liquidation cascade, NVT/MVRV
| | +-- commodity_models.py # Gibson-Schwartz, seasonal, calendar spread
| | +-- fixed_income_advanced.py # KRD, OAS, MBS, swaps, TIPS, repo
| | +-- auction_theory.py # FPSBA, Vickrey, treasury, dark pool crossing
| | +-- optimal_stopping.py # LSM, Bayesian stopping, Snell envelope
| | +-- tensor_decomposition.py # CP/Tucker/NTF, tensor regression
| | +-- point_processes.py # Hawkes, Cox, marked, Ogata thinning
| | +-- manifold_learning.py # Isomap, LLE, diffusion maps, t-SNE
| | +-- convex_optimization.py # ADMM, QP, CVaR LP, log-barrier
| | +-- wavelets_advanced.py # DWT, MODWT, denoising, multifractal
| | +-- ergodic_theory.py # Kelly from ergodicity, vol drag
| | +-- [40 more modules] # Copulas, HMM, factors, graph theory, etc.
| +-- ml/ # 22 ML modules (pure numpy, no frameworks)
| | +-- deep_signal_network.py # Dense/LSTM/TCN layers, backprop, Adam
| | +-- graph_neural_network.py # GCN, GAT, GraphSAGE, temporal GNN
| | +-- market_transformer.py # Multi-head attention, GRN
| | +-- gaussian_process.py # 7 kernels, sparse GP FITC
| | +-- variational_autoencoder.py # VAE, Beta-VAE, Conditional VAE
| | +-- normalizing_flows.py # Planar/radial/RealNVP
| | +-- temporal_conv_network.py # Causal dilated conv, WaveNet
| | +-- state_space_model.py # SSM, S4-inspired, HiPPO
| | +-- diffusion_model.py # Denoising diffusion, DDIM sampler
| | +-- mixture_density_network.py # GMM output, conditional density
| | +-- contrastive_learning.py # SimCLR regime representation
| | +-- bayesian_neural_network.py # BNN, MC Dropout, uncertainty
| | +-- [10 more modules] # Ensemble, features, attention, online, etc.
+-- infra/ # Observability, gRPC, event bus
+-- db/ # SQLite schema (16 migrations)
+-- terminal/ # Terminal UI TypeScript components
+-- dashboard/ # React dashboards (risk, signal, on-chain)
+-- docs/ # All deep-dive documentation
+-- scripts/ # Operational scripts (startup/shutdown/emergency)
+-- run_full_analysis.py # Macro + on-chain + alt data + IAE pipeline
+-- docker-compose.yml # 5-service deployment
+-- Makefile # 60+ targets
+-- .github/workflows/ # CI/CD: Python/Rust/Go/TS/Julia
| Service | Command | Port | Flag |
|---|---|---|---|
| Live Trader | python tools/live_trader_alpaca.py |
-- | LIVE |
| Process Supervisor | python scripts/supervisor.py |
:8790 |
INFRA |
| IAE API | cd idea-engine && go run cmd/api/main.go |
:8767 |
API |
| IAE Event Bus | go run cmd/bus/main.go |
:8768 |
MESSAGE BUS |
| IAE Scheduler | go run cmd/scheduler/main.go |
:8769 |
SCHEDULER |
| IAE Webhook | go run cmd/webhook/main.go |
:8770 |
WEBHOOK |
| IAE Metrics | go run cmd/metrics-server/main.go |
:8771 |
METRICS |
| IAE Dashboard | cd idea-engine/idea-dashboard && npm run dev |
:5175 |
UI |
| Coordination Layer | cd coordination && mix run --no-halt |
:8781 |
COORDINATION |
| Research API | cd infra/research-api && go run main.go |
:8766 |
API |
| Spacetime API | python run_api.py |
:8765 |
API |
| Spacetime Web | cd spacetime/web && npm run dev |
:5173 |
UI |
| Research Dashboard | cd research/dashboard && npm run dev |
:5174 |
UI |
| Risk Aggregator | python -m execution.risk.api |
:8791 |
RISK |
| Live Monitor (CLI) | python -m research.live_monitor.cli monitor run |
-- | MONITOR |
python tools/crypto_backtest_mc.py --verbose
python tools/backtest_wave4.py # Wave 4 with ML + Granger
cargo run -p tick-backtest -- sweep --data-dir data/ --sym BTC --n-trials 1000
python -m research.walk_forward.cli wf optimize \
--trades tools/backtest_output/crypto_trades.csv \
--method sobol --n-iter 200
python -m research.regime_lab.cli regime stress \
--trades tools/backtest_output/crypto_trades.csvbash scripts/start_all.sh start # All services
bash scripts/start_all.sh status # Health check
bash scripts/start_all.sh stop
python tools/live_trader_alpaca.py --dry-run --log-level DEBUG
python scripts/daily_startup.py # Full 9-step startup orchestrationpython -m idea_engine.db.migrate
python -m idea_engine.ingestion.pipeline --verbose
cd idea-engine/rust && cargo build --release
cd idea-engine/rust && ./target/release/genome-engine --generations 100 --pop-size 200
cd idea-engine && go run cmd/genome-inspector/main.go list --top 10# Zig components
cd native/zig && zig build -Doptimize=ReleaseFast
cd native/zig && zig test src/simd_indicators.zig
# C components
cd native/matrix && make
cd native/orderbook && make
# Or all at once
make nativecargo test --workspace
cargo build --workspace --release
cargo run -p rl-exit-optimizer -- --train --episodes 10000
cargo run -p genome-inspector -- best --top 5julia julia/src/SystemicRisk.jl
julia julia/src/CryptoDefi.jl
julia idea-engine/stats-service/julia/volatility_surface.jl
julia idea-engine/stats-service/julia/alpha_research.jlRscript r/R/regime_models.R
Rscript r/R/systemic_risk.R
Rscript idea-engine/stats-service/r/volatility_surface.Rpytest tests/ -v
cargo test --workspace
cd idea-engine && go test ./...
cd idea-engine/idea-dashboard && npm test-> Full deep dive with worked example
| Component | Formula | Interpretation |
|---|---|---|
| MinkowskiClassifier | ds^2 = c^2*dt^2 - dx^2 |
TIMELIKE (ds^2>0) = ordered, causal; SPACELIKE = anomalous |
| BH Formation | mass >= BH_FORM (1.92) |
Gravitational well forms; EMA asymptotes to 2.0 |
| Mass Accrual | mass = 0.97*mass + 0.03*min(2, 1+ctl*0.1) |
Consecutive timelike bars build conviction |
| Mass Decay | mass *= BH_DECAY (0.924) |
Noise bars bleed mass away |
| Hawking Monitor | T_H = 1/(8*pi*M) |
Cold well = stable signal; hot well = reduce size |
| Delta Score | tf_score * mass * ATR |
Expected dollar move -> allocation signal |
| OU Overlay | dX = theta*(mu-X)*dt + sigma*dW |
Mean reversion on flat BH; 8% equity |
| Mayer Dampener | scale = min(1, 2*MA200/price) |
Reduces size when price is extended |
| BTC Lead | alt_score *= (1 + btc_active * 0.3) |
BTC activation boosts correlated alts |
| Dynamic CORR | 0.25 base -> 0.60 when 30d pair-corr > 0.60 |
Stress regime portfolio risk reduction |
| Hurst Exponent | H > 0.58 trending, H < 0.42 mean-reverting |
R/S analysis over HURST_WINDOW=100 bars |
| GARCH(1,1) | h_t = omega + alpha*eps^2_{t-1} + beta*h_{t-1} |
Conditional variance, targets GARCH_TARGET_VOL |
| Parameter | Default | IAE Tuned | Effect |
|---|---|---|---|
BH_FORM |
1.92 | -- | Mass threshold for BH activation |
BH_DECAY |
0.924 | -- | Mass bleed rate on noise bars |
BH_COLLAPSE |
0.992 | -- | Collapse multiplier on exit |
CF (per instrument) |
0.001-0.025 | -- | Minkowski speed of light |
CORR |
dynamic | dynamic | Cross-asset correlation (0.25/0.60) |
GARCH_TARGET_VOL |
1.20 | 0.90 | Target annualized volatility |
OU_FRAC |
0.08 | -- | OU mean-reversion allocation |
MIN_HOLD |
4 | 8 | Minimum bars before exit |
BLOCKED_ENTRY_HOURS |
{} | {1,13,14,15,17,18} | UTC hours blocked for entries |
BOOST_HOURS |
{} | {3,9,16,19} | UTC hours with 1.25x size boost |
WINNER_PROTECTION_PCT |
0.001 | 0.005 | Threshold to let winners run |
OU_DISABLED_SYMBOLS |
{} | {AVAX,DOT,LINK} | Momentum symbols, skip OU |
DELTA_MAX_FRAC |
0.40 | -- | Max single-instrument allocation |
MIN_TRADE_FRAC |
0.03 | -- | Minimum equity shift to rebalance |
NAV_OMEGA_SCALE_K |
0.5 | -- | Quaternion angular velocity scale |
NAV_GEO_ENTRY_GATE |
3.0 | -- | Geodesic quality threshold |
HURST_WINDOW |
100 | -- | Bars for R/S Hurst estimation |
BH_MASS_THRESH |
1.92 | -- | Alias for BH_FORM in Rust/C++ |
RL_EXIT_EPSILON |
0.05 | -- | Epsilon-greedy exploration in DQN trainer |
IAE Tuned = parameter updated by IAE analysis of 63,993 backtest trades.
The IAE ingested 63,993 backtest trades (Jan 2024 - Apr 2026) and produced 10 actionable ideas. All 9 high-confidence ideas are now live in tools/live_trader_alpaca.py.
#1 [91%] EXIT RULE: Raise min_hold_bars 4 -> 8
1-bar holds: avg P&L=-169, WR=35.5% (16,939 trades = 26.5% of all trades)
5-12 bar holds: avg P&L=+111, WR=46.4%. Eliminating fast exits is the
single highest-leverage change.
#2 [88%] ENTRY TIMING: Block entries at hours 1, 13, 14, 15, 18 UTC
These hours: avg P&L=-131/trade vs -10 baseline. WR drops to 37%.
Hour 1 UTC worst (-179/trade, 33.2% WR) -- thin Asian/European overlap.
#3 [85%] CROSS-ASSET: BTC as signal only, reduce BTC direct trade
BTC is the worst P&L instrument (-156K) but the lead signal for alts.
Cut BTC cf_scale to 0.5, boost alt allocation 1.4x when BTC-lead fires.
#4 [82%] INSTRUMENT FILTER: Remove GRT + SOL, shrink AVAX/DOT/LINK
5 symbols = -390K combined loss. GRT (37.4% WR), SOL (36.4% WR).
#5 [80%] POSITION SIZING: GARCH target_vol 120% -> 90%
Overtrading in high-vol regimes. Tightening GARCH cuts ~25% of trades.
#6 [78%] EXIT RULE: Winner protection 0.1% -> 0.5%
48+ bar trades avg +610/trade (only 419 trades). Cutting winners too early.
Backtest comparison after applying all 6 ideas:
| Metric | Baseline | After IAE |
|---|---|---|
| Trades | 63,993 | 59,326 (-7%) |
| Win rate | 41.4% | 43.0% (+1.6pp) |
| MC median 12m | ~$678K | $1.72M |
| MC blowup rate | -- | 0% |
-> IAE architecture deep dive -> Genome evolution deep dive
AETERNUS is the scientific validation layer of SRFM — a controlled experiment testing whether BH convergence windows contain learnable structure beyond random noise.
- Control: Synthetic Heston paths (ES/NQ/YM simulated independently, no real structure)
- Experiment: Real ES/NQ/YM hourly data (2023-11-09 to 2026-04-03, 13,652 bars) with LARSA v16 BH physics reconstructed in real time
| Instrument | BH Active | Onsets |
|---|---|---|
| ES (E-mini S&P) | 27.5% of bars | 179 |
| NQ (E-mini Nasdaq) | 17.6% of bars | 132 |
| YM (E-mini Dow) | 13.4% of bars | 118 |
| Convergence (>=2 simultaneous) | 20.0% | — |
| Hypothesis | Control | Experiment | Result |
|---|---|---|---|
| H1 — Lumina accuracy >50% | 50.0% | 50.7% overall / 52.0% at convergence | Supported |
| H2 — Omni-Graph edges at convergence | 0 edges | density 0.624 vs 0.806, p<0.0001 | Confirmed |
| H3 — TensorNet compression (real < synthetic) | error 0.7829 | error 0.0152 (51x lower) | Confirmed |
| H4 — BH-Follower Sharpe higher | 0.234 | -0.009 | Not supported |
H3 (TensorNet): Real correlated instruments compress 51x more efficiently than independent Heston paths. The rank-2 MPS error drops from 0.7829 to 0.0152, confirming that ES/NQ/YM share genuine low-dimensional correlation structure.
H2 (Omni-Graph): The Granger causality network is significantly less dense during BH convergence (0.624) than during calm periods (0.806), p<0.0001. Interpretation: convergence events mark periods where instruments decouple from the common macro driver — internal structure forms while cross-asset Granger causality drops.
H1 (Lumina): 52.0% accuracy during convergence vs 50.4% calm. SRFM convergence windows are periods of slightly reduced entropy in next-bar direction — the physics engine identifies moments where returns are marginally more predictable.
BH Direction Alignment (TensorNet): The BH engine and linear algebra (dominant eigenvector of rolling correlation) agree on market direction 67.2% of the time vs 50% random baseline.
python run_aeternus_experiment.py # synthetic control
python run_aeternus_real.py # real SRFM experiment-> Full AETERNUS overview -> TensorNet deep dive -> Omni-Graph deep dive -> Lumina deep dive -> Hyper-Agent deep dive
Key findings (2021-2026, 19 crypto pairs):
- LARSA v1 (ES futures): +274% over backtest window
- 2024 standalone: +26%, driven by BTC and SOL regime
- Full period CAGR: -11% (crypto bear market dominated)
- Monte Carlo (10,000 paths): Median outcome captures distribution of sequential trade ordering; blowup rate: 0% after IAE tuning
- Wave 4 additions: EventCalendarFilter + Granger lead + ML signal show further improvement in OOS Sharpe
The backtest engine runs identical BH physics to live trading -- GARCH vol scaling, OU overlay, Mayer dampening -- no lookahead, no future data.
-> Wave 4 backtest deep dive -> Monte Carlo engine deep dive
| Component | Operation | Latency |
|---|---|---|
| Zig L2 book | Best bid/ask read | ~15ns |
| C SPSC ring buffer | Push + pop round trip | ~5.5ns |
| ITCH 5.0 decoder | Full message parse | ~40ns |
| Zig L2 book | Add/cancel | ~180-190ns |
| RL exit policy | Q-table state lookup | ~100ns |
| C L3 book | VWAP walk (21 levels) | ~850ns |
| SIMD matmul (C) | 21x21 double matrix | ~2.1us |
| C++ KalmanFilter1D | Single update step | ~50ns |
| C++ MultiTimeframe | 3-timeframe aggregate | ~200ns |
| Python function call | Overhead | ~50-100ns |
| SQLite WAL read | Single row | ~10-50us |
| Rust Monte Carlo | 10K GBM paths (252 steps) | ~8ms |