Struct DegraphqlPlugin 

pub struct DegraphqlPlugin {
    query: String,
    variables: Vec<String>,
    operation_name: Option<String>,
}

Rewrites the request into a GraphQL POST for the configured query.

Only GET and POST requests are accepted (anything else exits through the error port with a 405 and code METHOD_NOT_ALLOWED, mirroring APISIX). Each configured variable name is looked up in the request’s query parameters (first value, as a string) and then in the JSON request body (any JSON type); names found in neither are omitted from variables. A non-empty request body that is not valid JSON fails with a 400 and code INVALID_REQUEST_BODY when body lookups are needed.

Fields

query: String

variables: Vec<String>

operation_name: Option<String>

Implementations

impl DegraphqlPlugin

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

Builds the plugin from node config.

Accepted keys:

• query (string, required, 1–1024 chars): the GraphQL document sent upstream. Checked structurally at config load (balanced braces, a selection set present).
• variables (array of strings, optional): variable names to collect from the request. When present it must be non-empty. When absent, no variables key is sent upstream.
• operation_name (string, optional, 1–1024 chars): sent as operationName for multi-operation documents.

type: degraphql
config:
  query: |
    query ($name: String!) {
      persons(filter: { name: $name }) { id name }
    }
  variables: [name]

fn fail( &self, ctx: Context, status: u16, code: &str, error: &str, message: String, ) -> PluginExecutionError

Builds the error-port rejection with a JSON response body.

Trait Implementations

impl Plugin for DegraphqlPlugin

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.