Struct OasValidatorPlugin 

pub struct OasValidatorPlugin {
    operations: Vec<CompiledOp>,
    rejected_code: u16,
    rejected_msg: Option<Template>,
}

Validates requests against a compiled OpenAPI 3 spec.

Fields

operations: Vec<CompiledOp>

rejected_code: u16

rejected_msg: Option<Template>

Fixed message returned instead of the per-violation detail. Supports {{namespace.path}} references (no legacy $var interpolation — this field never supported it, so this sweep must not start).

Implementations

impl OasValidatorPlugin

pub fn from_config(config: &HashMap<String, Value>) -> Result<Self, String>

Builds the plugin from node config.

Accepted keys:

• spec (object, required): the OpenAPI 3 document as an inline JSON object. Its paths are walked and every operation’s application/json requestBody schema is compiled and required parameters indexed. A non-object spec, a malformed paths, or an uncompilable schema fails here at config load.
• rejected_code (integer 400–599, default 400): response status for rejected requests.
• rejected_msg (string): fixed message returned instead of the per-violation detail. Supports {{namespace.path}} references.

type: oas-validator
config:
  rejected_code: 400
  spec:
    openapi: 3.0.0
    info: { title: demo, version: "1.0" }
    paths:
      /users/{id}:
        get:
          parameters:
            - { name: verbose, in: query, required: true, schema: { type: string } }
        post:
          requestBody:
            required: true
            content:
              application/json:
                schema:
                  type: object
                  required: [name]
                  properties: { name: { type: string } }

fn match_operation(&self, method: &str, path: &str) -> Option<&CompiledOp>

Finds the best-matching operation for a method + path: the matching operation with the most literal (non-templated) segments wins, so an exact path is preferred over a templated one.

fn reject( &self, ctx: Context, detail: String, ) -> Result<PluginOutput, PluginExecutionError>

Writes the rejection onto the response and routes the context through the node’s denied port.

Trait Implementations

impl Plugin for OasValidatorPlugin

fn plugin_type(&self) -> &str

Unique identifier for the plugin type (e.g., “proxy-rewrite”, “upstream”). This is also the key its PortSpec is registered under in port_spec.

fn execute<'life0, 'async_trait>( &'life0 self, ctx: Context, ) -> Pin<Box<dyn Future<Output = Result<PluginOutput, PluginExecutionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Executes the plugin logic against the request/response context.

fn reads_response_body(&self) -> bool

Whether this configured instance reads context.response.body.

fn cache_target(&self) -> Option<CacheTarget>

The cache backend this node writes to, if it is a proxy-cache half.