Struct EchoPlugin 

pub struct EchoPlugin {
    body: Option<String>,
    before_body: Option<String>,
    after_body: Option<String>,
    headers: HashMap<String, String>,
}

Rewrites the response: body replaces the upstream body, then before_body / after_body are concatenated around it, and headers are set on the response (replacing any existing values, like ngx.header[...]).

Because the body is mutated, the plugin follows featherbit’s body-mutation convention: content-length is removed (the server recomputes it) and a compressed upstream body is decoded first, with content-encoding removed. This plugin never fails at execution time.

Fields

body: Option<String>

Replacement for the upstream response body.

before_body: Option<String>

Prepended to the (possibly replaced) body.

after_body: Option<String>

Appended to the (possibly replaced) body.

headers: HashMap<String, String>

Response headers to set (names lowercased, values replace existing).

Implementations

impl EchoPlugin

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

Builds the plugin from node config.

Accepted keys — at least one of body / before_body / after_body is required (APISIX parity):

• body (string): replaces the upstream response body.
• before_body (string): prepended to the body (after any body replacement).
• after_body (string): appended to the body.
• headers (map {name: value} or array [{name, value}], the UI editor’s form): response headers to set. Values must be scalars (strings, numbers, bools — stringified); names are lowercased; array entries with a blank name are skipped. Existing values for the same header are replaced.

type: echo
config:
  before_body: "before the body modification "
  after_body: " after the body modification"
  headers:
    x-served-by: featherbit

Trait Implementations

impl Plugin for EchoPlugin

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.