Struct SharedWorkingMemory 

pub struct SharedWorkingMemory { /* private fields */ }

Thread-safe shared working memory for agents.

SharedWorkingMemory provides a shared context that multiple agents can read from and write to. It uses deep merging to combine updates with existing state, preserving values that aren’t being updated.

The memory is thread-safe and can be safely cloned and shared across multiple agents and async tasks.

Implementations

impl SharedWorkingMemory

pub fn new(initial_memory: Value) -> Self

Create a new SharedWorkingMemory with initial state.

Arguments

• initial_memory - The initial JSON value for the working memory

Examples

use mojentic::context::SharedWorkingMemory;
use serde_json::json;

let memory = SharedWorkingMemory::new(json!({
    "user": { "name": "Bob" }
}));

pub fn get_working_memory(&self) -> Value

Get a clone of the current working memory.

Returns a snapshot of the current state. Subsequent changes to the working memory will not affect this returned value.

Examples

use mojentic::context::SharedWorkingMemory;
use serde_json::json;

let memory = SharedWorkingMemory::new(json!({"count": 1}));
let snapshot = memory.get_working_memory();
assert_eq!(snapshot["count"], 1);

pub fn merge_to_working_memory(&self, new_memory: Value)

Merge new values into the working memory.

Performs a deep merge of the provided value with the existing memory. For objects, this recursively merges nested fields. For arrays and primitives, the new value replaces the old value.

Arguments

• new_memory - The JSON value to merge into the working memory

Examples

use mojentic::context::SharedWorkingMemory;
use serde_json::json;

let memory = SharedWorkingMemory::new(json!({
    "user": {
        "name": "Charlie",
        "age": 25
    }
}));

memory.merge_to_working_memory(json!({
    "user": {
        "age": 26,
        "city": "NYC"
    }
}));

let result = memory.get_working_memory();
assert_eq!(result["user"]["name"], "Charlie"); // Preserved
assert_eq!(result["user"]["age"], 26);         // Updated
assert_eq!(result["user"]["city"], "NYC");     // Added

Trait Implementations

impl Clone for SharedWorkingMemory

fn clone(&self) -> SharedWorkingMemory

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SharedWorkingMemory

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

Formats the value using the given formatter.

impl Default for SharedWorkingMemory

fn default() -> Self

Create a new SharedWorkingMemory with an empty object as initial state.