Struct VersionSyncHandle

pub struct VersionSyncHandle {
    last_version_location: Option<StorageLocation>,
    next_version_location: Option<StorageLocation>,
    version_pending: Arc<(Mutex<bool>, Condvar)>,
    _resource_key: String,
}

Fields

last_version_location: Option<StorageLocation>

next_version_location: Option<StorageLocation>

version_pending: Arc<(Mutex<bool>, Condvar)>

_resource_key: String

Implementations

impl VersionSyncHandle

pub fn new( key: &str, last_version_location: Option<StorageLocation>, ) -> VersionSyncHandle

pub fn last_location(&self) -> &Option<StorageLocation>

pub fn start_version(&mut self) -> Result<()>

pub fn advance_next(&mut self, next_version_location: Option<StorageLocation>)

pub fn update_version(&mut self) -> Result<()>

pub fn skip_version(&mut self) -> Result<()>

pub fn revert_version(&mut self) -> Result<()>

pub fn wait_for_version_with_timeout(&self, timeout: Duration) -> Result<()>

Trait Implementations

impl Debug for VersionSyncHandle

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

Formats the value using the given formatter.