Struct MessageBuilder 

pub struct MessageBuilder { /* private fields */ }

Builder for Message. Collapses the historical new / with_id / from_value / without_change_capture four-way constructor split into a single fluent shape.

use dataflow_rs::Message;
use serde_json::json;

// Minimal: serde_json payload, default UUID id, capture on.
let m = Message::builder()
    .payload_json(&json!({"order": {"total": 1500}}))
    .build();
assert!(m.id().len() > 0);
assert!(m.capture_changes());

Implementations

impl MessageBuilder

pub fn new() -> Self

Create an empty builder. Equivalent to MessageBuilder::default.

pub fn id(self, id: impl Into<String>) -> Self

Caller-supplied id (typically a correlation id from upstream). Defaults to a freshly-generated UUID v7.

pub fn payload(self, payload: Arc<OwnedDataValue>) -> Self

Already-owned payload Arc — zero serde_json walk, refcount-only share. Mutually exclusive with Self::payload_json; whichever is called last wins.

pub fn payload_json(self, payload: &JsonValue) -> Self

Construct the payload from a serde_json::Value. Goes through the OwnedDataValue::from(&Value) bridge (one deep walk).

pub fn capture_changes(self, on: bool) -> Self

When false, built-in functions skip per-write Change capture — audit-trail entries are still recorded but their changes list is empty. Defaults to true.

pub fn build(self) -> Message

Finalize. Defaults: id = UUID v7, payload = OwnedDataValue::Null, capture_changes = true.

Trait Implementations

impl Default for MessageBuilder

fn default() -> MessageBuilder

Returns the “default value” for a type.