bamboo-engine 2026.10.15

Execution engine and orchestration for the Bamboo agent framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

//! Execution orchestration for background agent runs.
//!
//! This module provides the shared execution infrastructure used by all
//! background execution paths: HTTP execute handler, spawn scheduler,
//! and schedule manager.
//!
//! # Key types
//!
//! - [`AgentRunner`] / [`AgentStatus`] — lifecycle state of an agent run
//! - [`try_reserve_runner`] — atomically reserve a runner slot
//! - [`finalize_runner`] — update runner terminal status
//! - [`create_event_forwarder`] — MPSC → broadcast channel forwarder
//! - [`get_or_create_event_sender`] — session-scoped event broadcaster
//! - [`spawn_session_execution`] — spawn agent execution with full orchestration

pub mod agent_spawn;
pub mod child_completion;
pub mod event_forwarder;
pub mod event_publication;
pub mod runner_lifecycle;
pub mod runner_state;
pub mod session_events;
pub mod spawn;
pub mod visible_messages;

pub use agent_spawn::{
    log_base_system_prompt_snapshot, reserve_session_execution, reserve_session_preparation,
    spawn_session_execution, SessionCompletionHook, SessionExecutionArgs, SessionExecutionOutcome,
    SessionExecutionReservation, SessionExecutionReserveOutcome, SessionPreparationReservation,
};
pub use child_completion::{ChildCompletion, ChildCompletionHandler, ChildCompletionSource};
pub use event_forwarder::{
    create_event_forwarder, create_event_forwarder_with_history_commit_barrier,
    create_event_forwarder_with_root_actor, history_commit_barrier, AccountFeedInbox,
    HistoryCommitAcknowledger, HistoryCommitBarrier,
};
pub use runner_lifecycle::{
    finalize_runner, finalize_runner_exact, reserve_runner_core, status_from_execution_result,
    try_reserve_runner, ReserveOutcome, RunnerReservation,
};
pub use runner_state::{AgentRunner, AgentStatus};
pub use session_events::{get_or_create_event_sender, SESSION_EVENT_CHANNEL_CAPACITY};
pub use spawn::{
    ChildRunLaunchHook, ExternalChildRunner, SessionInboxRuntimeBinding, SpawnContext, SpawnJob,
    SpawnScheduler,
};
pub use visible_messages::{
    VisibleAssistantMessage, VisibleMessageEvent, VisibleMessageEventKind, VisibleMessageSnapshot,
    VisibleMessageStream,
};