Struct WebhookSubscriber 

pub struct WebhookSubscriber {
    pub id: String,
    pub url: String,
    pub event_pattern: String,
    pub headers: HashMap<String, String>,
    pub retry_count: u32,
    pub timeout_ms: u64,
}

Delivers events via HTTP POST to a webhook URL.

Retry strategy: 2xx = success, 4xx = no retry, 5xx / connection error = retry. Requires the events cargo feature for actual HTTP delivery.

Fields

id: String

url: String

event_pattern: String

headers: HashMap<String, String>

retry_count: u32

timeout_ms: u64

Implementations

impl WebhookSubscriber

pub fn new( id: impl Into<String>, url: impl Into<String>, event_pattern: impl Into<String>, ) -> Self

Trait Implementations

impl Clone for WebhookSubscriber

fn clone(&self) -> WebhookSubscriber

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WebhookSubscriber

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EventSubscriber for WebhookSubscriber

fn subscriber_id(&self) -> &str

Unique ID for this subscriber (used by unsubscribe).

fn event_pattern(&self) -> &str

The event type pattern this subscriber is interested in.

fn on_event<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 ApCoreEvent, ) -> Pin<Box<dyn Future<Output = Result<(), ModuleError>> + Send + 'async_trait>>

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

Handle an incoming event.

fn event_type_filter(&self) -> Option<&str>

The bound event-type string for bulk unsubscription, if set.