github.com/0xfnzero/solana-streamer @v1.5.16

<h1>🌊 Solana Streamer</h1>
<h3><em>Real-time event streaming from Solana DEX trading programs.</em></h3>







<strong>A lightweight Rust streaming facade over sol-parser-sdk, with low-latency subscriptions and a stable bot-facing API.</strong>







<a href="https://crates.io/crates/solana-streamer-sdk">
    <img src="https://img.shields.io/crates/v/solana-streamer-sdk.svg" alt="Crates.io">
</a>
<a href="https://docs.rs/solana-streamer-sdk">
    <img src="https://docs.rs/solana-streamer-sdk/badge.svg" alt="Documentation">
</a>
<a href="https://github.com/0xfnzero/solana-streamer/blob/main/LICENSE">
    <img src="https://img.shields.io/badge/license-MIT-blue.svg" alt="License">
</a>
<a href="https://github.com/0xfnzero/solana-streamer">
    <img src="https://img.shields.io/github/stars/0xfnzero/solana-streamer?style=social" alt="GitHub stars">
</a>
<a href="https://github.com/0xfnzero/solana-streamer/network">
    <img src="https://img.shields.io/github/forks/0xfnzero/solana-streamer?style=social" alt="GitHub forks">
</a>







<img src="https://img.shields.io/badge/Rust-000000?style=for-the-badge&logo=rust&logoColor=white" alt="Rust">
<img src="https://img.shields.io/badge/Solana-9945FF?style=for-the-badge&logo=solana&logoColor=white" alt="Solana">
<img src="https://img.shields.io/badge/Streaming-FF6B6B?style=for-the-badge&logo=livestream&logoColor=white" alt="Real-time Streaming">
<img src="https://img.shields.io/badge/gRPC-4285F4?style=for-the-badge&logo=grpc&logoColor=white" alt="gRPC">







<a href="https://github.com/0xfnzero/solana-streamer/raw/v1.5.16/README_CN.md">中文</a> | 
<a href="https://github.com/0xfnzero/solana-streamer/raw/v1.5.16/README.md">English</a> | 
<a href="https://fnzero.dev/">Website</a> |
<a href="https://t.me/fnzero_group">Telegram</a> |
<a href="https://discord.gg/vuazbGkqQE">Discord</a>

☕ Support This Project

This SDK is completely free and open source. However, maintaining and continuously updating it requires significant AI computing resources and token consumption. If this SDK helps with your development, consider making a monthly SOL donation — any amount is appreciated and helps keep this project alive!

Donation Wallet: 6oW7AXz1yRb57pYSxysuXnMs2aR1ha5rzGzReZ1MjPV8

---

Table of Contents

• 🚀 Project Features
• ⚡ Installation
• 🔄 Migration Guide
• ⚙️ Configuration System
• 📚 Usage Examples
• 🔧 Supported Protocols
• 🌐 Event Streaming Services
• 🏗️ Architecture Features
• 📁 Project Structure
• ⚡ Performance Considerations
• 📄 License
• 📞 Contact
• ⚠️ Important Notes

What This SDK Is For

solana-streamer-sdk is a Rust event streaming layer for Solana bots, indexers, copy-trading systems, sniper bots, and DEX monitoring tools. It provides a stable API over Yellowstone gRPC, ShredStream, RPC transaction parsing, and the underlying sol-parser-sdk parser core.

Area	Coverage
Input sources	Yellowstone gRPC, Jito ShredStream, fetched RPC transactions, encoded transaction data
DEX protocols	PumpFun, PumpSwap, Pump Fees, Raydium LaunchLab, Raydium CPMM, Raydium CLMM, Raydium AMM V4, Meteora DAMM v2, Meteora DLMM, Meteora DBC, Orca Whirlpool
Use cases	Real-time DEX event streaming, token launch monitoring, copy trading, account-state subscriptions, bot signal pipelines
Parser backend	sol-parser-sdk with default Borsh parsing and optional zero-copy backend for latency-sensitive workloads

🚀 Project Features

Core Capabilities

• Real-time Event Streaming: Subscribe to live trading events from multiple Solana DEX protocols
• SDK-backed Parser Core: Transaction, RPC, account, and ShredStream parsing are backed by sol-parser-sdk
• Yellowstone gRPC Support: High-performance event subscription using Yellowstone gRPC
• ShredStream Support: Alternative event streaming using ShredStream protocol; ALT-loaded accounts are parsed best-effort with default account placeholders
• Unified Event Interface: Consistent event handling across all supported protocols

Multi-Protocol Support

• PumpFun: Meme coin trading platform events
• Pump Fees: Pump fee-sharing configuration events
• PumpSwap: PumpFun's swap protocol events
• Raydium LaunchLab: Token launch platform events; Protocol::Bonk and Protocol::RaydiumLaunchpad remain compatible aliases
• Raydium CPMM: Raydium's Concentrated Pool Market Maker events
• Raydium CLMM: Raydium's Concentrated Liquidity Market Maker events
• Raydium AMM V4: Raydium's Automated Market Maker V4 events
• Meteora DAMM v2: Meteora DAMM v2 swap and liquidity events
• Orca Whirlpool: Orca Whirlpool swap and liquidity events
• Meteora Pools: Meteora Pools swap, liquidity, bootstrap, and fee events
• Meteora DBC: Meteora Dynamic Bonding Curve log-side swap, initialize-pool, and curve-complete events
• Meteora DLMM: Meteora DLMM swap, liquidity, pool, bin-array, and fee events

Advanced Features

• Event Parsing System: Automatic parsing and categorization of protocol-specific events
• Account State Monitoring: Real-time monitoring of protocol account states and configuration changes
• Transaction & Account Event Filtering: Separate filtering for transaction events and account state changes
• Dynamic Subscription Management: Runtime filter updates without reconnection, enabling adaptive monitoring strategies
• Multi-Filter Support: Support for multiple transaction and account filters in a single subscription
• Advanced Account Filtering: Memcmp filters for precise account data matching and monitoring
• Token2022 Support: Enhanced support for SPL Token 2022 with extended state parsing
• RPC Transaction Parsing: Parse already-fetched RPC transactions or fetch by signature through streamer-compatible helpers
• Advanced SDK Interop: Access the raw sol-parser-sdk crate through parser_sdk or sdk_bridge::raw

Performance & Optimization

• High Performance: Optimized for low-latency event processing
• Batch Processing Optimization: Batch processing events to reduce callback overhead
• Performance Monitoring: Built-in performance metrics monitoring, including event processing speed
• Memory Optimization: Object pooling and caching mechanisms to reduce memory allocations
• Flexible Configuration System: Support for custom batch sizes, backpressure strategies, channel sizes
• Preset Configurations: High-throughput and low-latency preset configurations optimized for different use cases
• Backpressure Handling: Supports blocking and dropping backpressure strategies
• Runtime Configuration Updates: Dynamic configuration parameter updates at runtime
• Graceful Shutdown: Support for programmatic stop() method for clean shutdown

⚡ Installation

Direct Clone

Clone this project to your project directory:

cd your_project_root_directory
git clone https://github.com/0xfnzero/solana-streamer

Add the dependency to your Cargo.toml:

# Add to your Cargo.toml
solana-streamer-sdk = { path = "./solana-streamer", version = "1.5.16" }

Use crates.io

# Add to your Cargo.toml
solana-streamer-sdk = "1.5.16"

Parser backend features:

# Default: sol-parser-sdk parse-borsh backend
solana-streamer-sdk = "1.5.16"

# Zero-copy parser backend for latency-sensitive bots
solana-streamer-sdk = { version = "1.5.16", default-features = false, features = ["sdk-parse-zero-copy"] }

If both sdk-parse-borsh and sdk-parse-zero-copy are enabled, sol-parser-sdk 0.5.15+ uses the zero-copy backend.

🔄 Migration Guide

Upgrading to v1.5.16

Version 1.5.16 fixes StreamingOrdered delivery for transactions that parse into multiple events. Events from the same (slot, tx_index) are admitted as a group, the streaming watermark advances once per transaction, and stable sorting preserves parser order for equal transaction indexes. It also pins yellowstone-grpc-proto to the 12.4.x API used by sol-parser-sdk 0.5.15 so CI and clean installs do not resolve an incompatible newer proto crate.

Upgrading to v1.5.15

Version 1.5.15 tracks sol-parser-sdk 0.5.15 at GitHub rev 36ec202. Pump.fun create_v2 now distinguishes 16-account SOL-sentinel creates from 19/20-account quote-pool creates, models Yellowstone gRPC loaded writable/readonly addresses correctly, rejects PumpFun program-account fillers as quote mints, and keeps ShredStream from guessing ALT-loaded quote mints when the static transaction keys do not contain them. gRPC/RPC inner instruction parsing now handles guarded 8-byte ordinary CPI instructions for all SDK-supported DEX parsers, so PumpSwap create_pool reads is_cashback_coin from instruction args before merging with log-derived CreatePoolEvent output. ShredStream remains outer-instruction only, but its outer discriminator gate is shared with the SDK parser and no longer diverges for supported DEX protocols.

Upgrading to v1.5.14

Version 1.5.14 uses sol-parser-sdk 0.5.14 from crates.io. Pump.fun canonical create events now expose quote_mint, quote_vault, and quote_token_program for create_v2 quote pools, including USDC pools, across gRPC/RPC parser bridge and ShredStream-backed SDK output.

Upgrading to v1.5.13

Version 1.5.13 uses sol-parser-sdk 0.5.13 from crates.io. Pump.fun gRPC and ShredStream create/trade outputs now preserve real WSOL quote mints (So11111111111111111111111111111111111111112). The Solscan SOL sentinel (So11111111111111111111111111111111111111111) is used only when legacy data omits a quote mint.

Upgrading to v1.5.11

Version 1.5.11 uses sol-parser-sdk 0.5.11 from crates.io. PumpSwap PumpSwapCreatePoolEvent now carries is_cashback_coin when it is available from the create_pool instruction args, including ShredStream outer-instruction parsing. Log-only CreatePoolEvent payloads still default this field to false because the on-chain log event IDL does not carry it. AccountPumpSwapPool remains the authoritative account-state source for the pool flag.

Upgrading to v1.5.10

Version 1.5.10 uses sol-parser-sdk 0.5.10 from crates.io. PumpSwap CreatePoolEvent now matches the on-chain IDL: it exposes is_mayhem_mode but does not expose is_cashback_coin. To read the cashback flag, subscribe to AccountPumpSwapPool and use PumpSwapPoolAccountEvent.pool.is_cashback_coin. The PumpSwap CreatePool log payload length check now includes the final is_mayhem_mode byte.

Upgrading to v1.5.9

Version 1.5.9 uses sol-parser-sdk 0.5.9 from crates.io. It inherits the Yellowstone gRPC stop lifecycle fix: stop() now signals, aborts, and awaits the active subscription task, subscription lifecycle transitions are serialized, and gRPC stream errors are labeled as Grpc Stream error for easier log separation from ShredStream.

Upgrading to v1.5.8

Version 1.5.8 uses sol-parser-sdk 0.5.8 from crates.io. It inherits the Pump.fun ShredStream filter-family semantics from the parser SDK: PumpFunBuy covers buy, buy_v2, buy_exact_sol_in, and buy_exact_quote_in_v2; PumpFunSell covers sell and sell_v2; and PumpFunTrade covers all buy/sell instructions while the parser can emit unified trade events when only the generic trade filter is requested.

Upgrading to v1.5.5

Version 1.5.5 uses sol-parser-sdk 0.5.5 from crates.io. The SDK now exposes Raydium LaunchLab as RaydiumLaunchlab*; streamer keeps the existing Bonk* event structs and Protocol::Bonk / Protocol::RaydiumLaunchpad aliases for source compatibility, while routing parser calls and upstream gRPC event filters to the new LaunchLab SDK variants. This release also syncs the CLMM/CPMM/Orca account bridges, Meteora DAMM v2 initialize-pool events, Meteora DBC events, and parser warmup on client creation.

Upgrading to v1.5.4

Version 1.5.4 uses sol-parser-sdk 0.5.4 from crates.io. Pump.fun create and create_v2 are delivered as one canonical PumpFunCreateTokenEvent; subscribing to either PumpFunCreateToken or PumpFunCreateV2Token receives the same complete create-family data. This prevents duplicate new-mint callbacks from gRPC log + instruction parsing while preserving create_v2 account fields on the canonical create event.

Upgrading to v1.5.3

Version 1.5.3 uses sol-parser-sdk 0.5.3 from crates.io. It preserves real Pump.fun v2 ix_name values through the streamer bridge, improves ShredStream Pump.fun v2 best-effort parsing for short account lists, and treats PumpFunBuy and PumpFunBuyExactSolIn subscriptions as compatible buy-family filters. ShredStream still uses the direct entry-reading path with automatic reconnect; callbacks should remain non-blocking and tx_index remains entry-local best-effort.

Upgrading to v1.5.2

Version 1.5.2 uses sol-parser-sdk 0.5.2 from crates.io. ShredStream delivery uses the SDK parser on a direct entry-reading path with automatic reconnect, avoiding the extra queue consumer task while keeping parser event buffers reused. ShredStream tx_index is entry-local best-effort, not the Yellowstone slot-level transaction index. User callbacks on the direct path run on the read task and should avoid blocking work.

Upgrading to v1.5.1

Version 1.5.1 uses sol-parser-sdk 0.5.1 from crates.io. It improves ShredStream ALT handling by parsing outer instructions best-effort with default placeholders for ALT-loaded accounts, adds dropped-event queue observability, and keeps CPI/inner-only events documented as a ShredStream