Struct BufferedDelta

Source

pub struct BufferedDelta {
    pub id: [u8; 32],
    pub parents: Vec<[u8; 32]>,
    pub hlc: u64,
    pub payload: Vec<u8>,
    pub nonce: Nonce,
    pub author_id: PublicKey,
    pub root_hash: Hash,
    pub events: Option<Vec<u8>>,
    pub source_peer: PeerId,
}

Expand description

A single buffered delta.

Contains ALL fields needed for replay after snapshot sync completes. Previously missing fields (nonce, author_id, root_hash, events) caused data loss because deltas couldn’t be decrypted or processed.

POC Bug 7: This struct MUST include all fields for replay - not just id, parents, hlc, payload, but also nonce, author_id, root_hash, events, and source_peer.

Fields§

§id: [u8; 32]

Delta ID.

§parents: Vec<[u8; 32]>

Parent IDs.

§hlc: u64

HLC timestamp.

§payload: Vec<u8>

Serialized (encrypted) payload.

§nonce: Nonce

Nonce for decryption (12 bytes for XChaCha20-Poly1305).

§author_id: PublicKey

Author public key (needed to get sender key for decryption).

§root_hash: Hash

Expected root hash after applying this delta.

§events: Option<Vec<u8>>

Optional serialized events (for handler execution after replay).

§source_peer: PeerId

Source peer ID (for requesting sender key if needed).

BufferedDelta

Struct BufferedDelta Copy item path

Fields§

Trait Implementations§

impl Clone for BufferedDelta

fn clone(&self) -> BufferedDelta

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

impl Debug for BufferedDelta

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

Auto Trait Implementations§

impl Freeze for BufferedDelta

impl RefUnwindSafe for BufferedDelta

impl Send for BufferedDelta

impl Sync for BufferedDelta

impl Unpin for BufferedDelta

impl UnsafeUnpin for BufferedDelta

impl UnwindSafe for BufferedDelta

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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<T> From<T> for T

fn from(t: T) -> 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> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

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> Reflect for T

fn as_dyn_ref<'a>(&self) -> &(dyn Reflect + 'a)where T: 'a,

fn as_dyn_mut<'a>(&mut self) -> &mut (dyn Reflect + 'a)where T: 'a,

fn as_dyn_box<'a>(self: Box<T>) -> Box<dyn Reflect + 'a>where T: 'a,

fn as_dyn_rc<'a>(self: Rc<T>) -> Rc<dyn Reflect + 'a>where T: 'a,

fn as_dyn_arc<'a>(self: Arc<T>) -> Arc<dyn Reflect + 'a>where T: 'a,

fn type_id(&self) -> TypeId

fn type_name(&self) -> &'static str

impl<T> ReflectExt for Twhere T: Reflect + ?Sized,

fn is<T>(&self) -> boolwhere T: Reflect + ?Sized,

fn type_id() -> TypeId

fn downcast_ref<T>(&self) -> Option<&T>where T: Reflect,

fn downcast_mut<T>(&mut self) -> Option<&mut T>where T: Reflect,

fn downcast_box<T>(self: Box<Self>) -> Result<Box<T>, Box<Self>>where T: Reflect,

fn downcast_rc<T>(self: Rc<Self>) -> Result<Rc<T>, Rc<Self>>where T: Reflect,

fn downcast_arc<T>(self: Arc<Self>) -> Result<Arc<T>, Arc<Self>>where T: Reflect,

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, 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>

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

fn vzip(self) -> V

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

impl<T> ErasedDestructor for Twhere T: 'static,

Struct BufferedDelta

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

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<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

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>,

fn as_dyn_ref<'a>(&self) -> &(dyn Reflect + 'a)
where T: 'a,

fn as_dyn_mut<'a>(&mut self) -> &mut (dyn Reflect + 'a)
where T: 'a,

fn as_dyn_box<'a>(self: Box<T>) -> Box<dyn Reflect + 'a>
where T: 'a,

fn as_dyn_rc<'a>(self: Rc<T>) -> Rc<dyn Reflect + 'a>
where T: 'a,

fn as_dyn_arc<'a>(self: Arc<T>) -> Arc<dyn Reflect + 'a>
where T: 'a,

impl<T> ReflectExt for T
where T: Reflect + ?Sized,

fn is<T>(&self) -> bool
where T: Reflect + ?Sized,

fn downcast_ref<T>(&self) -> Option<&T>
where T: Reflect,

fn downcast_mut<T>(&mut self) -> Option<&mut T>
where T: Reflect,

fn downcast_box<T>(self: Box<Self>) -> Result<Box<T>, Box<Self>>
where T: Reflect,

fn downcast_rc<T>(self: Rc<Self>) -> Result<Rc<T>, Rc<Self>>
where T: Reflect,

fn downcast_arc<T>(self: Arc<Self>) -> Result<Arc<T>, Arc<Self>>
where T: Reflect,

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

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

impl<T, U> TryInto<U> for T
where U: TryFrom<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> ErasedDestructor for T
where T: 'static,