Struct SyncRequester

pub struct SyncRequester<'a> { /* private fields */ }

Implementations

impl SyncRequester<'_>

pub fn new<R: Csprng>(storage_id: GraphId, rng: &mut R) -> Self

Create a new SyncRequester with a random session ID.

pub fn ready(&self) -> bool

Returns true if Self::poll would produce a message.

pub fn poll( &mut self, target: &mut [u8], provider: &mut impl StorageProvider, heads: &mut PeerCache, ) -> Result<(usize, usize), SyncError>

Write a sync message in to the target buffer. Returns the number of bytes written and the number of commands sent in the sample.

pub fn receive<'a>( &mut self, data: &'a [u8], ) -> Result<Option<Vec<SyncCommand<'a>, COMMAND_RESPONSE_MAX>>, SyncError>

Receive a sync message. Returns parsed sync commands.