What’s inside
| Field group | Examples |
|---|---|
| Identity | chainId, txHash, logIndex, blockNumber, timestamp |
| Parties | makerAddress, takerAddress, router, dex |
| Economics | tokenIn, tokenOut, amountIn, amountOut, priceUsd, sizeUsd |
| Context | poolAddress, feeTier, slippageBps, gasUsedUsd |
| Classification | side (buy/sell), type (open/close/add/remove), isFirstBuy |
Coverage & freshness
- Chains: every chain in Supported Chains.
- DEXes: Uniswap v2/v3/v4, Raydium, Meteora, PancakeSwap, Aerodrome, Jupiter-routed, + more — see per-chain support tables.
- Latency: block-level — Kafka delivers within 1–2 s of finalization, REST within 5–10 s.
Access
REST
/v2/trade/{chain}, /v2/trade/{chain}/activities, /v2/trade/{chain}/top-traders.GraphQL
Flexible filters: join Trades with Tokens and Wallets.
WebSocket
dex-trade:{chain}_{tokenAddress} (by token) and dex-wallet-trade:{chain}_{walletAddress} (by wallet). SDK: client.stream.subscribeTokenTrade / subscribeWalletTrade.Kafka
{chain}.dex.trades topics per chain, Protobuf-encoded.SDK / CLI
client.trade.list(), chainstream market trades --chain solana --token <addr>.MCP
trades_recent tool for agents (filter by token, wallet or pool).Common use cases
- Render a live trade tape for a token
- Compute realized PnL for a wallet
- Trigger alerts on first-buy or large-trade events
- Feed a trading bot with maker/taker context
- Aggregate to OHLC at custom intervals (or use Candles)
Billing
REST / GraphQL: per-page cost scales withlimit. WebSocket and Kafka charge per delivered message, discounted for high-volume tiers.
Next
Candles (OHLC)
Pre-aggregated price bars if you don’t need tick-level detail.
Smart Money
Trades filtered to high-performing wallet cohorts.