solana-stream-sdk 1.0.1

Rust SDK for Solana streaming data
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

//! # Solana Stream SDK
//!
//! A Rust SDK for streaming Solana data using Shreds and gRPC.
//! This crate provides convenient wrappers around the Shreds protobuf definitions
//! for easier integration with Solana streaming services.

pub mod error;
pub mod shreds_udp;
pub mod shredstream;
pub mod txn;
pub use yellowstone_grpc_client;
pub use yellowstone_grpc_proto;

// Internal protobuf modules
pub mod shared {
    tonic::include_proto!("shared");
}

pub mod shredstream_proto {
    tonic::include_proto!("shredstream");
}

// Re-export commonly used types for convenience
// Re-export error types
pub use error::SolanaStreamError;
// Re-export shredstream client
pub use shredstream::ShredstreamClient;
// Re-export UDP receiver
pub use shreds_udp::{deshred_shreds_to_entries, UdpDatagram, UdpShredReceiver};

// Shredstream protobuf exports
pub use shredstream_proto::{
    CommitmentLevel, SubscribeEntriesRequest, SubscribeRequestFilterAccounts,
    SubscribeRequestFilterAccountsFilter, SubscribeRequestFilterAccountsFilterLamports,
    SubscribeRequestFilterAccountsFilterMemcmp, SubscribeRequestFilterSlots,
    SubscribeRequestFilterTransactions,
};

pub use yellowstone_grpc_client::{GeyserGrpcClient, GeyserGrpcClientError, Interceptor};

// Geyser protobuf exports with clear prefixes
pub use yellowstone_grpc_proto::{
    geyser::{
        subscribe_update::UpdateOneof as GeyserUpdateOneof, SlotStatus as GeyserSlotStatus,
        SubscribeUpdateBlock as GeyserUpdateBlock,
        SubscribeUpdateBlockMeta as GeyserUpdateBlockMeta, SubscribeUpdateSlot as GeyserUpdateSlot,
    },
    plugin::{
        filter::message::FilteredUpdate as GeyserFilteredUpdate,
        message::{
            MessageAccount as GeyserMessageAccount, MessageBlock as GeyserMessageBlock,
            MessageBlockMeta as GeyserMessageBlockMeta, MessageEntry as GeyserMessageEntry,
            MessageSlot as GeyserMessageSlot, MessageTransaction as GeyserMessageTransaction,
        },
    },
    prelude::{
        geyser_client::GeyserClient as GeyserGrpcInnerClient,
        subscribe_request_filter_accounts_filter::Filter as GeyserAccountsFilterEnum,
        subscribe_request_filter_accounts_filter_lamports::Cmp as GeyserLamportsCmp,
        subscribe_request_filter_accounts_filter_memcmp::Data as GeyserMemcmpData,
        CommitmentLevel as GeyserCommitmentLevel, SubscribeRequest as GeyserSubscribeRequest,
        SubscribeRequestAccountsDataSlice as GeyserAccountsDataSlice,
        SubscribeRequestFilterAccounts as GeyserSubscribeRequestFilterAccounts,
        SubscribeRequestFilterAccountsFilter as GeyserSubscribeRequestFilterAccountsFilter,
        SubscribeRequestFilterAccountsFilterLamports as GeyserSubscribeRequestFilterAccountsFilterLamports,
        SubscribeRequestFilterAccountsFilterMemcmp as GeyserSubscribeRequestFilterAccountsFilterMemcmp,
        SubscribeRequestFilterBlocks as GeyserSubscribeRequestFilterBlocks,
        SubscribeRequestFilterBlocksMeta as GeyserSubscribeRequestFilterBlocksMeta,
        SubscribeRequestFilterEntry as GeyserSubscribeRequestFilterEntry,
        SubscribeRequestFilterSlots as GeyserSubscribeRequestFilterSlots,
        SubscribeRequestFilterTransactions as GeyserSubscribeRequestFilterTransactions,
        SubscribeUpdate as GeyserSubscribeUpdate,
        SubscribeUpdateAccountInfo as GeyserSubscribeUpdateAccountInfo,
        SubscribeUpdateEntry as GeyserSubscribeUpdateEntry,
        SubscribeUpdateTransactionInfo as GeyserSubscribeUpdateTransactionInfo,
    },
    prost::Message as GeyserMessage,
};

pub type Result<T> = std::result::Result<T, SolanaStreamError>;