solana-streamer-sdk 1.5.16

A low-latency Solana DEX event streaming facade over sol-parser-sdk with Yellowstone gRPC, ShredStream, and RPC parsing helpers.
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

use crate::streaming::event_parser::common::{types::EventType, EventMetadata};
use borsh::BorshDeserialize;
use serde::{Deserialize, Serialize};
use solana_sdk::signature::Signature;

/// Block元数据事件
#[derive(Clone, Debug, Default, PartialEq, Eq, Serialize, Deserialize, BorshDeserialize)]
pub struct BlockMetaEvent {
    #[borsh(skip)]
    pub metadata: EventMetadata,
    pub slot: u64,
    pub block_hash: String,
}

impl BlockMetaEvent {
    pub fn new(slot: u64, block_hash: String, block_time_ms: i64, recv_us: i64) -> Self {
        let metadata = EventMetadata::new(
            Signature::default(),
            slot,
            block_time_ms / 1000,
            block_time_ms,
            crate::streaming::event_parser::common::types::ProtocolType::Common,
            EventType::BlockMeta,
            solana_sdk::pubkey::Pubkey::default(),
            0,
            None,
            recv_us,
            None,
            None, // recent_blockhash not applicable for block meta
        );
        Self { metadata, slot, block_hash }
    }
}