Struct ValidateFactory 

pub struct ValidateFactory { /* private fields */ }

Implementations

impl ValidateFactory

pub fn new(schemas: Arc<SchemaRegistry>) -> Self

Trait Implementations

impl PipeFactory for ValidateFactory

Available on crate feature std only.

fn name(&self) -> &str

fn build( &self, spec: &Value, inner: Option<PipeHandle>, ) -> Pin<Box<dyn Future<Output = Result<PipeHandle, ProximaError>> + Send + '_>>

Build a Pipe from a config spec. inner carries the next stage in the chain for wrapping pipes (auth, retry, validate, transform, …); terminal pipes (synth, http, kv, …) ignore it. A wrapping factory called with inner: None should error; a terminal factory called with inner: Some(_) may either ignore or error — convention is ignore.