Struct SyncRequester 

pub struct SyncRequester<A> { /* private fields */ }

Implementations

impl<A: DeserializeOwned + Serialize + Clone> SyncRequester<A>

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

Create a new SyncRequester with a random session ID.

pub fn new_session_id( storage_id: GraphId, session_id: u128, server_address: A, ) -> Self

Create a new SyncRequester for an existing session.

pub fn server_addr(&self) -> A

Returns the server address.

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.

pub fn get_sync_commands<'a>( &mut self, message: SyncResponseMessage, remaining: &'a [u8], ) -> Result<Option<Vec<SyncCommand<'a>, COMMAND_RESPONSE_MAX>>, SyncError>

Extract SyncCommands from a SyncResponseMessage and remaining bytes.

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

Writes a Subscribe message to target.

pub fn unsubscribe(&mut self, target: &mut [u8]) -> Result<usize, SyncError>

Writes an Unsubscribe message to target.