Struct SharedState 

pub struct SharedState { /* private fields */ }

Shared state for graph workflows

Nodes read/write arbitrary key-value pairs via get / set, and access structured conversation history via messages(). Internally uses Arc<RwLock>, safe to share across nodes and threads.

Example

use echo_orchestration::workflow::SharedState;

let state = SharedState::new();
state.set("count", 42);
state.set("name", "echo");

assert_eq!(state.get::<i64>("count"), Some(42));
assert_eq!(state.get::<String>("name"), Some("echo".to_string()));

Implementations

impl SharedState

pub fn new() -> SharedState

Create an empty state

pub fn from_values(values: HashMap<String, Value>) -> SharedState

Create from existing data

pub fn from_snapshot(snapshot: &str) -> Result<SharedState, Error>

Restore from a snapshot

pub fn set<T>(&self, key: impl Into<String>, value: T) -> Result<(), StateError>

where T: Serialize,

Set a value (auto-serialized to JSON).

Returns Result (StateResult<()>) – no longer panics on serialization failure or lock poison. For a backward-compatible void-returning API, use [Self::set_unwrap].

pub fn set_best_effort<T>(&self, key: impl Into<String>, value: T) -> Option<()>

where T: Serialize,

Backward-compatible: set value, returns Option<()> on failure (no panic)

pub fn get<T>(&self, key: &str) -> Option<T>

where T: for<'de> Deserialize<'de>,

Get a value (auto-deserialized)

pub fn get_raw(&self, key: &str) -> Option<Value>

Get raw JSON value

pub fn contains(&self, key: &str) -> bool

Check if key exists

pub fn remove(&self, key: &str) -> Option<Value>

Remove a key

pub fn keys(&self) -> Vec<String>

Get all keys

pub fn push_message(&self, msg: Message) -> Result<(), StateError>

Push a message, returns Result

pub fn messages(&self) -> Vec<Message>

Get a clone of all messages

pub fn message_count(&self) -> usize

Get message count

pub fn clear_messages(&self) -> Result<(), StateError>

Clear messages, returns Result

pub fn current_node(&self) -> Option<String>

Get the current node

pub fn fork(&self) -> Result<SharedState, StateError>

Create an isolated copy for branch execution.

pub fn snapshot(&self) -> Result<String, StateError>

Export as JSON snapshot, returns Result (no longer panics)

pub fn snapshot_unwrap(&self) -> String

Convenience method: export as JSON snapshot, unwraps on failure

pub fn to_json_value(&self) -> Result<Value, StateError>

Export as JSON Value, returns Result

pub fn to_json(&self) -> Value

Convenience method: export as JSON Value, unwraps on failure

pub fn from_json(json: &Value) -> Result<SharedState, Error>

Restore from JSON Value

pub fn merge(&self, other: &SharedState) -> Result<(), StateError>

Merge values from another state (does not overwrite existing keys), returns Result

pub fn merge_overwrite(&self, other: &SharedState) -> Result<(), StateError>

Merge values from another state (overwrites existing keys), returns Result

pub fn deep_merge(&self, other: &SharedState) -> Result<(), StateError>

Deep merge values from another state (recursively merge nested structures), returns Result

Unlike merge_overwrite: when a key’s value is a JSON object in both states, this method recursively merges the two object’s fields rather than wholesale overwrite. Useful for maintaining data consistency when parallel branches modify nested structures in the same state.

Trait Implementations

impl Clone for SharedState

fn clone(&self) -> SharedState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SharedState

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

Formats the value using the given formatter.

impl Default for SharedState

fn default() -> SharedState

Returns the “default value” for a type.