Struct ResultStore 

pub struct ResultStore { /* private fields */ }

Shared result store for sub-agent communication

Implementations

impl ResultStore

pub fn new() -> Self

Create a new result store

pub fn new_arc() -> Arc<Self>

Create a new result store wrapped in an Arc

pub async fn publish( &self, key: impl Into<String>, producer_id: impl Into<String>, value: impl Serialize, tags: Vec<String>, expires_at: Option<DateTime<Utc>>, ) -> Result<SharedResult>

Publish a result to the store

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

Get a result by key

pub async fn get_typed<T: for<'de> Deserialize<'de>>( &self, key: &str, ) -> Result<T>

Get a result and deserialize it to a specific type

pub async fn query_by_tags(&self, tags: &[String]) -> Vec<SharedResult>

Query results by tags

pub async fn query_by_producer(&self, producer_id: &str) -> Vec<SharedResult>

Query results by producer

pub async fn query_by_prefix(&self, prefix: &str) -> Vec<SharedResult>

Query results by key prefix

pub fn subscribe(&self) -> Receiver<ResultNotification>

Subscribe to result notifications

pub async fn register_subscription( &self, subtask_id: impl Into<String>, pattern: SubscriptionPattern, )

Register a subscription pattern for a subtask

pub async fn unregister_subscriptions(&self, subtask_id: &str)

Unregister all subscriptions for a subtask

pub fn matches_pattern( result: &SharedResult, pattern: &SubscriptionPattern, ) -> bool

Check if a result matches a subscription pattern

pub async fn get_all(&self) -> Vec<SharedResult>

Get all results (for debugging/inspection)

pub async fn cleanup_expired(&self) -> usize

Remove expired results

pub async fn clear(&self)

Clear all results

Trait Implementations

impl Default for ResultStore

fn default() -> Self

Returns the “default value” for a type.