Struct SlotBuffer 

pub struct SlotBuffer { /* private fields */ }

Slot 缓冲区，用于有序模式下缓存同一 slot 的事件

Implementations

impl SlotBuffer

pub fn new() -> Self

pub fn push(&mut self, slot: u64, tx_index: u64, event: DexEvent)

添加事件到缓冲区

pub fn flush_before(&mut self, current_slot: u64) -> Vec<DexEvent>

输出所有小于 current_slot 的事件

pub fn flush_all(&mut self) -> Vec<DexEvent>

超时强制输出所有缓冲事件

pub fn should_timeout(&self, timeout_ms: u64) -> bool

检查是否超时

pub fn push_streaming( &mut self, slot: u64, tx_index: u64, event: DexEvent, ) -> Vec<DexEvent>

Streaming release: add event and return releasable continuous sequence NOTE: This mode assumes tx_index is continuous (0,1,2,3…) For filtered event streams where tx_index may not be continuous, use MicroBatch mode instead

pub fn flush_streaming_timeout(&mut self) -> Vec<DexEvent>

流式模式超时释放

Trait Implementations

impl Default for SlotBuffer

fn default() -> SlotBuffer

Returns the “default value” for a type.