Struct AzureFunctionsPlugin 

pub struct AzureFunctionsPlugin {
    function_uri: Template,
    apikey: Option<String>,
    clientid: Option<String>,
    ssl_verify: bool,
    timeout: Duration,
    client: Arc<OutboundClient>,
}

Forwards the request to an Azure Function and maps its reply into Context.response.

Fields

function_uri: Template

Supports {{namespace.path}} template references, rendered per request.

apikey: Option<String>

clientid: Option<String>

ssl_verify: bool

timeout: Duration

client: Arc<OutboundClient>

Implementations

impl AzureFunctionsPlugin

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 Azure Function URL. A missing/empty value is a config-load error.
• authorization (object, optional):
  • apikey (string) — sent as the x-functions-key header.
  • clientid (string) — sent as the x-functions-clientid header.
• ssl_verify (bool, default true): verify TLS certificates.
• timeout (integer ms, default 3000): whole-call deadline.

type: azure-functions
config:
  function_uri: https://app.azurewebsites.net/api/HttpTrigger
  authorization:
    apikey: ${AZURE_FUNCTION_KEY}
  ssl_verify: true
  timeout: 3000

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

Builds the outbound request: the client’s method/body/query forwarded to function_uri plus the Azure function key headers.

Trait Implementations

impl Plugin for AzureFunctionsPlugin

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.