Struct SimpleBlockAccumulator 

pub struct SimpleBlockAccumulator<E> { /* private fields */ }

An in-memory store for blocks being reconstructed.

It maintains active blocks (currently being reconstructed) and frozen blocks (fully reconstructed).

Trait Implementations

impl<E> BlockAccumulator for SimpleBlockAccumulator<E>

type EventT = E

The type of events that this cumulator can handle. This is typically the same as the EventT associated type of the GeyserEventAdapter used by the BlockStream.

type EventStore = SimpleBlockStore<E>

The type of storage used to hold the events for a block. This is typically a Vec<EventT>, but can be any type that can hold the events for a block.

fn add_event(&mut self, event: E, slot: Slot, ev_info: &GeyserEventInfo)

Inserts a new event into the block accumulator for the given slot, under the given Bucket.

fn freeze_block(&mut self, frozen_block_info: FrozenBlock)

Marks a block as frozen, indicating that it has been fully reconstructed and is ready for processing.

fn finish_block(&mut self, slot: Slot) -> Option<Block<SimpleBlockStore<E>>>

Finishes a block and returns it, if it exists. This is typically called when the block has been fully processed and is ready to be consumed.

fn prune_block(&mut self, slot: Slot)

Prunes a block from the accumulator, removing all associated events and data for the given slot. This is typically called when a block is no longer needed, such as when it has been finalized or when a fork has been detected.

impl<E> Default for SimpleBlockAccumulator<E>

fn default() -> Self

Returns the “default value” for a type.