Crate agent_orchestrator 

Public API surface for the agent orchestrator core crate.

This crate exposes orchestration models, configuration loading, scheduling, persistence helpers, and service-facing data transfer types used by the CLI and daemon crates.

Examples

use agent_orchestrator::config::WorkflowLoopGuardConfig;

let guard = WorkflowLoopGuardConfig::default();
assert!(guard.stop_when_no_unresolved);

Modules

agent_lifecycle

Agent Lifecycle Management Module

anomaly

Anomaly classification types for scheduler traces and runtime diagnostics.

async_database

Async SQLite access helpers backed by tokio_rusqlite (foundation layer).

cli_types

K8s-style declarative resource types shared by the CLI surface. K8s-style declarative resource types shared by the CLI surface.

collab

Re-exports from the orchestrator-collab crate.

config

Configuration model types. Configuration structures for the orchestrator.

config_ext

Extension trait adding CRD-projected accessors to OrchestratorConfig. Extension trait adding CRD-projected accessors to OrchestratorConfig.

config_load

Configuration loading, overlaying, and validation helpers.

crd

Custom resource definitions and resource store projections.

db

SQLite admin facade (admin / facade layer).

db_maintenance

Database maintenance utilities: VACUUM and size reporting. Database maintenance utilities: VACUUM and size reporting.

db_write

Serialized database write coordination for async callers (async write layer).

dto

Data transfer objects returned by public task and event APIs.

dynamic_orchestration

Dynamic Orchestration Module

env_resolve

Environment resolution utilities for command execution. Environment resolution utilities for command execution.

error

Canonical error categories and error classification helpers.

event_cleanup

TTL-based event cleanup, archival, and statistics. TTL-based event cleanup, optional archival, and statistics.

events

Event sink types and event-query helpers.

events_backfill

Backfill helpers for reconstructing missing event streams.

health

Health check models and endpoint support code.

json_extract

JSON extraction helpers used by dynamic orchestration and templating.

log_cleanup

TTL-based log file cleanup for terminated tasks. TTL-based log file cleanup for terminated tasks.

metrics

Agent Selection Metrics Module

migration

Legacy migration entry points preserved for compatibility.

observability

Logging and metrics bootstrap helpers for runtime observability.

output_capture

Output capture utilities for spawned commands. Output capture utilities for spawned commands.

output_validation

Structured output validation and diagnostics.

persistence

Persistence infrastructure (infrastructure layer).

prehook

Prehook execution models and support helpers.

qa_utils

QA document parsing and validation utilities.

resource

Declarative resource CRUD support and manifest rendering.

runner

Command runner abstractions, policies, and spawn helpers. Command runner abstractions, policies, and spawn helpers.

runtime

Daemon lifecycle state and runtime snapshots.

sandbox_network

Sandbox network allowlist parsing and validation. Sandbox network allowlist parsing and validation.

scheduler_port

Scheduler port: TaskEnqueuer trait for cross-crate task enqueue dispatch (see module docs). Scheduler port for cross-crate task enqueue dispatch.

secret_key_audit

Secret key audit reports and validation routines. SecretStore key audit event types and database helpers.

secret_key_lifecycle

Secret key rotation lifecycle primitives. SecretStore key lifecycle state machine and rotation logic.

secret_store_crypto

Secret-store encryption and decryption helpers. SecretStore encryption/decryption helpers (AES-256-GCM-SIV envelope scheme).

secure_files

Secure file and directory creation helpers. Secure file and directory creation helpers.

selection

Agent selection algorithms and resolution helpers.

self_referential_policy

Self-referential workspace safety policies.

service

Service-layer handlers used by the daemon.

session_store

Session persistence models and repository helpers.

state

Shared daemon state and state transition helpers.

store

Persistent Store — cross-task workflow memory with pluggable backends.

task_cleanup

Auto-cleanup of terminated tasks and associated data. Auto-cleanup of terminated tasks and their associated data.

task_ops

High-level task mutation operations.

task_repository

Task-execution persistence abstraction (execution layer).

ticket

Ticket discovery, preview, and creation helpers. Helpers for discovering, previewing, and creating QA failure tickets.

trigger_engine

Trigger engine: cron scheduler and event-driven task creation. Trigger engine: cron scheduler and event-driven task creation.

Structs

WorkflowLoopGuardConfig

Re-export of the public workflow loop guard configuration type. Guard settings evaluated between workflow cycles.