Struct FaultInjectionPlugin 

pub struct FaultInjectionPlugin {
    abort: Option<AbortRule>,
    delay: Option<DelayRule>,
}

Injects delays and/or abort responses into matching requests.

Order matches APISIX: the delay (if it triggers) is applied first, then the abort check runs. body, and string header values, support $var interpolation against the request.

Fields

abort: Option<AbortRule>

delay: Option<DelayRule>

Implementations

impl FaultInjectionPlugin

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

Builds the plugin from node config. At least one of abort / delay is required; expressions and shapes are validated here at config load.

Accepted keys:

• abort (object): injected response.
  • http_status (integer >= 200, required): response status.
  • body (string): response body; supports $var interpolation. Empty body when unset.
  • headers (map {name: value} or array [{name, value}]): response headers; string values support $var interpolation.
  • percentage (integer 0-100): chance the abort triggers; unset means always.
  • vars (array): APISIX condition expressions, OR-ed across items.
• delay (object): injected latency.
  • duration (number, seconds, may be fractional, required).
  • percentage, vars: same gating as for abort.

type: fault-injection
config:
  delay:
    duration: 0.5
    percentage: 30
  abort:
    http_status: 503
    body: '{"error": "injected for $uri"}'
    percentage: 10
    vars:
      - [["arg_debug", "==", "1"]]

Trait Implementations

impl Plugin for FaultInjectionPlugin

fn plugin_type(&self) -> &str

Unique identifier for the plugin type (e.g., “proxy-rewrite”, “upstream”).

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

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

Executes the plugin logic against the request/response context.