Struct ContextMessageStore 

pub struct ContextMessageStore;

Persistent store for context messages across the agent loop.

Messages are keyed by their key field for upsert semantics. The AddContextMessage handler applies throttle logic and upserts accepted messages here. The orchestrator reads messages, injects them, then applies lifecycle rules (removing ephemeral and consume-after-emit messages).

Trait Implementations

impl StateKey for ContextMessageStore

const KEY: &'static str = "__runtime.context_message_store"

const MERGE: MergeStrategy = MergeStrategy::Commutative

Parallel merge strategy. Default: Exclusive (conflict on concurrent writes).

type Value = ContextMessageStoreValue

type Update = ContextMessageAction

fn apply(value: &mut Self::Value, update: Self::Update)

const SCOPE: KeyScope = KeyScope::Run

Lifetime scope. Default: Run (cleared at run start).

fn encode(value: &Self::Value) -> Result<Value, StateError>

fn decode(value: Value) -> Result<Self::Value, StateError>