Struct MessageMeta 

#[non_exhaustive]
pub struct MessageMeta {
    pub policy: CompactionPolicy,
    pub source: Option<String>,
    pub salience: Option<f64>,
    pub version: u64,
}

Per-message annotation attached to every message in an OperatorContext.

All fields are public and directly settable. The Default implementation uses CompactionPolicy::Normal and zeros/nones for everything else.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

policy: CompactionPolicy

Compaction policy governing how this message survives context reduction.

source: Option<String>

Source of the message, e.g. "user" or "tool:shell".

salience: Option<f64>

Importance hint in the range 0.0–1.0. Higher values should survive compaction longer.

version: u64

Monotonic version counter, incremented on each mutation via OperatorContext::transform.

Implementations

impl MessageMeta

pub fn with_policy(policy: CompactionPolicy) -> Self

Create metadata with the given policy and defaults for all other fields.

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

Set the source.

pub fn set_salience(self, salience: f64) -> Self

Set the salience score.

Trait Implementations

impl Clone for MessageMeta

fn clone(&self) -> MessageMeta

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageMeta

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

Formats the value using the given formatter.

impl Default for MessageMeta

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MessageMeta

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MessageMeta

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

where __S: Serializer,

Serialize this value into the given Serde serializer.