Module orchestrator

Module orchestrator 

Source
Expand description

Subagent orchestration (core-owned, tauri-free).

This module coordinates delegated tasks across subagents and executes them via the unified crate::pipeline::AgentPipeline.

§Layering

  • gestura-core owns orchestration policy (permissions, task tracking, execution).
  • Adapters (GUI/CLI) may attach observers to emit UI events, but must not re-implement orchestration logic.

Structs§

ActiveTaskSnapshot
Active workflow-task snapshot surfaced to adapters for live operator views.
AgentInfo
Public agent info for status queries
AgentOrchestrator
Orchestrator for coordinating subagents and delegated task execution.
AgentSpawnRequest
Spawn configuration for a managed agent.
ApprovalActor
Actor provenance for an approval request or decision.
ApprovalDecision
Audit entry for a single approval decision.
ApprovalPolicy
End-to-end approval policy for a delegated task.
ApprovalRequest
Snapshot of a single approval request.
ApprovalRequirement
Policy requirement for a single approval scope.
ChildSupervisorRunRequest
Request payload for creating a direct child supervisor run.
ChildSupervisorRunSummary
Summary stored on parent runs for each child supervisor run.
CleanupResult
Cleanup result for an environment.
DelegatedCheckpointSummary
Compact checkpoint metadata surfaced on workflow task records.
DelegatedTask
Task that can be delegated to a subagent
DelegatedTaskCheckpoint
Durable checkpoint record for delegated-task execution.
DelegationBrief
Structured brief attached to delegated work.
EnvironmentFailure
Structured failure details for environment operations.
EnvironmentLease
Active or historical environment lease.
EnvironmentRecord
Durable persisted record for an execution environment.
EnvironmentSpec
Durable specification for an execution environment.
ExecutionEnvironment
Execution environment bound to a task.
GitWorktreeSpec
Git worktree provisioning details.
LocalExecutionEnvironmentSnapshot
Environment snapshot carried alongside local delegated telemetry.
LocalExecutionProgress
Local delegated execution progress mirrored from the streaming agent loop.
LocalExecutionRecord
Mirrored local execution state for a workflow task.
LocalExecutionTokenUsageSnapshot
Token usage telemetry captured during local delegated execution.
OrchestratorToolCall
Record of a tool call during orchestrated task execution
RemoteAgentTarget
Remote target details for delegated work that may execute via A2A.
RemoteExecutionArtifact
Summary of a remote artifact available for a task.
RemoteExecutionCompatibility
Compatibility assessment for a remote peer.
RemoteExecutionProgress
Remote progress snapshot mirrored from an A2A task.
RemoteExecutionRecord
Mirrored remote execution state for a workflow task.
SharedCognitionNote
Durable run-scoped collaboration memory surfaced to workflows and prompt enrichment.
SupervisorHierarchySummary
Roll-up state for a run and its direct children.
SupervisorInheritancePolicy
Inherited policy applied to tasks created inside a supervisor run.
SupervisorParentRunRef
Parent run reference stored on child supervisor runs.
SupervisorRun
Persistent supervisor run state.
SupervisorRunTaskSummary
Task-state counts for a supervisor run.
SupervisorTaskRecord
Persistent task record owned by a supervisor run.
TaskApprovalRecord
Approval details tracked per task.
TaskArtifactRecord
Artifact produced by delegated task execution.
TaskResult
Result from a delegated task
TeamActionRequest
Actionable request embedded in a collaboration message.
TeamActionRequestDraft
Draft payload for creating a new actionable request.
TeamArtifactReference
Artifact reference attached to a collaboration message.
TeamEscalation
Structured escalation details for a collaboration message.
TeamEscalationDraft
Draft escalation payload for a collaboration message.
TeamMessage
Message exchanged within a supervisor run.
TeamMessageDraft
Draft payload for creating or replying within a collaboration thread.
TeamResultReference
Result reference attached to a collaboration message.
TeamThread
Grouped collaboration thread view.

Enums§

AgentExecutionMode
Execution mode used by a subagent.
AgentRole
Specialist role assigned to a managed agent.
ApprovalActorKind
Actor category authorized to make approval decisions.
ApprovalDecisionKind
Decision outcome for an approval request.
ApprovalScope
Gate scope for an approval request.
ApprovalState
Approval state tracked by the supervisor.
CleanupDisposition
Resulting cleanup action for an environment.
CleanupPolicy
Cleanup behavior for an execution environment.
CollaborationActionStatus
Resolution status for an actionable collaboration request.
CollaborationEscalationLevel
Escalation severity for a collaboration thread.
CollaborationRequestKind
Actionable collaboration request type.
CollaborationThreadStatus
Aggregate status for a collaboration thread.
DelegatedCheckpointAction
Operator actions exposed for delegated-task checkpoints.
DelegatedCheckpointStage
Persisted lifecycle stage for a delegated-task checkpoint.
DelegatedReplaySafety
Replay-safety class used during delegated-task restart reconciliation.
DelegatedResumeDisposition
Recovery disposition for a delegated-task checkpoint.
EnvironmentFailureKind
Kind of failure observed while managing an environment.
EnvironmentHealth
Health assessment for an environment on disk.
EnvironmentLeaseKind
Lease type held on an environment.
EnvironmentState
Durable environment lifecycle state.
LocalExecutionPhase
Local delegated execution progress mirrored from the streaming agent loop.
LocalExecutionWaitingReason
Structured waiting reason for local delegated execution.
RecoveryAction
Recommended recovery action for an environment.
RecoveryStatus
Recovery status for an environment.
SharedCognitionKind
Structured shared-cognition note persisted on a supervisor run and projected into durable memory.
SupervisorRunStatus
Aggregate status for a supervisor run.
SupervisorTaskState
Execution state for a task managed by the supervisor.
TaskTerminalStateHint
Optional terminal-state mapping returned by delegated execution.
TeamMessageKind
Structured team-message category.

Constants§

DEFAULT_RESOLVED_THREAD_RETENTION_DAYS
Retention period before resolved threads are auto-archived.
MAX_CHILD_SUPERVISOR_DEPTH
Maximum allowed parent -> child supervisor depth.
SHARED_COGNITION_CATEGORY
Durable memory-bank category used for run/task shared cognition.
SHARED_COGNITION_TAG
Stable tag applied to shared-cognition memory entries.

Traits§

AgentSpawner
Trait for spawning and managing isolated agents
OrchestratorAgentManager
Agent manager capabilities required by the orchestrator.
OrchestratorObserver
Optional observer for adapter-side UI/event wiring.

Functions§

actor_kind_for_agent_role
Infer the default actor kind from an agent role when possible.
archive_resolved_threads
Archive resolved threads older than the configured retention period.
build_team_threads
Build grouped threads from flat collaboration messages.
build_team_threads_with_options
Build grouped threads from flat collaboration messages with archive controls.
default_actor_kind_for_scope
Build the default approval actor role for a task gate scope.