Struct Graft 

pub struct Graft {
    pub local: VolumeId,
    pub remote: VolumeId,
    pub sync: Option<SyncPoint>,
    pub pending_commit: Option<PendingCommit>,
}

Fields

local: VolumeId

The local Volume backing this Graft

remote: VolumeId

The remote Volume backing this Graft.

sync: Option<SyncPoint>

Metadata keeping track of which portion of the local and remote volume this Graft cares about.

pending_commit: Option<PendingCommit>

Presence of the pending_commit field means that the Push operation is in the process of committing to the remote. If no such Push job is currently running (i.e. it was interrupted), this field must be used to resume or abort the commit process.

Implementations

impl Graft

pub fn new( local: VolumeId, remote: VolumeId, sync: Option<SyncPoint>, pending_commit: Option<PendingCommit>, ) -> Self

pub fn with_sync(self, sync: Option<SyncPoint>) -> Self

pub fn sync(&self) -> Option<&SyncPoint>

pub fn with_pending_commit(self, pending_commit: Option<PendingCommit>) -> Self

pub fn pending_commit(&self) -> Option<&PendingCommit>

pub fn local_watermark(&self) -> Option<LSN>

pub fn remote_commit(&self) -> Option<LSN>

pub fn local_changes(&self, head: Option<LSN>) -> Option<RangeInclusive<LSN>>

pub fn remote_changes(&self, head: Option<LSN>) -> Option<RangeInclusive<LSN>>

pub fn status( &self, latest_local: Option<LSN>, latest_remote: Option<LSN>, ) -> GraftStatus

Trait Implementations

impl Clone for Graft

fn clone(&self) -> Graft

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Graft

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

Formats the value using the given formatter.

impl Default for Graft

fn default() -> Graft

Returns the “default value” for a type.

impl EmptyState<(), Graft> for ()

where (): EmptyState<general, Option<PendingCommit>> + EmptyState<general, Option<SyncPoint>> + EmptyState<general, VolumeId> + Encoder<general, Option<PendingCommit>> + Encoder<general, Option<SyncPoint>> + Encoder<general, VolumeId>,

fn is_empty(val: &__Self) -> bool

Returns true iff this instance is in the empty state.

fn clear(val: &mut __Self)

fn empty() -> T

Produces the empty state for this type.

impl ForOverwrite<(), Graft> for ()

where (): EmptyState<general, Option<PendingCommit>> + EmptyState<general, Option<SyncPoint>> + EmptyState<general, VolumeId> + Encoder<general, Option<PendingCommit>> + Encoder<general, Option<SyncPoint>> + Encoder<general, VolumeId>,

fn for_overwrite() -> __Self

Produces a new Self value to be overwritten.

impl PartialEq for Graft

fn eq(&self, other: &Graft) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl RawMessage for __Self

where (): EmptyState<general, Option<PendingCommit>> + EmptyState<general, Option<SyncPoint>> + EmptyState<general, VolumeId> + Encoder<general, Option<PendingCommit>> + Encoder<general, Option<SyncPoint>> + Encoder<general, VolumeId>,

const __ASSERTIONS: ()

fn empty() -> Self

Returns an initialized message in an empty state.

fn is_empty(&self) -> bool

Returns whether the message is currently empty.

fn clear(&mut self)

Resets the message to an empty state.

fn raw_encode<__B>(&self, buf: &mut __B)

where __B: BufMut + ?Sized,

Encodes the message to a buffer.

fn raw_prepend<__B>(&self, buf: &mut __B)

where __B: ReverseBuf + ?Sized,

Prepends the message to a prepend buffer.

fn raw_encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

impl<'__a> RawMessageBorrowDecoder<'__a> for __Self

where (): BorrowDecoder<'__a, general, Option<PendingCommit>> + BorrowDecoder<'__a, general, Option<SyncPoint>> + BorrowDecoder<'__a, general, VolumeId> + EmptyState<general, Option<PendingCommit>> + EmptyState<general, Option<SyncPoint>> + EmptyState<general, VolumeId>,

fn raw_borrow_decode_field( &mut self, tag: u32, wire_type: WireType, duplicated: bool, buf: Capped<'_, &'__a [u8]>, ctx: DecodeContext, ) -> Result<(), DecodeError>

Decodes a field from a buffer into self from a borrowed slice.

impl RawMessageDecoder for __Self

where (): Decoder<general, Option<PendingCommit>> + Decoder<general, Option<SyncPoint>> + Decoder<general, VolumeId> + EmptyState<general, Option<PendingCommit>> + EmptyState<general, Option<SyncPoint>> + EmptyState<general, VolumeId>,

fn raw_decode_field<__B>( &mut self, tag: u32, wire_type: WireType, duplicated: bool, buf: Capped<'_, __B>, ctx: DecodeContext, ) -> Result<(), DecodeError>

where __B: Buf + ?Sized,

Decodes a field from a buffer into self.

impl Eq for Graft

impl StructuralPartialEq for Graft