Struct Delta 

pub struct Delta {
    pub resource: String,
    pub record_id: String,
    pub op: DeltaOp,
    pub payload: Value,
    pub occurred_at: DateTime<Utc>,
    pub provenance: Provenance,
}

A single change-set emitted by a SyncSource.

Fields

resource: String

Resource (table) the delta applies to, e.g. "pets".

record_id: String

Stable id of the record within the resource.

op: DeltaOp

Operation kind.

payload: Value

Record payload (JSON object). For Delete this is typically serde_json::Value::Null.

occurred_at: DateTime<Utc>

When the source observed the change.

provenance: Provenance

Source + confidence metadata.

Implementations

impl Delta

pub fn upsert( resource: impl Into<String>, record_id: impl Into<String>, payload: Value, source: impl Into<String>, ) -> Self

Convenience: build an upsert delta.

pub fn delete( resource: impl Into<String>, record_id: impl Into<String>, source: impl Into<String>, ) -> Self

Convenience: build a delete delta.

pub fn with_confidence(self, confidence: f32) -> Self

Builder helper to override the default confidence.

pub fn at(self, ts: DateTime<Utc>) -> Self

Builder helper to set a specific occurrence time.

Trait Implementations

impl Clone for Delta

fn clone(&self) -> Delta

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Delta

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Delta

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Delta

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

where __S: Serializer,

Serialize this value into the given Serde serializer.