Enum LeaderMessage 

pub enum LeaderMessage {
    WalEntry {
        offset: u64,
        data: WALEntry,
    },
    CaughtUp {
        current_offset: u64,
    },
    SnapshotStart {
        parquet_files: Vec<String>,
    },
    SnapshotChunk {
        filename: String,
        data: String,
        chunk_offset: u64,
        is_last: bool,
    },
    SnapshotEnd {
        wal_offset_after_snapshot: u64,
    },
}

Messages sent from leader to follower.

Variants

WalEntry

A WAL entry to be replayed by the follower.

Fields

offset: u64

data: WALEntry

CaughtUp

Sent after all catch-up entries have been streamed.

Fields

current_offset: u64

SnapshotStart

Signals the start of a Parquet snapshot transfer for catch-up. Sent when the follower’s last_offset is older than the oldest WAL entry.

Fields

parquet_files: Vec<String>

List of Parquet file names that will be streamed.

SnapshotChunk

A chunk of a Parquet file being transferred during catch-up. File contents are sent as base64-encoded binary chunks.

Fields

filename: String

The Parquet file name this chunk belongs to.

data: String

Base64-encoded binary data for this chunk.

chunk_offset: u64

Byte offset within the file where this chunk starts.

is_last: bool

Whether this is the last chunk for this file.

SnapshotEnd

Signals the end of Parquet snapshot transfer. After this, the leader resumes normal WAL streaming from the given offset.

Fields

wal_offset_after_snapshot: u64

The WAL offset to resume streaming from after loading the snapshot.

Trait Implementations

impl Clone for LeaderMessage

fn clone(&self) -> LeaderMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LeaderMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LeaderMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for LeaderMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.