Enum Message 

#[non_exhaustive]
pub enum Message {
    Handshake {
        worker_version: String,
        protocol_version: u16,
    },
    ConfigureFrameLimit {
        max_frame_bytes: u32,
    },
    Request(Request),
    Response(Response),
    Diagnostic(Diagnostic),
    ProgressTick(ProgressTick),
    DataRow(DataRow),
    FatalExit(FatalExit),
}

One protocol message exchanged over the worker boundary.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Handshake

Sent by the child immediately after spawn to advertise its version and supported protocol revision.

Fields

worker_version: String

lean-rs-worker-child package version.

protocol_version: u16

Protocol version the child speaks. Parent rejects mismatches.

ConfigureFrameLimit

Sent by the parent immediately after the handshake frame to negotiate the per-frame size cap for the remainder of this connection.

The parent owns the memory-safety policy: it clamps the requested cap into [MIN_FRAME_BYTES, MAX_FRAME_BYTES_HARD_CAP] before sending. The child installs the value as-is.

Fields

max_frame_bytes: u32

Per-frame byte cap applied in both directions for this connection.

Request(Request)

Parent → child request frame.

Response(Response)

Child → parent terminal response for one request.

Diagnostic(Diagnostic)

Child → parent intermediate diagnostic frame.

ProgressTick(ProgressTick)

Child → parent intermediate progress frame.

DataRow(DataRow)

Child → parent streaming data row frame.

FatalExit(FatalExit)

Child → parent fatal exit notification carrying the captured stderr just before the child process tears down.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Message

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Message

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Message

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for Message

impl StructuralPartialEq for Message