Struct WebhookTrigger 

pub struct WebhookTrigger { /* private fields */ }

HTTP webhook trigger.

Listens on a specified host:port for incoming HTTP requests. Converts request body to a trigger event.

Configuration

triggers:
  - id: webhook_orders
    type: trigger::webhook
    params:
      host: "0.0.0.0"
      port: 8080
      path: "/orders"
      method: "POST"

Parameters

• host - Host to bind to (default: “0.0.0.0”)
• port - Port to listen on (default: 8080)
• path - URL path to match (default: “/”)
• method - HTTP method to accept (default: “POST”)

Implementations

impl WebhookTrigger

pub fn new(id: impl Into<String>, host: impl Into<String>, port: u16) -> Self

Create a new webhook trigger.

pub fn from_config(config: &TriggerConfig) -> Result<Self>

Create from configuration.

pub fn with_path(self, path: impl Into<String>) -> Self

Set the URL path.

pub fn with_method(self, method: Method) -> Self

Set the HTTP method.

Trait Implementations

impl Trigger for WebhookTrigger

fn trigger_type(&self) -> TriggerType

Get the trigger type.

fn id(&self) -> &str

Get the trigger ID.

fn start<'a>( &'a self, callback: Box<dyn Fn(TriggerEvent) + Send + Sync + 'static>, ) -> TriggerFuture<'a, ()>

Start the trigger.

fn stop<'a>(&'a self) -> TriggerFuture<'a, ()>

Stop the trigger.

fn pause<'a>(&'a self) -> TriggerFuture<'a, ()>

Pause the trigger (stop accepting new events).

fn resume<'a>(&'a self) -> TriggerFuture<'a, ()>

Resume the trigger.

fn is_running(&self) -> bool

Check if the trigger is running.