Expand description
gRPC 模块 - 支持gRPC订阅、事件过滤、账号过滤
这个模块提供了完整的Solana DEX事件gRPC流式处理功能,包括:
- gRPC连接和订阅管理
- 事件类型过滤
- 账户和交易过滤
- 多协议支持(PumpFun, Bonk, Raydium等)
subscribe_builder:构造 YellowstoneSubscribeRequest(DEX 与 mentions 监控共用)transaction_meta:原始Transaction/TransactionStatusMeta工具(转账分析等)
Re-exports§
pub use client::YellowstoneGrpc;pub use geyser_connect::connect_yellowstone_geyser;pub use geyser_connect::GeyserConnectConfig;pub use subscribe_builder::build_subscribe_request;pub use subscribe_builder::build_subscribe_request_with_commitment;pub use subscribe_builder::build_subscribe_transaction_filters_named;pub use transaction_meta::collect_account_keys_bs58;pub use transaction_meta::collect_watch_transfer_counterparty_pairs;pub use transaction_meta::heuristic_sol_counterparties_for_watched_keys;pub use transaction_meta::lamport_balance_deltas;pub use transaction_meta::spl_token_counterparty_by_owner;pub use transaction_meta::token_balance_raw_amount;pub use transaction_meta::try_yellowstone_signature;pub use types::account_filter_memcmp;pub use types::AccountFilter;pub use types::ClientConfig;pub use types::EventType as StreamingEventType;pub use types::EventTypeFilter;pub use types::OrderMode;pub use types::Protocol;pub use types::SlotFilter;pub use types::TransactionFilter;pub use StreamingEventType as EventType;pub use event_parser::*;
Modules§
- buffers
- 事件缓冲区模块 - 用于有序模式下的事件排序和批次处理
- client
- Yellowstone gRPC 客户端 - 超低延迟 DEX 事件订阅
- config
- event_
parser - filter
- geyser_
connect - Yellowstone Geyser gRPC 客户端连接(与
super::client::YellowstoneGrpc共用 tonic / TLS 约定)。 - instruction_
parser - Instruction 解析器 - 完整支持 instruction + inner instruction
- program_
ids - subscribe_
builder - Yellowstone
SubscribeRequest构造(DEX 订阅、钱包 mentions 转账监控等共用)。 - transaction_
meta - Yellowstone
Transaction/TransactionStatusMeta通用工具。 - types