Struct AwsLambdaPlugin 

pub struct AwsLambdaPlugin {
    function_uri: String,
    authorization: Authorization,
    ssl_verify: bool,
    timeout: Duration,
    client: Arc<OutboundClient>,
}

Invokes an AWS Lambda function and maps its reply into Context.response.

Fields

function_uri: String

Full Lambda function URL / API endpoint.

authorization: Authorization

ssl_verify: bool

timeout: Duration

client: Arc<OutboundClient>

Implementations

impl AwsLambdaPlugin

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

Builds the plugin from node config.

Accepted keys:

• function_uri (string, required): the Lambda function URL or API endpoint to invoke. A missing/empty value is a config-load error.

• authorization (object, optional): either

  • apikey (string) — sent as the x-api-key header (no signing), or
  • iam (object) — SigV4 credentials:
    • accesskey (string, required)
    • secretkey (string, required)
    • aws_region (string, default us-east-1)
    • aws_service (string, default lambda)
    • session_token (string, optional) — adds x-amz-security-token.

  An iam block missing accesskey/secretkey is a config error.

• ssl_verify (bool, default false): verify TLS certificates.

• timeout (integer ms, default 3000): whole-call deadline.

type: aws-lambda
config:
  function_uri: https://xyz.lambda-url.us-east-1.on.aws/
  authorization:
    iam:
      accesskey: AKIDEXAMPLE
      secretkey: ${AWS_SECRET_KEY}
      aws_region: us-east-1
      aws_service: lambda
  ssl_verify: false
  timeout: 3000

fn build_request( &self, ctx: &Context, amz_time: u64, ) -> Result<OutboundRequest, String>

Assembles the outbound headers, canonical query string, and target URL for the request, applying the configured authorization (API key header or SigV4 signing). amz_time is the signing timestamp (seconds since epoch), threaded in so tests are deterministic.

Trait Implementations

impl Plugin for AwsLambdaPlugin

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.