Struct PallasChainReader

pub struct PallasChainReader { /* private fields */ }

PallasChainReader reads blocks with ‘chainsync’ mini-protocol

Implementations

impl PallasChainReader

pub fn new(socket: &Path, network: CardanoNetwork, logger: Logger) -> Self

Creates a new PallasChainReader with the specified socket and network.

Trait Implementations

impl ChainBlockReader for PallasChainReader

fn set_chain_point<'life0, 'life1, 'async_trait>( &'life0 mut self, point: &'life1 RawCardanoPoint, ) -> Pin<Box<dyn Future<Output = StdResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Sets the chain point

fn get_next_chain_block<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StdResult<Option<ChainBlockNextAction>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the next chain block

impl Drop for PallasChainReader

fn drop(&mut self)

Executes the destructor for this type.