Struct ReplicationStatusEntry

Source

pub struct ReplicationStatusEntry {
    pub status: ReplicationStatus,
    pub generation: u64,
}

Expand description

Per-(source_bucket, source_key) replication status entry, paired with the generation token of the source PUT that produced it.

§v0.8.2 #61 — generation token

Each put_object (or complete_multipart_upload) on a source key pulls a fresh, monotonically-increasing generation from the manager. The detached replication task carries that generation and only stamps the status when its generation is >= the stored one (CAS-style). A stale retry whose generation has been overtaken by a newer PUT is silently dropped, so the destination bucket never gets rolled back to older bytes. See ReplicationManager::next_generation

ReplicationManager::record_status_if_newer.

Fields§

§status: ReplicationStatus§generation: u64

Struct ReplicationStatusEntry Copy item path

§v0.8.2 #61 — generation token

Fields§

Trait Implementations§

impl Clone for ReplicationStatusEntry

fn clone(&self) -> ReplicationStatusEntry

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

impl Debug for ReplicationStatusEntry

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

impl<'de> Deserialize<'de> for ReplicationStatusEntry

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl PartialEq for ReplicationStatusEntry

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

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

impl Serialize for ReplicationStatusEntry

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

impl Eq for ReplicationStatusEntry

impl StructuralPartialEq for ReplicationStatusEntry

Auto Trait Implementations§

impl Freeze for ReplicationStatusEntry

impl RefUnwindSafe for ReplicationStatusEntry

impl Send for ReplicationStatusEntry

impl Sync for ReplicationStatusEntry

impl Unpin for ReplicationStatusEntry

impl UnsafeUnpin for ReplicationStatusEntry

impl UnwindSafe for ReplicationStatusEntry

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromExt for T

fn from_<T>(t: T) -> Selfwhere Self: From<T>,

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoExt for T

fn into_<T>(self) -> Twhere Self: Into<T>,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T> TryFromExt for T

fn try_from_<T>(t: T) -> Result<Self, Self::Error>where Self: TryFrom<T>,

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Struct ReplicationStatusEntry

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

impl<T> Any for T
where T: 'static + ?Sized,

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn from_<T>(t: T) -> Self
where Self: From<T>,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_<T>(self) -> T
where Self: Into<T>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

fn try_from_<T>(t: T) -> Result<Self, Self::Error>
where Self: TryFrom<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn try_into_<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,