Struct EventStoreWriter 

pub struct EventStoreWriter { /* private fields */ }

This struct is used to archive events to an object store. It allows for appending logs and flushing them to the store in batches. It is designed to work with a specific event signature.

Implementations

impl EventStoreWriter

pub fn new( store: Arc<dyn ObjectStore>, path: Path, batch_size: usize, event: Event, ) -> Result<Self>

pub fn selector(&self) -> B256

pub fn event(&self) -> &Event

pub fn append<'a>( &mut self, logs: impl Iterator<Item = &'a Log>, from_block: u64, to_block: u64, ) -> Result<()>

pub async fn last_block(&self) -> Result<u64>

pub async fn flush(&mut self) -> Result<()>

pub async fn append_and_maybe_flush<'a>( &mut self, logs: impl Iterator<Item = &'a Log>, from_block: u64, to_block: u64, ) -> Result<bool>