Struct ParallelAgent 

pub struct ParallelAgent { /* private fields */ }

Parallel agent executes sub-agents concurrently

Implementations

impl ParallelAgent

pub fn new(name: impl Into<String>, sub_agents: Vec<Arc<dyn Agent>>) -> Self

Create a new parallel agent with the given name and sub-agents.

pub fn with_description(self, desc: impl Into<String>) -> Self

Set the agent description.

pub fn before_callback(self, callback: BeforeAgentCallback) -> Self

Add a before-agent callback.

pub fn after_callback(self, callback: AfterAgentCallback) -> Self

Add an after-agent callback.

pub fn with_skills(self, index: SkillIndex) -> Self

Set a preloaded skills index for this agent.

pub fn with_auto_skills(self) -> Result<Self>

Auto-load skills from .skills/ in the current working directory.

pub fn with_skills_from_root(self, root: impl AsRef<Path>) -> Result<Self>

Auto-load skills from .skills/ under a custom root directory.

pub fn with_skill_policy(self, policy: SelectionPolicy) -> Self

Customize skill selection behavior.

pub fn with_skill_budget(self, max_chars: usize) -> Self

Limit injected skill content length.

pub fn with_shared_state(self) -> Self

Enables shared state coordination for sub-agents.

When enabled, a fresh SharedState instance is created for each run() invocation and injected into each sub-agent’s context. Sub-agents can then use ctx.shared_state() to access the store.

Trait Implementations

impl Agent for ParallelAgent

fn name(&self) -> &str

Returns the unique name of this agent.

fn description(&self) -> &str

Returns a human-readable description of this agent’s purpose.

fn sub_agents(&self) -> &[Arc<dyn Agent>]

Returns the child agents managed by this agent.

fn supports_agent_transfer(&self) -> bool

Whether this agent participates in LLM-driven agent transfer and may be resumed directly across conversation turns.

fn run<'life0, 'async_trait>( &'life0 self, ctx: Arc<dyn InvocationContext>, ) -> Pin<Box<dyn Future<Output = Result<EventStream>> + Send + 'async_trait>>

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

Executes the agent and returns a stream of events.

fn interaction_mode(&self) -> AgentInteractionMode

Returns the agent’s primary interaction pattern.

fn capabilities(&self) -> AgentCapabilities

Declares the execution-plane capabilities this agent supports.

fn topology(&self) -> Option<AgentTopology>

Returns portable composition metadata when this agent owns an explicit topology.

fn configure_run(&self, _agent_name: &str, _config: &mut RunConfig)

Applies agent-composition policy to a run before the runtime creates the invocation context for agent_name.

fn transfer_targets_for(&self, _agent_name: &str) -> Option<Vec<String>>

Returns the exact handoff targets allowed for agent_name, when this agent owns an explicit transfer topology.

fn strict_transfer_policy(&self) -> bool

Whether transfer-policy violations should fail the run.

fn govern_transfer<'life0, 'life1, 'async_trait>( &'life0 self, _request: &'life1 AgentTransferRequest, ) -> Pin<Box<dyn Future<Output = Result<AgentTransferDecision, AdkError>> + Send + 'async_trait>>

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

Applies asynchronous policy to an otherwise valid transfer.