Go Backend · Next.js 14 · Apache Kafka · Multi-Broker Copy Trading
TradeNova is a low-latency, multi-broker copy trading platform that mirrors trades from a master/leader account to up to 20+ follower accounts in parallel, with an end-to-end execution SLA of under 3 seconds. It supports 7 major futures brokers and provides a real-time dashboard for monitoring all accounts simultaneously.
Traders running multiple prop firm or personal accounts need every follower account to execute the same trade as the leader account — fast, reliably, and at scale. Traditional manual duplication is impossible at the speed required. TradeNova automates the entire flow from signal detection to execution confirmation across all accounts.
| Layer | Component |
|---|---|
| 1 | Next.js 14 Frontend (SSR + client components, WebSocket) |
| 2 | Go WS Gateway (:8081) + Go REST API (:8080) |
| 3 | Apache Kafka Cluster (KRaft, 6 topics) |
| 4 | Go Microservices (Signal Ingestion, Fan-Out, Executor, Position Tracker) |
| 5 | 7 Broker Adapters (persistent auth, circuit breakers) |
| 6 | PostgreSQL, Redis, Prometheus + Grafana |
| Topic | Partitions | Key | Purpose |
|---|---|---|---|
| trade.signals | 3 | symbol | Master order events |
| trade.executions | 10 | account_id | Fill confirmations |
| positions.updates | 10 | account_id | Position & P&L |
| account.status | 20 | account_id | Broker health |
| order.errors | 5 | account_id | Execution failures |
| system.heartbeat | 1 | — | Service health |
| Signal detection | <50ms |
| Normalization + Kafka publish | <25ms |
| Fan-out router + goroutine dispatch | <10ms |
| Broker API execution (P95) | <800ms |
| Result collection + Kafka publish | <50ms |
| Total end-to-end (typical) | <1 second |
| Total end-to-end (worst case SLA) | <3 seconds |
| Broker | Protocol | Connection | Key Notes |
|---|---|---|---|
| Tradovate | REST + WebSocket | Persistent WSS | OAuth2 token, fill subscription via WS |
| Rithmic | R|API+ (proprietary) | TCP binary (C SDK) | Most complex — CGO wrapper |
| DxFeed | dxLink | WebSocket | Order chain event subscription |
| NinjaTrader | ATI | TCP socket | SuperDOM AT Interface, text commands |
| ProjectX | REST + SignalR | HTTP + WSS | SignalR fills · HTTP poll fallback · pgcrypto account sync |
| Quantower | FIX 4.2/4.4 | FIX session | Standard FIX, session management |
| Sierra Chart | SCID / DLL | DLL/Extension API | Trading extension interface |
Every adapter implements BrokerAdapter Go interface: Connect(), PlaceOrder(), Subscribe(), Disconnect()
/tradenova-backend ├── cmd/ │ ├── ingestion/ # Signal ingestion service :9100 │ ├── router/ # Fan-out order router :9101 │ ├── executor/ # Broker executor worker pool │ ├── gateway/ # REST :8080 · WebSocket :8081 │ └── tracker/ # Position & P&L tracker :9103 ├── internal/ │ ├── kafka/ # Producer/Consumer wrappers │ ├── brokers/ │ │ ├── tradovate/ │ │ ├── rithmic/ │ │ ├── ninjatrader/ │ │ ├── projectx/ # SignalR + HTTP poll fallback │ │ ├── dxfeed/ │ │ ├── quantower/ │ │ └── sierrachart/ │ ├── api/ │ │ ├── handlers/ # auth, accounts, orders, dashboard │ │ └── middleware/ # JWTProtected (jwt/v5, NOT jwtware) │ ├── models/ # TradeSignal, Execution, Position │ ├── router/ # Fan-out logic (fanout.go) │ ├── scaling/ # Scaling rules engine │ └── circuit/ # gobreaker per broker ├── pkg/ │ └── ws/ # WebSocket hub (thread-safe) └── docker-compose.yml
/tradenova-frontend ├── app/ │ ├── layout.tsx │ ├── (auth)/login/page.tsx # NextAuth credentials signIn │ ├── (auth)/signup/page.tsx # POST /api/auth/signup │ ├── accounts/page.tsx # flat list · crown icons │ ├── dashboard/page.tsx # SERVER Component │ └── api/ │ ├── auth/[...nextauth]/route.ts # calls Go /auth/login │ ├── auth/signup/route.ts # proxies to Go /auth/register │ ├── accounts/route.ts # Bearer token → Go /accounts │ ├── orders/route.ts │ └── projectx/auth/route.ts # server-side PX account sync ├── components/ │ └── accounts/AddConnectionModal.tsx # ProjectX sync flow ├── hooks/ │ ├── useTradeStream.ts # routes WS messages to stores │ └── usePositions.ts ├── store/ │ ├── tradeStore.ts # Zustand · 500 exec ring buffer │ ├── positionStore.ts # Zustand · position map │ └── accountStore.ts ├── lib/ │ ├── ws.ts # WS singleton · exp backoff reconnect │ ├── types.ts # Account, Execution, Position, WSMessage │ └── go-auth.ts # goAuthHeader() reads goToken from session └── middleware.ts