Enum RegistryEvent 

pub enum RegistryEvent {
    Put {
        seq: i64,
        record: RepoRecord,
    },
    Mutation {
        seq: i64,
        repo_id: String,
    },
    Removed {
        seq: i64,
        repo_id: String,
    },
}

The registry mutation event — the durable change feed’s payload. Every variant carries the mutation’s sequence number: the consumer’s per-seq idempotency key and the reconcile watermark’s currency. The Mutation variant is the per-push mutation-marker event’s kind (ADR-019 §7 — pushes do not modify RepoRecord; the marker write’s announce carries the bare mutation).

Variants

Put

A record was created or replaced (the put/update mutations).

Fields

seq: i64

The mutation’s sequence number.

record: RepoRecord

The record as committed.

Mutation

The repo mutated without a record change — the per-push mutation-marker write’s event (the watermark leg that drives reconcile and diff-driven replication on every push).

Fields

seq: i64

The mutation’s sequence number.

repo_id: String

The repo id the mutation anchored.

Removed

A record was removed (the removal consumed a sequence; the row is gone — the event is the removal’s only row-carrying trace).

Fields

seq: i64

The mutation’s sequence number.

repo_id: String

The removed repo id.

Implementations

impl RegistryEvent

pub fn repo_id(&self) -> &str

The event’s repo id (the publish key).

pub fn seq(&self) -> i64

The event’s sequence number.

pub fn decode_event(event: &StreamEvent) -> Option<RegistryEvent>

Decode a feed event. Undecodable payloads (a foreign producer on the stream, codec drift) yield None — the consumer skips and checkpoints past them rather than wedging its cursor on the poison event.

Trait Implementations

impl Clone for RegistryEvent

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RegistryEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RegistryEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for RegistryEvent

impl PartialEq for RegistryEvent

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for RegistryEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RegistryEvent