Gateway poll-to-stream adapters: - broker_gateway: StreamAccountState (3s), StreamSessionStatus (5s) - data_acquisition: StreamDownloadStatus (5s) - risk: StreamCircuitBreakerStatus (2s), StreamRiskMetrics (3s) - ml: StreamModelStatus (5s) - trading: StreamPortfolioSummary (3s), StreamOrderBook (1s) - trading_agent: StreamAgentStatus (3s) Monitoring handler real implementations: - stream_system_status: fan-out health checks - stream_metrics: Prometheus query loop - stream_alerts: empty placeholder (no alertmanager yet) Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
api_gateway
API Gateway service with 6-layer authentication, RBAC, rate limiting, and gRPC proxy routing.
Key Types
ApiGatewayService-- main service implementationRoleBasedAccessControl-- RBAC authorizationRateLimiter-- 3-tier rate limiting (auth/trading/compute)CircuitBreaker-- upstream service protection
Configuration
JWT_SECRET-- JWT signing secret (min 32 chars)UPSTREAM_TRADING_URL-- trading service gRPC endpointUPSTREAM_ML_URL-- ML service gRPC endpoint
Features
mfa(default) -- multi-factor authentication support- Build without:
cargo check -p api_gateway --no-default-features --features minimal