Struct SyncConfiguration

pub struct SyncConfiguration<T> { /* private fields */ }

Configuration parameters for data synchronisation between peers.

Implementations

impl<T> SyncConfiguration<T>

where T: TopicQuery,

pub fn new(protocol: impl for<'a> SyncProtocol<'a, T> + 'static) -> Self

Return a default instance of SyncConfiguration.

pub fn max_concurrent_sync_sessions(self, sessions: usize) -> Self

Define the maximum number of concurrent sync sessions.

pub fn max_retry_attempts(self, attempts: u8) -> Self

Define the maximum number of attempts at successfully completing a sync session with a specific peer.

pub fn protocol(&self) -> Arc<dyn for<'a> SyncProtocol<'a, T>>

Return the sync protocol from the given configuration.

pub fn resync(self, config: ResyncConfiguration) -> Self

Provide the resync configuration for the sync scheduler.

pub fn is_resync(&mut self) -> bool

Is resync enabled?

pub fn sync_queue_send_timeout(self, seconds: u64) -> Self

Define the maximum number of seconds to wait for sync attempt queue to have an open slot before failing.

Trait Implementations

impl<T: Clone> Clone for SyncConfiguration<T>

fn clone(&self) -> SyncConfiguration<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for SyncConfiguration<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.