Struct Orchestrator 

pub struct Orchestrator {
    pub thread_runtime: ThreadRuntime,
    pub planner: Arc<dyn Planner>,
    pub normalizer: PlanNormalizer,
    pub executor: Executor,
    pub task_store: Arc<dyn TaskStore>,
    pub context_builder: Option<Arc<dyn ContextBuilder>>,
    pub config: OrchestratorConfig,
    pub hook_registry: Arc<HookRegistry>,
    pub lifecycle_hooks: Arc<LifecycleHookRegistry>,
    pub skill_catalog: Arc<RwLock<SkillCatalog>>,
    pub skill_config_path: Option<PathBuf>,
}

Orchestrator - wires runtime + planner + executor for a minimal pipeline

Fields

thread_runtime: ThreadRuntime

planner: Arc<dyn Planner>

normalizer: PlanNormalizer

executor: Executor

task_store: Arc<dyn TaskStore>

context_builder: Option<Arc<dyn ContextBuilder>>

config: OrchestratorConfig

hook_registry: Arc<HookRegistry>

lifecycle_hooks: Arc<LifecycleHookRegistry>

skill_catalog: Arc<RwLock<SkillCatalog>>

skill_config_path: Option<PathBuf>

Config path used for skill re-discovery (hot reload).

Implementations

impl Orchestrator

pub async fn handle_event( &self, event: Event, ) -> Result<OrchestratorResult, OrchestratorError>

Handle an event end-to-end (intent -> plan -> normalize -> execute)

impl Orchestrator

pub fn new( thread_runtime: ThreadRuntime, planner: Arc<dyn Planner>, normalizer: PlanNormalizer, executor: Executor, task_store: Arc<dyn TaskStore>, ) -> Self

Create a new orchestrator

pub fn with_config( thread_runtime: ThreadRuntime, planner: Arc<dyn Planner>, normalizer: PlanNormalizer, executor: Executor, task_store: Arc<dyn TaskStore>, config: OrchestratorConfig, ) -> Self

Create a new orchestrator with config

pub fn with_context_builder(self, builder: Arc<dyn ContextBuilder>) -> Self

Attach a context builder (optional)

pub fn with_hook_registry(self, hook_registry: Arc<HookRegistry>) -> Self

Attach runtime hook registry.

pub fn with_lifecycle_hooks(self, hooks: Arc<LifecycleHookRegistry>) -> Self

Attach lifecycle hook registry for SDK pipeline hooks.

pub fn with_skill_catalog( self, skill_catalog: Arc<RwLock<SkillCatalog>>, ) -> Self

Attach skill catalog for planner-time instruction injection.

pub fn with_skill_config_path(self, path: PathBuf) -> Self

Set config path for skill hot-reload discovery.