wasmind 0.1.0

Core actor-based coordination runtime for AI agent workflows
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use crate::actors::{MessageEnvelope, manager::wasmind::actor::messaging};

use super::ActorState;

impl messaging::Host for ActorState {
    async fn broadcast(&mut self, message_type: String, payload: Vec<u8>) {
        let id = self
            .current_message_id
            .as_ref()
            .map(|parent_id| crate::utils::generate_child_correlation_id(parent_id))
            .unwrap_or_else(crate::utils::generate_root_correlation_id);

        let _ = self.tx.send(MessageEnvelope {
            id,
            message_type,
            from_actor_id: self.actor_id.to_string(),
            from_scope: self.scope.to_string(),
            payload,
        });
    }
}