Trait FileLogPuller 

pub trait FileLogPuller<E> {
    // Required methods
    fn list_peers(&self) -> Vec<Uuid> ;
    fn read_entries(
        &self,
        peer: Uuid,
        from: u64,
    ) -> Result<Vec<(u64, DecodedEntry<E>)>, SyncError>;
}

Synchronous reader over the segment directories — one per origin. Sync because it decodes local files; an adapter pairs it with a watch/poll loop to present it as an async LogSource.

Required Methods

fn list_peers(&self) -> Vec<Uuid>

Origins present in this store.

fn read_entries( &self, peer: Uuid, from: u64, ) -> Result<Vec<(u64, DecodedEntry<E>)>, SyncError>

Bounded batch of peer’s entries at or after from; empty when drained. The synchronous counterpart to LogSource::read_since.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors