Struct AgentState 

pub struct AgentState { /* private fields */ }

Shared state that persists across graph execution. All nodes can read and write to this state.

Implementations

impl AgentState

pub fn new() -> Self

Create a new empty state

pub fn with_limits(limits: StateLimits) -> Self

Create a new empty state with explicit limits.

pub fn with_data(data: HashMap<String, Value>) -> Self

Create state with initial data

pub fn with_data_and_limits( data: HashMap<String, Value>, limits: StateLimits, ) -> Self

Create state with initial data and explicit limits.

pub async fn register_reducer( &self, key: impl Into<String>, reducer: impl Reducer + 'static, )

Register a reducer for a specific state key. When set() is called on this key and a value already exists, the reducer is used to combine old and new values.

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

where T: DeserializeOwned,

Get a value from state (type-safe)

pub async fn get_opt<T>(&self, key: &str) -> Result<Option<T>>

where T: DeserializeOwned,

Try to get a value (returns None if missing)

pub async fn set<T>(&self, key: &str, value: T) -> Result<()>

where T: Serialize,

Set a value in state (type-safe). If a reducer is registered for this key and a value already exists, the reducer is used to combine old and new values.

pub async fn set_raw(&self, key: &str, value: Value) -> Result<()>

Set a raw JSON value without applying reducers.

pub async fn apply_reducer( &self, key: &str, current: &Value, new: &Value, ) -> Result<Value>

Apply a reducer to combine current and new values for a key. If no reducer is registered, returns the new value (last-write-wins).

pub async fn update<T, F>(&self, key: &str, f: F) -> Result<()>

where T: DeserializeOwned + Serialize, F: FnOnce(T) -> T,

Update a value using a closure

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

Check if a key exists

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

Remove a key

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

Get all keys

pub async fn snapshot(&self) -> StateSnapshot

Create a snapshot of current state

pub async fn save_to_history(&self)

Save current state to history

pub async fn restore(&self, snapshot: &StateSnapshot)

Restore state from snapshot

pub async fn get_history(&self) -> Vec<StateSnapshot>

Get state history

pub async fn export(&self) -> HashMap<String, Value>

Export state as HashMap for serialization

pub async fn transaction(&self) -> StateTransaction

Begin a transaction. Captures a snapshot so changes can be rolled back.

pub async fn fork(&self) -> AgentState

Create an independent deep copy of this state for parallel branches. The forked state has its own data storage but shares the same reducers.

Trait Implementations

impl Clone for AgentState

fn clone(&self) -> AgentState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentState

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

Formats the value using the given formatter.

impl Default for AgentState

fn default() -> Self

Returns the “default value” for a type.