Struct Lease 

pub struct Lease {
    pub idx: u64,
    pub start: u64,
    pub end: Arc<AtomicU64>,
    pub progress: Arc<AtomicU64>,
}

A worker’s exclusive claim on part of the file.

Fields

idx: u64

start: u64

end: Arc<AtomicU64>

Inclusive upper bound. The scheduler may lower this; re-read it before every write and stop when it is passed.

progress: Arc<AtomicU64>

Bytes written from start, published by the owning worker.

Implementations

impl Lease

pub fn end(&self) -> u64

pub fn progress(&self) -> u64

pub fn cursor(&self) -> u64

Absolute file offset of the next byte to fetch.

pub fn is_open_ended(&self) -> bool

pub fn remaining(&self) -> u64

Bytes still owed on this lease, given the current (possibly lowered) end.

pub fn publish_progress(&self, bytes_from_start: u64)

Trait Implementations

impl Clone for Lease

fn clone(&self) -> Lease

Returns a duplicate of the value.

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

Performs copy-assignment from source.