Struct SharedState 

pub struct SharedState { /* private fields */ }

Thread-safe key-value store for parallel agent coordination.

Scoped to a single ParallelAgent::run() invocation. All sub-agents share the same Arc<SharedState> instance.

Example

use adk_core::SharedState;
use std::sync::Arc;
use std::time::Duration;

let state = Arc::new(SharedState::new());

// Agent A publishes a workbook handle
state.set_shared("workbook_id", serde_json::json!("wb-123")).await?;

// Agent B waits for the handle
let handle = state.wait_for_key("workbook_id", Duration::from_secs(30)).await?;

Implementations

impl SharedState

pub fn new() -> Self

Creates a new empty SharedState.

pub async fn set_shared( &self, key: impl Into<String>, value: Value, ) -> Result<(), SharedStateError>

Inserts a key-value pair. Notifies all waiters on that key.

Errors

Returns SharedStateError::EmptyKey if key is empty. Returns SharedStateError::KeyTooLong if key exceeds 256 bytes.

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

Returns the value for a key, or None if not present.

pub async fn wait_for_key( &self, key: &str, timeout: Duration, ) -> Result<Value, SharedStateError>

Blocks until the key appears, or the timeout expires.

If the key already exists, returns immediately. A SharedState::set_shared for the key that runs concurrently with this call is never missed: the waiter registers for notification before each read of the key.

Errors

Returns SharedStateError::Timeout if the timeout expires. Returns SharedStateError::InvalidTimeout if timeout is outside [1ms, 300s].

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

Returns a snapshot of all current entries.

Trait Implementations

impl Debug for SharedState

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

Formats the value using the given formatter.

impl Default for SharedState

fn default() -> Self

Returns the “default value” for a type.

impl Serialize for SharedState

fn serialize<S: Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error>

Serialize this value into the given Serde serializer.