Struct StateSchemaValidator 

pub struct StateSchemaValidator { /* private fields */ }

Available on crate feature graph only.

Validates workflow state against a declared schema.

Wraps the existing StateSchema and adds field-level type validation capabilities for the functional API. Used at workflow start to validate initial state, and before applying reducers to validate task output.

Example

use adk_graph::functional::StateSchemaValidator;
use adk_graph::state::StateSchema;

let schema = StateSchema::builder()
    .channel("status")
    .counter_channel("count")
    .build();

let validator = StateSchemaValidator::new(schema)
    .expect_type("status", ExpectedType::String)
    .expect_type("count", ExpectedType::Number);

Implementations

impl StateSchemaValidator

pub fn new(schema: StateSchema) -> StateSchemaValidator

Available on crate feature functional only.

Create a new validator wrapping an existing StateSchema.

pub fn expect_type( self, field: &str, expected: ExpectedType, ) -> StateSchemaValidator

Available on crate feature functional only.

Declare the expected type for a state field.

Fields with type expectations will be validated when present. Use Self::require_field to also require the field’s presence.

pub fn require_field(self, field: &str) -> StateSchemaValidator

Available on crate feature functional only.

Mark a field as required (must be present in state).

Required fields that are missing from state will cause validation to fail with a descriptive error.

pub fn schema(&self) -> &StateSchema

Available on crate feature functional only.

Get the underlying StateSchema.

pub fn validate_state( &self, state: &HashMap<String, Value>, ) -> Result<(), FunctionalError>

Available on crate feature functional only.

Validate that all required fields exist with correct types in state.

Called at workflow start to validate the initial state.

Errors

Returns FunctionalError::SchemaValidation if:

• A required field is missing from state
• A field value does not match its declared expected type

pub fn validate_task_output( &self, output: &HashMap<String, Value>, ) -> Result<(), FunctionalError>

Available on crate feature functional only.

Validate task output before applying reducers.

Checks that output fields match their declared types. This is called after a task produces output but before the output is merged into the workflow state via reducers.

Arguments

• output - A map of field names to values produced by the task.

Errors

Returns FunctionalError::SchemaValidation if any output field has a value that does not match its declared expected type.

pub fn apply_update( &self, state: &mut HashMap<String, Value>, key: &str, value: Value, )

Available on crate feature functional only.

Apply an update to state using the underlying schema’s reducer.

Delegates to StateSchema::apply_update.

Trait Implementations

impl Clone for StateSchemaValidator

fn clone(&self) -> StateSchemaValidator

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StateSchemaValidator

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for StateSchemaValidator

fn default() -> StateSchemaValidator

Returns the “default value” for a type.