Struct ValidatorAgent 

pub struct ValidatorAgent {
    pub id: String,
    pub config: ValidatorAgentConfig,
    pub communication_hub: Arc<CommunicationHub>,
    pub file_lock_manager: Arc<FileLockManager>,
    pub status: Arc<RwLock<ValidatorAgentStatus>>,
}

A standalone, read-only agent that runs external validators and returns a structured result to the orchestrator.

Fields

id: String

Unique identifier for this validator agent.

config: ValidatorAgentConfig

Configuration.

communication_hub: Arc<CommunicationHub>

Communication hub for broadcasting status messages.

file_lock_manager: Arc<FileLockManager>

File lock manager for acquiring read locks.

status: Arc<RwLock<ValidatorAgentStatus>>

Observable status.

Implementations

impl ValidatorAgent

pub fn new( id: impl Into<String>, config: ValidatorAgentConfig, communication_hub: Arc<CommunicationHub>, file_lock_manager: Arc<FileLockManager>, ) -> Self

Create a new ValidatorAgent.

pub async fn validate(&self) -> Result<ValidatorAgentResult>

Run the full validation pipeline.

1. Register with the communication hub, broadcast AgentSpawned.
2. Acquire read locks on all working_set_files (best-effort).
3. Run run_validation with a wall-clock timeout.
4. Release locks, broadcast AgentCompleted, unregister.