Struct JsonState 

pub struct JsonState { /* private fields */ }

A simple JSON-based state implementation

This is a basic implementation of GraphState that uses a JSON object as the backing store. Useful for simple workflows or testing.

Implementations

impl JsonState

pub fn new() -> JsonState

Create a new empty JSON state

pub fn from_map(data: Map<String, Value>) -> JsonState

Create from a JSON object

pub fn from_value(value: Value) -> Result<JsonState, AgentError>

Create from a JSON value (must be an object)

pub fn as_map(&self) -> &Map<String, Value>

Get a reference to the underlying map

pub fn as_map_mut(&mut self) -> &mut Map<String, Value>

Get a mutable reference to the underlying map

Trait Implementations

impl Clone for JsonState

fn clone(&self) -> JsonState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JsonState

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

Formats the value using the given formatter.

impl Default for JsonState

fn default() -> JsonState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for JsonState

fn deserialize<__D>( __deserializer: __D, ) -> Result<JsonState, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl GraphState for JsonState

fn apply_update<'life0, 'life1, 'async_trait>( &'life0 mut self, key: &'life1 str, value: Value, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, JsonState: 'async_trait,

Apply a state update

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

Get a value by key

fn keys(&self) -> Vec<&str>

Get all keys in this state

fn to_json(&self) -> Result<Value, AgentError>

Convert entire state to a JSON Value

fn from_json(value: Value) -> Result<JsonState, AgentError>

Create state from a JSON Value

fn apply_updates<'life0, 'life1, 'async_trait>( &'life0 mut self, updates: &'life1 [StateUpdate], ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Apply multiple updates

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

Check if a key exists

impl Serialize for JsonState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.