solana-stream-sdk 3.0.0

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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

//! # 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 block_marker;
pub mod entries;
pub mod error;
#[cfg(feature = "udp")]
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 block_marker::{
    classify_block_marker, decode_block_component, BlockComponentPayload, BlockMarkerKind,
};
pub use entries::decode_entries;
pub use error::SolanaStreamError;
// `BlockComponentPayload::BlockMarker` exposes `solana_entry` types such as
// `VersionedBlockMarker`; re-export the crate so they need no extra dependency.
pub use solana_entry;
pub use solana_entry::entry::Entry;
pub use solana_transaction::versioned::VersionedTransaction;
// Re-export shredstream client
pub use shredstream::ShredstreamClient;
// Re-export UDP receiver
#[cfg(feature = "udp")]
pub use shreds_udp::{
    deshred_shreds_to_component, 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::cuckoo::{
    CompressedAccountFilterSet as GeyserCompressedAccountFilterSet,
    CuckooBuildError as GeyserCuckooBuildError, CuckooFilter as GeyserCuckooFilter,
    TableFullError as GeyserCuckooTableFullError,
    YellowstoneHasherBuilder as GeyserYellowstoneHasherBuilder,
};
pub use yellowstone_grpc_proto::{
    geyser::{
        subscribe_update::UpdateOneof as GeyserUpdateOneof,
        CuckooFilter as GeyserCuckooFilterMessage,
        CuckooHashAlgorithm as GeyserCuckooHashAlgorithm, SlotStatus as GeyserSlotStatus,
        SubscribeDeshredRequest as GeyserSubscribeDeshredRequest,
        SubscribeRequestFilterDeshredTransactions as GeyserSubscribeRequestFilterDeshredTransactions,
        SubscribeUpdateBlock as GeyserUpdateBlock,
        SubscribeUpdateBlockFooter as GeyserUpdateBlockFooter,
        SubscribeUpdateBlockMeta as GeyserUpdateBlockMeta,
        SubscribeUpdateDeshred as GeyserSubscribeUpdateDeshred,
        SubscribeUpdateDeshredTransaction as GeyserSubscribeUpdateDeshredTransaction,
        SubscribeUpdateDeshredTransactionInfo as GeyserSubscribeUpdateDeshredTransactionInfo,
        SubscribeUpdateDeshredUpdateParent as GeyserSubscribeUpdateDeshredUpdateParent,
        SubscribeUpdateSlot as GeyserUpdateSlot,
        TokenAccountExpansionControlFlag as GeyserTokenAccountExpansionControlFlag,
    },
    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,
        SubscribeRequestFilterBlockFooter as GeyserSubscribeRequestFilterBlockFooter,
        SubscribeRequestFilterBlocks as GeyserSubscribeRequestFilterBlocks,
        SubscribeRequestFilterBlocksMeta as GeyserSubscribeRequestFilterBlocksMeta,
        SubscribeRequestFilterEntry as GeyserSubscribeRequestFilterEntry,
        SubscribeRequestFilterSlots as GeyserSubscribeRequestFilterSlots,
        SubscribeRequestFilterTransactions as GeyserSubscribeRequestFilterTransactions,
        SubscribeRequestPing as GeyserSubscribeRequestPing,
        SubscribeUpdate as GeyserSubscribeUpdate,
        SubscribeUpdateAccountInfo as GeyserSubscribeUpdateAccountInfo,
        SubscribeUpdateEntry as GeyserSubscribeUpdateEntry,
        SubscribeUpdateEntryUpdateParent as GeyserUpdateEntryUpdateParent,
        SubscribeUpdateTransactionInfo as GeyserSubscribeUpdateTransactionInfo,
    },
    prost::Message as GeyserMessage,
};

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