Struct ExitTransformerPlugin 

pub struct ExitTransformerPlugin {
    status_map: HashMap<u16, u16>,
    body: Option<Template>,
    always: bool,
}

Remaps Context.response.status_code via status_map and/or replaces the body with an interpolated {{namespace.path}} (plus legacy $var) template — but only when the response was generated by the gateway (Context.errors non-empty), unless always is set. This plugin never fails at execution time.

Fields

status_map: HashMap<u16, u16>

body: Option<Template>

Body template: supports {{namespace.path}} references and legacy $var interpolation (see Template::render_with_legacy).

always: bool

Implementations

impl ExitTransformerPlugin

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

Builds the plugin from node config.

Accepted keys (all optional):

• status_map (map of status → status, e.g. "502": 503): when the response status matches a key, it is replaced by the value. Keys are strings (YAML/JSON object keys), values integers; both must be within 100-599.
• body (string): replacement body template. Supports {{namespace.path}} references plus legacy $var / ${var} interpolation — $status (the status after remapping), $uri, $host, $http_<name>, $msg_<key>, and every other variable from crate::vars.
• always (bool, default false): apply to every response. When false, only responses generated by the gateway itself — heuristic: Context.errors is non-empty — are transformed; clean upstream responses pass through untouched.

type: exit-transformer
config:
  status_map:
    "401": 403
    "502": 503
  body: '{"status": $status, "path": "$uri"}'

Trait Implementations

impl Plugin for ExitTransformerPlugin

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.