Struct ProxyMirrorPlugin 

pub struct ProxyMirrorPlugin {
    host: String,
    path: Option<String>,
    sample_ratio: f64,
    client: Arc<OutboundClient>,
}

Mirrors matching requests to a shadow host, best-effort.

Fields

host: String

Shadow base URL, e.g. http://shadow:8080 (scheme + host + optional port, no trailing path).

path: Option<String>

Optional path override; when unset the original request path is used.

sample_ratio: f64

Fraction of requests to mirror, in 0.0..=1.0.

client: Arc<OutboundClient>

Shared pooled outbound HTTP client (from PluginResources).

Implementations

impl ProxyMirrorPlugin

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

Builds the plugin from node config.

Accepted keys:

• host (string, required): shadow base URL — scheme + host + optional port, e.g. http://shadow:8080. Must start with http:// or https://; no trailing path.
• path (string, optional): overrides the mirrored request path; when unset the original request path is mirrored. The original query string is always appended.
• sample_ratio (number, default 1.0): fraction of requests to mirror, in 0.0..=1.0. 1.0 mirrors every request; 0.0 mirrors none. Sampling uses a pseudo-random draw (see roll_fraction).

type: proxy-mirror
config:
  host: "http://shadow:8080"
  path: "/mirror"
  sample_ratio: 0.5

fn should_mirror(&self) -> bool

Decides whether this request should be mirrored, per sample_ratio.

>= 1.0 always mirrors, 0.0 never mirrors; otherwise a pseudo-random draw is compared against the ratio.

fn build_request(&self, ctx: &Context) -> OutboundRequest

Builds the outbound mirror request from the current context (pure; does no I/O). The mirrored URL is host + (path override or the original path) + the original query string. All request headers and the body are copied.

Trait Implementations

impl Plugin for ProxyMirrorPlugin

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.