newPairs subscription on SOLANA_MAINNET delivers new DEX pairs as they appear.
Subscribe
wss://streaming.goldrushdata.com/graphql with your API key in the connection parameters.
The protocol field carries the DEX protocol name. Filter client-side to scope to a particular venue.
Patterns
”New pools” tab
Stream the firehose, dedupe bypair_address, drop pools below a liquidity threshold to filter spam, and display chronologically.
Cross-DEX arbitrage discovery
The same base/quote pair can launch on multiple venues within minutes. Group new pools by base/quote token addresses to discover routes for arb.Production considerations
- Reconnect on close or error. Wrap the subscribe call in a function and re-invoke on
error/completewith a 1-2s backoff. - Dedupe by
pair_address. During brief reconnects you may see a recently-emitted pool twice; deduplicate onpair_address. - No backfill on reconnect. The subscription delivers events from the moment it opens. For historical pairs and swaps, use the warehouse
swapsrecipe.
Related
- DEX Swaps warehouse recipe - decoded swaps landed in your warehouse.
- New DEX Pairs Stream reference - full subscription schema.