Struct HiveMind 

pub struct HiveMind { /* private fields */ }

The central orchestrator of PulseHive.

Owns the substrate, LLM providers, approval handler, and event bus. Constructed exclusively via HiveMind::builder().

Implementations

impl HiveMind

pub fn builder() -> HiveMindBuilder

Creates a new builder for constructing a HiveMind.

pub fn substrate(&self) -> &dyn SubstrateProvider

Access the substrate provider for direct operations.

pub async fn deploy( &self, agents: Vec<AgentDefinition>, tasks: Vec<Task>, ) -> Result<Pin<Box<dyn Stream<Item = HiveEvent> + Send>>>

Deploy agents to execute tasks. Returns a stream of events.

Each agent is spawned as a Tokio task and dispatched via the workflow module’s dispatch_agent() which handles all agent kinds (LLM, Sequential, Parallel, Loop).

Automatically subscribes to the PulseDB Watch system for the collective, forwarding substrate change events as HiveEvent::WatchNotification. If Watch subscription fails, agents still execute normally (graceful degradation).

pub async fn record_experience( &self, experience: NewExperience, ) -> Result<ExperienceId>

Record an experience in the substrate.

Stores the experience via PulseDB, emits an ExperienceRecorded event, runs the RelationshipDetector to infer relations, and triggers the InsightSynthesizer if a cluster exceeds the density threshold.

pub fn shutdown(&self)

Signal shutdown to all background tasks (Watch system).

Sets the shutdown flag, causing the Watch background task to stop after processing its current event. This is non-blocking.

pub fn is_shutdown(&self) -> bool

Returns true if shutdown has been signaled.

pub async fn redeploy( &self, agents: Vec<AgentDefinition>, task: Task, ) -> Result<()>

Redeploy agents on the existing substrate and event bus.

Use this to restart failed agents. Products typically call this when they observe AgentCompleted { outcome: Error { .. } } on the event stream.

The collective is created/resolved from the task, same as in HiveMind::deploy().

Trait Implementations

impl Debug for HiveMind

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

Formats the value using the given formatter.

impl Drop for HiveMind

fn drop(&mut self)

Executes the destructor for this type.