Struct OpenWhiskPlugin 

pub struct OpenWhiskPlugin {
    api_host: String,
    authorization: String,
    namespace: String,
    package: Option<String>,
    action: String,
    result: bool,
    ssl_verify: bool,
    timeout: Duration,
    timeout_ms: u64,
    client: Arc<OutboundClient>,
}

Invokes an OpenWhisk action and maps its reply into Context.response.

Fields

api_host: String

authorization: String

Pre-computed Basic <base64(service_token)> header value.

namespace: String

package: Option<String>

action: String

result: bool

ssl_verify: bool

timeout: Duration

timeout_ms: u64

timeout in milliseconds, passed through as the action query param.

client: Arc<OutboundClient>

Implementations

impl OpenWhiskPlugin

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

Builds the plugin from node config.

Accepted keys:

• api_host (string, required): the OpenWhisk API host (e.g. https://ow.example.com). Missing/empty is a config error.
• service_token (string, required): user:pass action token, sent base64-encoded as HTTP Basic auth. Missing/empty is a config error.
• action (string, required): the action name to invoke.
• namespace (string, default _): the OpenWhisk namespace.
• package (string, optional): the package the action belongs to.
• result (bool, default true): request result=true (inline the action result rather than the full activation record).
• ssl_verify (bool, default true): verify TLS certificates.
• timeout (integer ms, default 3000): whole-call deadline, also passed as the action timeout query parameter.

type: openwhisk
config:
  api_host: https://ow.example.com
  service_token: ${OPENWHISK_TOKEN}
  namespace: guest
  action: hello
  result: true
  ssl_verify: true
  timeout: 3000

fn endpoint(&self) -> String

Builds the OpenWhisk action-invocation URL.

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

Builds the outbound POST request carrying the client body as the action parameters.

Trait Implementations

impl Plugin for OpenWhiskPlugin

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.