Enum ReplicaEvent 

pub enum ReplicaEvent {
    Frame(DecodedFrame),
    SnapshotBegin,
    SnapshotChunk(Vec<u8>),
    SnapshotEnd {
        ack_offset: u64,
    },
}

Event yielded by ReplicaClient::next_event. A driver loop pattern-matches and applies each:

• Self::Frame → run through the local dispatcher.
• Self::SnapshotBegin → caller should reset / prepare the local store for a fresh-from-snapshot fill.
• Self::SnapshotChunk → append the bytes to the caller’s accumulating snapshot buffer.
• Self::SnapshotEnd → caller hands the accumulated buffer to kevy_persist::load_snapshot; ReplicaClient has already advanced expected_offset to ack_offset, so the next Self::Frame arrives at ack_offset with no gap.

Variants

Frame(DecodedFrame)

A live mutation frame.

SnapshotBegin

Snapshot ship begin marker (+SNAPSHOT\r\n).

SnapshotChunk(Vec<u8>)

One snapshot chunk’s payload bytes (RESP bulk string body).

SnapshotEnd

Snapshot ship end marker carrying the offset the next live frame will have.

Fields

ack_offset: u64

The offset the primary’s next_offset was at when the snapshot started. After this event, ReplicaClient::expected_offset equals this value.

Trait Implementations

impl Debug for ReplicaEvent

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

Formats the value using the given formatter.