Module shredstream 

ShredStream 模块 - Jito ShredStream 超低延迟交易订阅

提供从 Jito ShredStream 直接订阅 Solana Entry 数据的能力， 相比 gRPC 订阅具有更低的延迟（约 50-100ms 优势）。

使用示例

use sol_parser_sdk::shredstream::{ShredStreamClient, ShredStreamConfig};
use sol_parser_sdk::DexEvent;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = ShredStreamClient::new("http://localhost:10800").await?;

    // 订阅并获取事件队列
    let queue = client.subscribe().await?;

    // 消费事件
    loop {
        if let Some(event) = queue.pop() {
            println!("Received: {:?}", event);
        } else {
            std::hint::spin_loop();
        }
    }
}

限制说明

ShredStream 相比 gRPC 订阅有以下限制：

• 仅 static_account_keys()，使用 ALT 的交易会有错误账户
• 无 Inner Instructions，无法解析 CPI 调用
• 无 block_time，恒为 0
• tx_index 是 entry 内索引而非 slot 内索引

Re-exports

pub use client::ShredStreamClient;

pub use config::ShredStreamConfig;

Modules

client

ShredStream 客户端

config

ShredStream 配置

proto

ShredStream protobuf 定义