Struct WebhookTrigger 

pub struct WebhookTrigger { /* private fields */ }

HTTP webhook receiver trigger.

Implementations

impl WebhookTrigger

pub fn new(config: WebhookConfig) -> Self

Create a new WebhookTrigger from config.

Trait Implementations

impl TriggerSource for WebhookTrigger

fn kind(&self) -> &'static str

Unique, stable identifier for this trigger kind (e.g. "cdc", "email").

fn start<'life0, 'async_trait>( &'life0 self, on_event: EventCallback, ) -> Pin<Box<dyn Future<Output = Result<(), TriggerFault>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start watching for events.

fn pause<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TriggerFault>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Pause the trigger without destroying source state.

fn resume<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TriggerFault>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Resume after a previous pause.

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TriggerFault>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gracefully stop the trigger and release all resources.